Update peer.py

This commit is contained in:
Aryan Singh committed 2026-09-25 18:57:35 -05:00
1 parent a4f6d78ab9
commit 492b93544c
1 file changed
+16 -22
+16 -22
View File
@@ -1,32 +1,26 @@
from datetime import datetime, timezone from datetime import datetime, timezone
import socket import socket
INTRODUCER_IP = "172.22.156.3" def main():
IP = socket.gethostbyname(socket.gethostname()) INTRODUCER_IP = "172.22.156.3"
SERVER_PORT = 6767 IP = socket.gethostbyname(socket.gethostname())
INTRODUCER_FLAG = (INTRODUCER_IP == IP) SERVER_PORT = 6767
INTRODUCER_FLAG = (INTRODUCER_IP == IP)
#check if this VM is the introducer and add it self members_list = {
members_list = {} (IP, SERVER_PORT): {"heart_beat": 1, "last_seen": utc_time()}
if INTRODUCER_FLAG:
members_list[(IP, PORT)] = {
"heart_beat": 1,
"last_seen": utc_time()
} }
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(("", SERVER_PORT))
#start UDP socket if not INTRODUCER_FLAG:
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) server.sendto(b"JOIN", (INTRODUCER_IP, SERVER_PORT))
server.bind((IP, SERVER_PORT)) data, addr = server.recvfrom(4096)
print(addr, data)
if not INTRODUCER_FLAG:
server.sendto(b"JOIN", (INTRODUCER_IP, SERVER_PORT))
while True:
data, addr = server.recvfrom(4096)
#increment heart beat
#utc time
def utc_time(): def utc_time():
return datetime.now(timezone.utc) return datetime.now(timezone.utc)
if __name__ == "__main__":
main()