Skip to content
Snippets Groups Projects
Commit 6e00ddc0 authored by Hang's avatar Hang
Browse files

fast push

parent 9bc501aa
No related branches found
No related tags found
1 merge request!10MP3 Log Version Ready
...@@ -645,6 +645,9 @@ def client_handler(conn, SELF_NODE): ...@@ -645,6 +645,9 @@ def client_handler(conn, SELF_NODE):
broadcast_msg(format_operation_and_timestamp_json('ABORT', timestamp), connect_info) broadcast_msg(format_operation_and_timestamp_json('ABORT', timestamp), connect_info)
abort(SELF_NODE, timestamp) abort(SELF_NODE, timestamp)
if operation.startswith('BALANCE'):
account_name = operation.split()[1]
ret_value = f'{account_name} = {ret_value}'
send_msg_to_socket(ret_value, conn) send_msg_to_socket(ret_value, conn)
except Exception as e: except Exception as e:
rprint(f"[ERROR] client_handler error:{e.__class__.__name__}.{e}.{traceback.format_exc()}") rprint(f"[ERROR] client_handler error:{e.__class__.__name__}.{e}.{traceback.format_exc()}")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment