protocols/pipe_ipc: raise line length limit

sbourdeauducq · sbourdeauducq · commit bbef353057be · 2016-03-23T15:14:24.000+08:00
diff --git a/artiq/protocols/pipe_ipc.py b/artiq/protocols/pipe_ipc.py
@@ -22,7 +22,7 @@ async def read(self, n):
 
 if os.name != "nt":
     async def _fds_to_asyncio(rfd, wfd, loop):
-        reader = asyncio.StreamReader(loop=loop)
+        reader = asyncio.StreamReader(loop=loop, limit=4*1024*1024)
         reader_protocol = asyncio.StreamReaderProtocol(reader, loop=loop)
         rf = open(rfd, "rb", 0)
         rt, _ = await loop.connect_read_pipe(lambda: reader_protocol, rf)
@@ -128,7 +128,7 @@ async def create_subprocess(self, *args, **kwargs):
             loop = asyncio.get_event_loop()
 
             def factory():
-                reader = asyncio.StreamReader(loop=loop)
+                reader = asyncio.StreamReader(loop=loop, limit=4*1024*1024)
                 protocol = asyncio.StreamReaderProtocol(reader,
                                                 self._child_connected,
                                                 loop=loop)
@@ -189,7 +189,7 @@ def __init__(self, address):
 
         async def connect(self):
             loop = asyncio.get_event_loop()
-            self.reader = asyncio.StreamReader(loop=loop)
+            self.reader = asyncio.StreamReader(loop=loop, limit=4*1024*1024)
             reader_protocol = asyncio.StreamReaderProtocol(
                 self.reader, loop=loop)
             transport, _ = await loop.create_pipe_connection(
