Handle zero agg_timeout properly

svpcom · Dec 30, 2024 · 44a9653 · 44a9653
1 parent bb03607
commit 44a9653
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/wfb_ng/proxy.py b/wfb_ng/proxy.py
@@ -60,7 +60,7 @@ def _send_to_peer(self, data):
 
     def messageReceived(self, data):
         # send message to local transport
-        if self.agg_max_size is None or self.agg_timeout is None:
+        if self.agg_max_size is None or not self.agg_timeout:
             return self._send_to_peer(data)
 
         if len(data) > self.agg_max_size:
@@ -174,7 +174,7 @@ def write(self, msg):
             self.transport.write(msg, self.mirror)
 
         # Send non-aggregated packets directly
-        if self.agg_max_size is None or self.agg_timeout is None:
+        if self.agg_max_size is None or not self.agg_timeout:
             self.transport.write(msg, self.reply_addr)
             return