From db037f4f42fa165680ce26dabb0ff94b2b426c4a Mon Sep 17 00:00:00 2001 From: Aryan Singh Date: Fri, 25 Sep 2026 22:57:39 -0500 Subject: [PATCH] adding monitoring --- MP2/peer.py | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/MP2/peer.py b/MP2/peer.py index 060d635..859237e 100644 --- a/MP2/peer.py +++ b/MP2/peer.py @@ -149,14 +149,31 @@ def worker_3(): time.sleep(GOSSIP_INTERVAL) +#only for debuging +def worker_monitoring(): + while not stop_event.is_set(): + with members_list_lock: + local_ml = { + member_id: member_data.copy(), + for member_id , member_data in members_list.items() + } + + with open("membership_list.txt", "w") as f: + for member_id, member_data in local_ml.items(): + f.write(f"{member_id}: {member_data}\n") + time.sleep(0.5) + t1 = threading.Thread(target=worker_1) t2 = threading.Thread(target=worker_2) t3 = threading.Thread(target=worker_3) +#only for debugging +t4 = threading.Thread(target=worker_monitoring) t1.start() t2.start() t3.start() +t4.start() try: while not stop_event.is_set(): @@ -168,4 +185,5 @@ except KeyboardInterrupt: t1.join() t2.join() t3.join() +t4.join() server_socket.close()