Skip to content
Snippets Groups Projects
Commit a7d9fd5d authored by Quoc Nguyen Dao's avatar Quoc Nguyen Dao
Browse files

fix

parent 4688268b
No related branches found
No related tags found
No related merge requests found
...@@ -324,32 +324,33 @@ class Server(): ...@@ -324,32 +324,33 @@ class Server():
multicast_socket.settimeout(3) multicast_socket.settimeout(3)
while True: while True:
try: if not self.is_leader:
data, address = multicast_socket.recvfrom(1024) try:
if data: data, address = multicast_socket.recvfrom(1024)
self.leader_heartbeat_last_received = time.time() if data:
sender_ip = address[0] self.leader_heartbeat_last_received = time.time()
self.leader_ip = sender_ip sender_ip = address[0]
if sender_ip != MY_IP: self.leader_ip = sender_ip
print(f"Received heartbeat from {sender_ip}: {data.decode()}") if sender_ip != MY_IP:
print(f"Received heartbeat from {sender_ip}: {data.decode()}")
# Wenn kein Heartbeat empfangen wurde # Wenn kein Heartbeat empfangen wurde
except socket.timeout: except socket.timeout:
time_since_last_heartbeat = time.time() - self.leader_heartbeat_last_received time_since_last_heartbeat = time.time() - self.leader_heartbeat_last_received
if time_since_last_heartbeat > self.heartbeat_interval: if time_since_last_heartbeat > self.heartbeat_interval:
self.missed_heartbeats += 1 self.missed_heartbeats += 1
print(f"Missed heartbeat detected. Count: {self.missed_heartbeats}") print(f"Missed heartbeat detected. Count: {self.missed_heartbeats}")
if self.missed_heartbeats >= self.missed_heartbeats_limit: if self.missed_heartbeats >= self.missed_heartbeats_limit:
print("Missed heartbeats limit reached. Initiating leader election.") print("Missed heartbeats limit reached. Initiating leader election.")
self.serverList.remove(self.leader_ip) self.serverList.remove(self.leader_ip)
self.basic_lcr() self.basic_lcr()
# Reset missed heartbeats count # Reset missed heartbeats count
self.missed_heartbeats = 0 self.missed_heartbeats = 0
# Code to initiate a new voting process to elect a new leader # Code to initiate a new voting process to elect a new leader
# This could involve calling a function from voting.py or similar logic # This could involve calling a function from voting.py or similar logic
time.sleep(self.heartbeat_interval) time.sleep(self.heartbeat_interval)
# starting all simultaneously working procedures # starting all simultaneously working procedures
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment