Update peer.py
add print statements
This commit is contained in:
1 parent
8915eab209
commit
d6938f088e
1 file changed
+8
@@ -24,6 +24,7 @@ members_list[SELF_ID] = {
|
|||||||
"heart_beat": 1,
|
"heart_beat": 1,
|
||||||
"last_seen": utc_time()
|
"last_seen": utc_time()
|
||||||
}
|
}
|
||||||
|
print(f"Starting peer: IP={IP}, port={SERVER_PORT}, introducer={INTRODUCER_FLAG}, self_id={SELF_ID}")
|
||||||
|
|
||||||
stop_event = threading.Event()
|
stop_event = threading.Event()
|
||||||
|
|
||||||
@@ -49,6 +50,7 @@ def worker_1():
|
|||||||
continue
|
continue
|
||||||
|
|
||||||
msg_type = msg.get("type")
|
msg_type = msg.get("type")
|
||||||
|
print(f"Processing message type={msg_type} from {addr}")
|
||||||
|
|
||||||
if msg_type == "JOIN":
|
if msg_type == "JOIN":
|
||||||
join_ip, join_port, join_timestamp = msg["sender_id"]
|
join_ip, join_port, join_timestamp = msg["sender_id"]
|
||||||
@@ -60,6 +62,7 @@ def worker_1():
|
|||||||
"heart_beat": 1,
|
"heart_beat": 1,
|
||||||
"last_seen": utc_time()
|
"last_seen": utc_time()
|
||||||
}
|
}
|
||||||
|
print(f"Added member: {join_id}")
|
||||||
|
|
||||||
members_payload = []
|
members_payload = []
|
||||||
for m_id, m_data in members_list.items():
|
for m_id, m_data in members_list.items():
|
||||||
@@ -79,6 +82,7 @@ def worker_1():
|
|||||||
"members": members_payload
|
"members": members_payload
|
||||||
}
|
}
|
||||||
server_socket.sendto(json.dumps(reply_payload).encode('utf-8'), (join_ip, join_port))
|
server_socket.sendto(json.dumps(reply_payload).encode('utf-8'), (join_ip, join_port))
|
||||||
|
print(f"Sent initial membership state to {(join_ip, join_port)}: {reply_payload}")
|
||||||
|
|
||||||
elif msg_type == "GOSSIP":
|
elif msg_type == "GOSSIP":
|
||||||
members_json = msg.get('members', [])
|
members_json = msg.get('members', [])
|
||||||
@@ -96,9 +100,11 @@ def worker_1():
|
|||||||
"heart_beat": member_hb,
|
"heart_beat": member_hb,
|
||||||
"last_seen": utc_time()
|
"last_seen": utc_time()
|
||||||
}
|
}
|
||||||
|
print(f"Added gossip member: {member_id}, heartbeat={member_hb}")
|
||||||
elif member_hb > members_list[member_id]["heart_beat"]:
|
elif member_hb > members_list[member_id]["heart_beat"]:
|
||||||
members_list[member_id]["heart_beat"] = member_hb
|
members_list[member_id]["heart_beat"] = member_hb
|
||||||
members_list[member_id]["last_seen"] = utc_time()
|
members_list[member_id]["last_seen"] = utc_time()
|
||||||
|
print(f"Updated member: {member_id}, heartbeat={member_hb}")
|
||||||
|
|
||||||
except socket.timeout:
|
except socket.timeout:
|
||||||
continue
|
continue
|
||||||
@@ -107,6 +113,7 @@ def worker_2():
|
|||||||
while not stop_event.is_set():
|
while not stop_event.is_set():
|
||||||
with members_list_lock:
|
with members_list_lock:
|
||||||
members_list[SELF_ID]["heart_beat"] += 1
|
members_list[SELF_ID]["heart_beat"] += 1
|
||||||
|
print(f"Updated my heartbeat: {members_list[SELF_ID]['heart_beat']}")
|
||||||
time.sleep(HEART_BEAT_INTERVAL)
|
time.sleep(HEART_BEAT_INTERVAL)
|
||||||
|
|
||||||
def worker_3():
|
def worker_3():
|
||||||
@@ -137,6 +144,7 @@ def worker_3():
|
|||||||
}
|
}
|
||||||
|
|
||||||
json_string = json.dumps(payload)
|
json_string = json.dumps(payload)
|
||||||
|
print(f"Sending GOSSIP to {(peer_ip, peer_port)}: {payload}")
|
||||||
server_socket.sendto(json_string.encode('utf-8'), (peer_ip, peer_port))
|
server_socket.sendto(json_string.encode('utf-8'), (peer_ip, peer_port))
|
||||||
|
|
||||||
time.sleep(GOSSIP_INTERVAL)
|
time.sleep(GOSSIP_INTERVAL)
|
||||||
|
|||||||
Reference in new issue
Block a user