Mirror/wfb-ng
5
0
Fork 1
mirror of https://github.com/svpcom/wfb-ng.git synced 2025-03-19 04:54:11 -03:00
Code Issues Actions Packages Projects Releases Wiki Activity

Small refactoring

Browse Source
This commit is contained in:
Vasily Evseenko 2019-11-12 00:14:04 +03:00
parent b0b88d7ac3
commit 5474bf9122
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
telemetry/proxy.py
View File

@ -58,9 +58,9 @@ class UDPProxyProtocol(DatagramProtocol):
def flush_queue(self): def flush_queue(self):
if self.agg_queue_size > 0: if self.agg_queue_size > 0:
if self.agg_queue_timer is not None: if self.agg_queue_timer is not None \
if not self.agg_queue_timer.called: and not self.agg_queue_timer.called:
self.agg_queue_timer.cancel() self.agg_queue_timer.cancel()
self.agg_queue_timer = None self.agg_queue_timer = None
self._send_to_peer(b''.join(self.agg_queue)) self._send_to_peer(b''.join(self.agg_queue))
self.agg_queue = [] self.agg_queue = []