@@ -433,7 +433,6 @@ def _exit_tasks():
433433 max_size = self .max_frame_size ,
434434 server_hostname = server_hostname ,
435435 sock = sock ,
436- close_timeout = 1 ,
437436 )), url , endpoint , cacert
438437
439438 async def close (self , to_reconnect = False ):
@@ -645,7 +644,7 @@ async def rpc(self, msg, encoder=None):
645644 if "version" not in msg :
646645 msg ['version' ] = self .facades [msg ['type' ]]
647646 outgoing = json .dumps (msg , indent = 2 , cls = encoder )
648- log .debug ('connection id: {} -- sending {}' .format (id (self ), outgoing ))
647+ log .debug ('connection id: {} ---> {}' .format (id (self ), outgoing ))
649648 for attempt in range (3 ):
650649 if self .monitor .status == Monitor .DISCONNECTED :
651650 # closed cleanly; shouldn't try to reconnect
@@ -668,7 +667,7 @@ async def rpc(self, msg, encoder=None):
668667 log .error ('RPC: Automatic reconnect failed' )
669668 raise
670669 result = await self ._recv (msg ['request-id' ])
671- log .debug ('connection id : {} -- receiving {}' .format (id (self ), result ))
670+ log .debug ('connection id : {} <--- {}' .format (id (self ), result ))
672671
673672 if not result :
674673 return result
0 commit comments