diff --git a/server.py b/server.py index 00dc61f41d03ff3518ab76ec2fd48a86f0ce6656..9dc5ee1ab41a26d113df97076de65406986c6f14 100644 --- a/server.py +++ b/server.py @@ -37,6 +37,7 @@ class Server(multiprocessing.Process): self.server_port = server_port self.local_servers_cache = server_cache self.local_clients_cache = clients_cache + self.last_heartbeat_timestamp = last_heartbeat_timestamp @staticmethod def get_local_ip_address(): @@ -104,7 +105,6 @@ class Server(multiprocessing.Process): else: return "Unknown" - def run(self): print(self.server_id+": "+"Up and running") if self.server_id == "MAIN": @@ -169,7 +169,6 @@ class Server(multiprocessing.Process): except socket.error: pass # Error handling for connection errors or timeout return acknowledgment_received - def listen_for_heartbeats(self): while True: @@ -391,11 +390,11 @@ class Server(multiprocessing.Process): def listen_for_cache_update(self): BROADCAST_ADDRESS = self.get_broadcast_address() BROADCAST_PORT = 5980 - + print("listen for cache update") # Local host information MY_HOST = socket.gethostname() MY_IP = socket.gethostbyname(MY_HOST) - + print("listen for cache update") # Create a UDP socket listen_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # Set the socket to broadcast and enable reusing addresses