mirror of
https://github.com/saltstack/salt.git
synced 2025-04-17 10:10:20 +00:00
Stop socket before queue on delete
This commit is contained in:
parent
9587f5c69e
commit
dbe671f943
1 changed files with 2 additions and 2 deletions
|
@ -545,8 +545,6 @@ class TCPReqServerChannel(salt.transport.mixins.auth.AESReqServerMixin, salt.tra
|
|||
return self._socket
|
||||
|
||||
def close(self):
|
||||
if hasattr(self.req_server, 'stop'):
|
||||
self.req_server.stop()
|
||||
if self._socket is not None:
|
||||
try:
|
||||
self._socket.shutdown(socket.SHUT_RDWR)
|
||||
|
@ -559,6 +557,8 @@ class TCPReqServerChannel(salt.transport.mixins.auth.AESReqServerMixin, salt.tra
|
|||
raise exc
|
||||
self._socket.close()
|
||||
self._socket = None
|
||||
if hasattr(self.req_server, 'stop'):
|
||||
self.req_server.stop()
|
||||
|
||||
def __del__(self):
|
||||
self.close()
|
||||
|
|
Loading…
Add table
Reference in a new issue