From ffdb0c68078a6cd41c83ebec57c0b0f3c92df371 Mon Sep 17 00:00:00 2001 From: leberr <robin.leber@student.reutlingen-university.de> Date: Wed, 31 Jan 2024 09:35:52 +0100 Subject: [PATCH] new basic_lcr function calls --- server.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/server.py b/server.py index 7eb49f6..34ced50 100644 --- a/server.py +++ b/server.py @@ -50,6 +50,7 @@ class Server(): # if my IP is not in the server list add it if MY_IP not in self.serverList: self.serverList.append(MY_IP) + self.basic_lcr() # create socket bind to server address multicast_listen_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) @@ -108,6 +109,7 @@ class Server(): # if my IP is not in the server list add it if MY_IP not in self.serverList: self.serverList.append(MY_IP) + self.basic_lcr() # listen for IPs from existing servers maxLoop = 5 @@ -134,6 +136,7 @@ class Server(): # if reply address is not in the server list, add it if reply_address not in self.serverList: self.serverList.append(reply_address) + self.basic_lcr() # Erhöhe die Anzahl der eingehenden Antworten num_responses += 1 @@ -223,7 +226,7 @@ class Server(): } self.participant = True ring_socket.sendto(json.dumps(first_message).encode('utf-8'), neighbour_address) - + print('Neighbour') print(neighbour) @@ -279,8 +282,8 @@ if __name__== '__main__': thread1 = threading.Thread(target = server.ListenForClientAndReply) thread1.start() - thread_election = threading.Thread(target = server.basic_lcr) - thread_election.start() + # thread_election = threading.Thread(target = server.basic_lcr) + # thread_election.start() # server.basic_lcr() -- GitLab