Skip to content

Commit 501bb98

Browse files
committed
Reset variables are moved to inside lock
1 parent c1e5b29 commit 501bb98

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

fluent/sender.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,11 +81,12 @@ def close(self):
8181
self._send_data(self.pendings)
8282
except Exception:
8383
self._call_buffer_overflow_handler(self.pendings)
84+
85+
self._close()
86+
self.pendings = None
8487
finally:
8588
self.lock.release()
8689

87-
self._close()
88-
self.pendings = None
8990

9091
def _make_packet(self, label, timestamp, data):
9192
if label:

0 commit comments

Comments
 (0)