diff options
| author | Evgeny Zinoviev <me@ch1p.io> | 2022-07-02 15:42:23 +0300 |
|---|---|---|
| committer | Evgeny Zinoviev <me@ch1p.io> | 2022-07-02 15:42:23 +0300 |
| commit | 4f04fe96a82dd2a2f36dd445f997b04d4f120324 (patch) | |
| tree | ab61da321003394fe4d62c9b1fb876aa3dfa01bb | |
| parent | 9b280e35186a3f0078a39ca013454cc8d0c21d62 (diff) | |
polaris/protocol: delete PingMessage from queue immediately, just like ACK/NAKs
| -rw-r--r-- | src/polaris/protocol.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/polaris/protocol.py b/src/polaris/protocol.py index d562ff9..c145009 100644 --- a/src/polaris/protocol.py +++ b/src/polaris/protocol.py @@ -989,7 +989,7 @@ class UDPConnection(threading.Thread, ConnectionStatusListener): remove_list = [] for wm in self.outgoing_queue: if wm.phase == MessagePhase.DONE: - if isinstance(wm.message, (AckMessage, NakMessage)) or time.time() - wm.phase_update_time >= MESSAGE_QUEUE_REMOVE_DELAY: + if isinstance(wm.message, (AckMessage, NakMessage, PingMessage)) or time.time() - wm.phase_update_time >= MESSAGE_QUEUE_REMOVE_DELAY: remove_list.append(wm) continue message = wm |