File tree 1 file changed +3
-2
lines changed
1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -293,7 +293,7 @@ async def getstream(self, **kwargs):
293
293
)
294
294
self .unpacker = salt .utils .msgpack .Unpacker ()
295
295
log .debug (
296
- "PubClient conencted to %r %r:%r" , self , self .host , self .port
296
+ "PubClient connected to %r %r:%r" , self , self .host , self .port
297
297
)
298
298
else :
299
299
log .debug ("PubClient connecting to %r %r" , self , self .path )
@@ -303,7 +303,7 @@ async def getstream(self, **kwargs):
303
303
)
304
304
await asyncio .wait_for (stream .connect (self .path ), 1 )
305
305
self .unpacker = salt .utils .msgpack .Unpacker ()
306
- log .debug ("PubClient conencted to %r %r" , self , self .path )
306
+ log .debug ("PubClient connected to %r %r" , self , self .path )
307
307
except Exception as exc : # pylint: disable=broad-except
308
308
if self .path :
309
309
_connect_to = self .path
@@ -1896,6 +1896,7 @@ async def _do_send():
1896
1896
def close (self ):
1897
1897
if self ._closing :
1898
1898
return
1899
+ self ._closing = True
1899
1900
if self ._stream is not None :
1900
1901
self ._stream .close ()
1901
1902
self ._stream = None
You can’t perform that action at this time.
0 commit comments