Merge pull request #51 from funkelab/dev/master

Increase max message size assertion in TCPStream class
funkelab · Mar 17, 2024 · 750e8ca · 750e8ca
2 parents fd10335 + b688d2f
commit 750e8ca
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/daisy/tcp/tcp_stream.py b/daisy/tcp/tcp_stream.py
@@ -95,7 +95,8 @@ async def _get_message(self):
 
             size = await self.stream.read_bytes(4)
             size = struct.unpack("I", size)[0]
-            assert size < 65535  # TODO: parameterize max message size
+            assert size < 2**64  # TODO: parameterize max message size
+            # assert size < 2**16  # TODO: parameterize max message size
             pickled_data = await self.stream.read_bytes(size)
 
         except tornado.iostream.StreamClosedError: