fix delays in sending/receiving messages between pox and pyretic

frenetic-lang · Mar 10, 2016 · 4e81651 · 4e81651
1 parent 737f63a
commit 4e81651
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/of_client/pox_client.py b/of_client/pox_client.py
@@ -68,8 +68,10 @@ def __init__(self, host, port, of_client):
         asynchat.async_chat.__init__(self)
         self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
         self.connect((host, port))
-        self.ac_in_buffer_size = 4096 * 3
-        self.ac_out_buffer_size = 4096 * 3
+        # If there are delays in receiving messages from the other side, and
+        # they are because of large message sizes, increase this buffer size.
+        self.ac_in_buffer_size = 4096 * 5
+        self.ac_out_buffer_size = 4096 * 5
         self.set_terminator(TERM_CHAR)
         self.start_time = 0
         self.interval = 0

diff --git a/pyretic/backend/backend.py b/pyretic/backend/backend.py
@@ -66,8 +66,10 @@ def __init__(self, backend, sock):
         self.backend = backend
         self.received_data = []
         asynchat.async_chat.__init__(self, sock)
-        self.ac_in_buffer_size = 4096 * 3
-        self.ac_out_buffer_size = 4096 * 3
+        # If there are delays in receiving messages from the other side, and
+        # they are because of large message sizes, increase this buffer size.
+        self.ac_in_buffer_size = 4096 * 5
+        self.ac_out_buffer_size = 4096 * 5
         self.set_terminator(TERM_CHAR)
         return