We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c60580b commit 96310f6Copy full SHA for 96310f6
logstash_async/transport.py
@@ -133,10 +133,12 @@ def _convert_data_to_send(self, data):
133
def _close(self, force=False):
134
if not self._keep_connection or force:
135
if self._sock:
136
- self._wait_for_socket_buffer_empty()
137
- self._sock.shutdown(socket.SHUT_WR)
138
- self._sock.close()
139
- self._sock = None
+ try:
+ self._wait_for_socket_buffer_empty()
+ self._sock.shutdown(socket.SHUT_WR)
+ self._sock.close()
140
+ finally:
141
+ self._sock = None
142
143
# ----------------------------------------------------------------------
144
def _wait_for_socket_buffer_empty(self):
0 commit comments