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

Set self.working

Browse Source
This commit is contained in:
Davte 2020-04-09 23:06:55 +02:00
parent ca3aa5857b
commit 1ec3a4b5e2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/server.py
View File

@ -91,8 +91,8 @@ class Server:
peer_is_sender = client_hello.decode('utf-8') == 'sender\n' peer_is_sender = client_hello.decode('utf-8') == 'sender\n'
writer.write("Start!\n".encode('utf-8')) # Send start signal to client writer.write("Start!\n".encode('utf-8')) # Send start signal to client
await writer.drain() await writer.drain()
self._working = True
if peer_is_sender: if peer_is_sender:
self._working = True
logging.info("Sender is connecting...") logging.info("Sender is connecting...")
await self.run_reader(reader=reader) await self.run_reader(reader=reader)
logging.info("Incoming transmission ended") logging.info("Incoming transmission ended")
@ -100,7 +100,7 @@ class Server:
logging.info("Receiver is connecting...") logging.info("Receiver is connecting...")
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 # Reset peer_is_sender self._working = False
return return
def run(self): def run(self):