From 05b57f5110f61fe3d84f1d9daaa514d149f0eb9d Mon Sep 17 00:00:00 2001 From: Chris Ballance Date: Wed, 21 Jun 2017 18:09:43 +0100 Subject: [PATCH] protocols: increase another asyncio line limit (#671) --- 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 b83f9f1f4..e81176c4e 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, limit=4*1024*1024) + reader = asyncio.StreamReader(loop=loop, limit=100*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, limit=4*1024*1024) + reader = asyncio.StreamReader(loop=loop, limit=100*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, limit=4*1024*1024) + self.reader = asyncio.StreamReader(loop=loop, limit=100*1024*1024) reader_protocol = asyncio.StreamReaderProtocol( self.reader, loop=loop) transport, _ = await loop.create_pipe_connection(