diff --git a/server.py b/server.py index 7eb49f674d71f8834273956d624e548542ef75e1..34ced50710be79843a00ba1097e34c17c900f096 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()