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

Test 8

Browse Source
This commit is contained in:
Davte 2020-04-19 19:56:43 +02:00
parent f52429fc4d
commit 14992dd19b
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
filebridging/client.py
View File

@ -436,7 +436,6 @@ class Client:
force=(new_progress == 100) force=(new_progress == 100)
) )
if not input_data: if not input_data:
continue
break break
file_to_receive.write(input_data) file_to_receive.write(input_data)
print() # New line after sys.stdout.write print() # New line after sys.stdout.write

6
filebridging/server.py
View File

@ -96,6 +96,7 @@ class Server:
async def run_writer(self, writer, connection_token): async def run_writer(self, writer, connection_token):
consecutive_interruptions = 0 consecutive_interruptions = 0
errors = 0 errors = 0
r = 0
while connection_token in self.buffers: while connection_token in self.buffers:
try: try:
input_data = self.buffers[connection_token].popleft() input_data = self.buffers[connection_token].popleft()
@ -109,10 +110,9 @@ class Server:
continue continue
else: else:
consecutive_interruptions = 0 consecutive_interruptions = 0
r += len(input_data)
if not input_data: if not input_data:
print("No input data received") print(r)
await asyncio.sleep(.5)
continue
break break
try: try:
writer.write(input_data) writer.write(input_data)