Davte/filebridging
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Misplacement of writer.drain()

Browse Source
This commit is contained in:
Davte 2020-04-10 16:09:39 +02:00
parent f1d54861ee
commit c0dd046670
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/server.py
View File

@ -105,12 +105,12 @@ class Server:
""" """
client_hello = await reader.readline() client_hello = await reader.readline()
peer_is_sender = client_hello.decode('utf-8') == 'sender\n' peer_is_sender = client_hello.decode('utf-8') == 'sender\n'
await writer.drain()
if peer_is_sender: if peer_is_sender:
self._working = True self._working = True
logging.info("Sender is connecting...") logging.info("Sender is connecting...")
# Send start signal to client # Send start signal to client
writer.write("Start!\n".encode('utf-8')) writer.write("Start!\n".encode('utf-8'))
await writer.drain()
await self.run_reader(reader=reader) await self.run_reader(reader=reader)
logging.info("Incoming transmission ended") logging.info("Incoming transmission ended")
else: else:
@ -119,6 +119,7 @@ class Server:
await asyncio.sleep(.5) await asyncio.sleep(.5)
# Send start signal to client # Send start signal to client
writer.write("Start!\n".encode('utf-8')) writer.write("Start!\n".encode('utf-8'))
await writer.drain()
await self.run_writer(writer=writer) await self.run_writer(writer=writer)
logging.info("Outgoing transmission ended") logging.info("Outgoing transmission ended")
self._working = False self._working = False