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

protocols/pipe_ipc: raise line length limit

This commit is contained in:
Sebastien Bourdeauducq 2016-03-23 15:12:29 +08:00
parent 799c2c77c4
commit 120db8ba08
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) reader = asyncio.StreamReader(loop=loop, limit=4*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) reader = asyncio.StreamReader(loop=loop, limit=4*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) self.reader = asyncio.StreamReader(loop=loop, limit=4*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(