From 511fdfe6c13b0c536d788c3cd02617bd51f25935 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 15 Aug 2024 16:35:55 -0400 Subject: [PATCH] Fix issues in the online debugger --- confluent_server/confluent/debugger.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/debugger.py b/confluent_server/confluent/debugger.py index 6924f8d1..ea7c600c 100644 --- a/confluent_server/confluent/debugger.py +++ b/confluent_server/confluent/debugger.py @@ -24,6 +24,8 @@ async def interact(cloop, cnn): newinput = b'' while b'\n' not in newinput: rcv = await cloop.sock_recv(cnn, 4) + if not rcv: + return newinput += rcv somecode += newinput.decode() if newinput.startswith(b' '): @@ -48,7 +50,6 @@ async def interact(cloop, cnn): finally: sys.stdin, sys.stderr, sys.stdout = saved cnn.settimeout(0) - print("done") somecode = '' prompt = b'>>> ' @@ -56,9 +57,10 @@ async def interact(cloop, cnn): async def srv_debug(sock): cloop = asyncio.get_event_loop() while True: + print("waiting") cnn, addr = await cloop.sock_accept(sock) - cnn.settimeout(0) util.spawn(interact(cloop, cnn)) + print("next time") def start_dbgif():