Commit 34c276b8 authored by Julien Muchembled's avatar Julien Muchembled

Process remaining received packets when closing a connection

This fixes admin not always forwarding error packets from master to neoctl.
parent 72277c38
...@@ -541,6 +541,8 @@ class Connection(BaseConnection): ...@@ -541,6 +541,8 @@ class Connection(BaseConnection):
def _closure(self): def _closure(self):
assert self.connector is not None, self.whoSetConnector() assert self.connector is not None, self.whoSetConnector()
while self._queue:
self._handlers.handle(self, self._queue.pop(0))
self.close() self.close()
@profiler_decorator @profiler_decorator
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment