occheung/artiq
1
0
Fork 0
forked from M-Labs/artiq
Code Pull Requests Activity

protocols: increase another asyncio line limit (#671)

Browse Source
This commit is contained in:
Chris Ballance 2017-06-21 18:09:43 +01:00 committed by Sébastien Bourdeauducq
parent e3588c9e68
commit 05b57f5110
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
artiq/protocols/pipe_ipc.py
View File

@ -22,7 +22,7 @@ class _BaseIO:
if os.name != "nt": if os.name != "nt":
async def _fds_to_asyncio(rfd, wfd, loop): 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) reader_protocol = asyncio.StreamReaderProtocol(reader, loop=loop)
rf = open(rfd, "rb", 0) rf = open(rfd, "rb", 0)
rt, _ = await loop.connect_read_pipe(lambda: reader_protocol, rf) rt, _ = await loop.connect_read_pipe(lambda: reader_protocol, rf)
@ -128,7 +128,7 @@ else: # windows
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
def factory(): def factory():
reader = asyncio.StreamReader(loop=loop, limit=4*1024*1024) reader = asyncio.StreamReader(loop=loop, limit=100*1024*1024)
protocol = asyncio.StreamReaderProtocol(reader, protocol = asyncio.StreamReaderProtocol(reader,
self._child_connected, self._child_connected,
loop=loop) loop=loop)
@ -189,7 +189,7 @@ else: # windows
async def connect(self): async def connect(self):
loop = asyncio.get_event_loop() 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( reader_protocol = asyncio.StreamReaderProtocol(
self.reader, loop=loop) self.reader, loop=loop)
transport, _ = await loop.create_pipe_connection( transport, _ = await loop.create_pipe_connection(