M-Labs/artiq
2
0
Fork 2
mirror of https://github.com/m-labs/artiq.git synced 2024-12-25 11:18:27 +08:00
Code Issues Projects Releases Wiki Activity

protocols: increase asyncio line limit. Closes #671

Browse Source
This commit is contained in:
Sebastien Bourdeauducq 2017-02-17 20:46:23 +08:00
parent f5cd0928c3
commit c777ae8ae9
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artiq/protocols/broadcast.py
View File

@ -17,7 +17,7 @@ class Receiver:
async def connect(self, host, port): async def connect(self, host, port):
self.reader, self.writer = \ self.reader, self.writer = \
await asyncio.open_connection(host, port, limit=4*1024*1024) await asyncio.open_connection(host, port, limit=100*1024*1024)
try: try:
self.writer.write(_init_string) self.writer.write(_init_string)
self.writer.write((self.name + "\n").encode()) self.writer.write((self.name + "\n").encode())

2
artiq/protocols/pc_rpc.py
View File

@ -201,7 +201,7 @@ class AsyncioClient:
this method is a coroutine. See ``Client`` for a description of the this method is a coroutine. See ``Client`` for a description of the
parameters.""" parameters."""
self.__reader, self.__writer = \ self.__reader, self.__writer = \
await asyncio.open_connection(host, port, limit=4*1024*1024) await asyncio.open_connection(host, port, limit=100*1024*1024)
try: try:
self.__writer.write(_init_string) self.__writer.write(_init_string)
server_identification = await self.__recv() server_identification = await self.__recv()

2
artiq/protocols/sync_struct.py
View File

@ -64,7 +64,7 @@ class Subscriber:
async def connect(self, host, port, before_receive_cb=None): async def connect(self, host, port, before_receive_cb=None):
self.reader, self.writer = \ self.reader, self.writer = \
await asyncio.open_connection(host, port, limit=4*1024*1024) await asyncio.open_connection(host, port, limit=100*1024*1024)
try: try:
if before_receive_cb is not None: if before_receive_cb is not None:
before_receive_cb() before_receive_cb()