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

sync_struct: Tweak variable name to avoid confusion with `init` mod action [nfc]

This commit is contained in:
David Nadlinger 2018-03-08 18:18:52 +00:00
parent 90c144a685
commit bd71852427
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/sync_struct.py
View File

@ -19,7 +19,7 @@ from artiq.protocols import pyon
from artiq.protocols.asyncio_server import AsyncioServer from artiq.protocols.asyncio_server import AsyncioServer
_init_string = b"ARTIQ sync_struct\n" _protocol_banner = b"ARTIQ sync_struct\n"
def process_mod(target, mod): def process_mod(target, mod):
@ -71,7 +71,7 @@ class Subscriber:
try: try:
if before_receive_cb is not None: if before_receive_cb is not None:
before_receive_cb() before_receive_cb()
self.writer.write(_init_string) self.writer.write(_protocol_banner)
self.writer.write((self.notifier_name + "\n").encode()) self.writer.write((self.notifier_name + "\n").encode())
self.receive_task = asyncio.ensure_future(self._receive_cr()) self.receive_task = asyncio.ensure_future(self._receive_cr())
except: except:
@ -217,7 +217,7 @@ class Publisher(AsyncioServer):
async def _handle_connection_cr(self, reader, writer): async def _handle_connection_cr(self, reader, writer):
try: try:
line = await reader.readline() line = await reader.readline()
if line != _init_string: if line != _protocol_banner:
return return
line = await reader.readline() line = await reader.readline()