From 120db8ba08aed8db071d0486e16c1bfe6cb2fa21 Mon Sep 17 00:00:00 2001 From: Sebastien Bourdeauducq Date: Wed, 23 Mar 2016 15:12:29 +0800 Subject: [PATCH] protocols/pipe_ipc: raise line length limit --- artiq/protocols/pipe_ipc.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/artiq/protocols/pipe_ipc.py b/artiq/protocols/pipe_ipc.py index c32f74b8f..b83f9f1f4 100644 --- a/artiq/protocols/pipe_ipc.py +++ b/artiq/protocols/pipe_ipc.py @@ -22,7 +22,7 @@ class _BaseIO: 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 @@ else: # windows 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 @@ else: # windows 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(