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()