From 492b93544c7cf776b9517ecd366392a60992fd54 Mon Sep 17 00:00:00 2001 From: Aryan Singh Date: Fri, 25 Sep 2026 18:57:35 -0500 Subject: [PATCH] Update peer.py --- MP2/peer.py | 38 ++++++++++++++++---------------------- 1 file changed, 16 insertions(+), 22 deletions(-) diff --git a/MP2/peer.py b/MP2/peer.py index 31aa924..f9bad3b 100644 --- a/MP2/peer.py +++ b/MP2/peer.py @@ -1,32 +1,26 @@ from datetime import datetime, timezone import socket -INTRODUCER_IP = "172.22.156.3" -IP = socket.gethostbyname(socket.gethostname()) -SERVER_PORT = 6767 -INTRODUCER_FLAG = (INTRODUCER_IP == IP) +def main(): + INTRODUCER_IP = "172.22.156.3" + IP = socket.gethostbyname(socket.gethostname()) + SERVER_PORT = 6767 + INTRODUCER_FLAG = (INTRODUCER_IP == IP) -#check if this VM is the introducer and add it self -members_list = {} -if INTRODUCER_FLAG: - members_list[(IP, PORT)] = { - "heart_beat": 1, - "last_seen": utc_time() + members_list = { + (IP, SERVER_PORT): {"heart_beat": 1, "last_seen": utc_time()} } - -#start UDP socket -server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) -server.bind((IP, SERVER_PORT)) + server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) + server.bind(("", SERVER_PORT)) -if not INTRODUCER_FLAG: - server.sendto(b"JOIN", (INTRODUCER_IP, SERVER_PORT)) + if not INTRODUCER_FLAG: + server.sendto(b"JOIN", (INTRODUCER_IP, SERVER_PORT)) + data, addr = server.recvfrom(4096) + print(addr, data) -while True: - data, addr = server.recvfrom(4096) - -#increment heart beat - -#utc time def utc_time(): return datetime.now(timezone.utc) + +if __name__ == "__main__": + main()