diff --git a/artiq/protocols/broadcast.py b/artiq/protocols/broadcast.py
index 9cffc6b78..74ae20b1b 100644
--- a/artiq/protocols/broadcast.py
+++ b/artiq/protocols/broadcast.py
@@ -17,7 +17,7 @@ class Receiver:
 
     async def connect(self, host, port):
         self.reader, self.writer = \
-            await asyncio.open_connection(host, port, limit=4*1024*1024)
+            await asyncio.open_connection(host, port, limit=100*1024*1024)
         try:
             self.writer.write(_init_string)
             self.writer.write((self.name + "\n").encode())
diff --git a/artiq/protocols/pc_rpc.py b/artiq/protocols/pc_rpc.py
index ca3c356f2..e50b39f74 100644
--- a/artiq/protocols/pc_rpc.py
+++ b/artiq/protocols/pc_rpc.py
@@ -201,7 +201,7 @@ class AsyncioClient:
         this method is a coroutine. See ``Client`` for a description of the
         parameters."""
         self.__reader, self.__writer = \
-            await asyncio.open_connection(host, port, limit=4*1024*1024)
+            await asyncio.open_connection(host, port, limit=100*1024*1024)
         try:
             self.__writer.write(_init_string)
             server_identification = await self.__recv()
diff --git a/artiq/protocols/sync_struct.py b/artiq/protocols/sync_struct.py
index 59bced790..574a76485 100644
--- a/artiq/protocols/sync_struct.py
+++ b/artiq/protocols/sync_struct.py
@@ -64,7 +64,7 @@ class Subscriber:
 
     async def connect(self, host, port, before_receive_cb=None):
         self.reader, self.writer = \
-            await asyncio.open_connection(host, port, limit=4*1024*1024)
+            await asyncio.open_connection(host, port, limit=100*1024*1024)
         try:
             if before_receive_cb is not None:
                 before_receive_cb()