From 6e2e1a20385ed0434e591c5b2957fe8a27cd6eee Mon Sep 17 00:00:00 2001
From: Hang <hang@Hangs-MacBook-Pro.local>
Date: Tue, 26 Apr 2022 15:44:50 -0500
Subject: [PATCH] fast push
---
mp3/server.py | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/mp3/server.py b/mp3/server.py
index 05e3e09..e2d6a7c 100644
--- a/mp3/server.py
+++ b/mp3/server.py
@@ -461,6 +461,8 @@ def connect_with_all_servers(servers: dict, current_server_id: str, return_value
host_ip_address = SERVER_ID_TO_IP_MAPPING[server[SERVER_IDENTIFIER]]
# server[SERVER_PORT] = SERVERS[CURRENT_SERVER_ID][SERVER_PORT]+1 # todo: to be deleted
address = (host_ip_address, SERVERS[server_id][ACCEPTING_PEER_PORT])
+ pprint(f"[connect_with_all_servers] - {CURRENT_SERVER_ID} is trying to "
+ f"connect {(host_ip_address, SERVERS[server_id][ACCEPTING_PEER_PORT])}")
s.connect(address)
connect_info[server_id] = s
gprint(f"[Connect] - "
@@ -726,6 +728,8 @@ def accepting_peer_servers(SELF_NODE):
try:
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind((CURRENT_SERVER_IP, SERVERS[CURRENT_SERVER_ID][ACCEPTING_PEER_PORT]))
+ pprint(f'[accepting_peer_servers] - {CURRENT_SERVER_ID} current '
+ f'bind at {(CURRENT_SERVER_IP, SERVERS[CURRENT_SERVER_ID][ACCEPTING_PEER_PORT])}')
server.listen()
# print(f"[LISTENING] Server is listening on {ADDR}") # DEBUG
while True:
--
GitLab