|
@@ -91,10 +91,9 @@ class Server:
|
|
|
break
|
|
break
|
|
|
except Exception as e:
|
|
except Exception as e:
|
|
|
logging.error(f"Unexpected exception:\n{e}", exc_info=True)
|
|
logging.error(f"Unexpected exception:\n{e}", exc_info=True)
|
|
|
- print(received_bytes)
|
|
|
|
|
|
|
+ print(f"received_bytes: {received_bytes}")
|
|
|
|
|
|
|
|
async def run_writer(self, writer, connection_token):
|
|
async def run_writer(self, writer, connection_token):
|
|
|
- print("ERRRR")
|
|
|
|
|
consecutive_interruptions = 0
|
|
consecutive_interruptions = 0
|
|
|
errors = 0
|
|
errors = 0
|
|
|
r = 0
|
|
r = 0
|
|
@@ -113,7 +112,7 @@ class Server:
|
|
|
consecutive_interruptions = 0
|
|
consecutive_interruptions = 0
|
|
|
r += len(input_data)
|
|
r += len(input_data)
|
|
|
if not input_data:
|
|
if not input_data:
|
|
|
- print(r)
|
|
|
|
|
|
|
+ print(f"Sent bytes: {r}")
|
|
|
break
|
|
break
|
|
|
try:
|
|
try:
|
|
|
writer.write(input_data)
|
|
writer.write(input_data)
|
