Skip to content
Snippets Groups Projects
Commit aa84d1c4 authored by Katharina's avatar Katharina
Browse files

debug whatever+listener

parent 3dd787ad
No related branches found
No related tags found
No related merge requests found
...@@ -24,16 +24,17 @@ server_id = str(uuid.uuid4()) ...@@ -24,16 +24,17 @@ server_id = str(uuid.uuid4())
#print(hostIP) #print(hostIP)
dynamic.broadcast_sender(leaderServer.broadcast_ip, leaderServer.broadcast_port, server_adress, server_id) dynamic.broadcast_sender(leaderServer.broadcast_ip, leaderServer.broadcast_port, server_adress, server_id)
print(f"send broadcast of server a id: {server_id}")#debug
while True: while True:
print(leaderServer.leader) print(f"server a before broadcast sender: {leaderServer.leader}")
print(leaderServer.server_network) print(f"server a before broadcast sender: {leaderServer.server_network}")
data = dynamic.broadcast_listener(leaderServer.broadcast_ip, leaderServer.broadcast_port) data = dynamic.broadcast_listener(leaderServer.broadcast_ip, leaderServer.broadcast_port)
print(leaderServer.server_network) #data = leaderServer.leader
print(f"after broadcast sender: {leaderServer.server_network}")
if data: if data:
x = data #x = data
print(x) print(data)
# if d in leaderServer.leader: # if d in leaderServer.leader:
# leaderServer.server_network = leaderServer.addServer(data) # leaderServer.server_network = leaderServer.addServer(data)
# dynamic.broadcast_sender(leaderServer.broadcast_ip, leaderServer.broadcast_port, leaderServer.server_network) # dynamic.broadcast_sender(leaderServer.broadcast_ip, leaderServer.broadcast_port, leaderServer.server_network)
... ...
......
...@@ -19,12 +19,13 @@ server_id = str(uuid.uuid4()) ...@@ -19,12 +19,13 @@ server_id = str(uuid.uuid4())
hostName = socket.gethostname() hostName = socket.gethostname()
# IP des Rechners im Subnetz # IP des Rechners im Subnetz
hostIP = socket.gethostbyname(hostName) hostIP = socket.gethostbyname(hostName)
print(leaderServer.leader) print(f"server b before broadcast sender: {leaderServer.leader}")
print(leaderServer.server_network) print(f"server b before broadcast sender: {leaderServer.server_network}")
dynamic.broadcast_sender(leaderServer.broadcast_ip, leaderServer.broadcast_port, server_adress, server_id) dynamic.broadcast_sender(leaderServer.broadcast_ip, leaderServer.broadcast_port, server_adress, server_id)
print(f"send broadcast of server b id: {server_id}")#debug
while True: while True:
server_network = dynamic.broadcast_listener(leaderServer.broadcast_ip, leaderServer.broadcast_port) server_network = dynamic.broadcast_listener(leaderServer.broadcast_ip, leaderServer.broadcast_port)
print(server_network) print(f"server in network: {leaderServer.server_network}")
print(f"leader in network: {leaderServer.leader}")
File added
File added
...@@ -18,19 +18,22 @@ buffer_size = 4096 ...@@ -18,19 +18,22 @@ buffer_size = 4096
def broadcast_sender(broadcast_ip, broadcast_port, server_ip, server_uuid): def broadcast_sender(broadcast_ip, broadcast_port, server_ip, server_uuid):
#create UDP socket #create UDP socket
broadcast_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) broadcast_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
print(leaderServer.leader) #print(leaderServer.leader)
message = f"{server_ip}::{server_uuid}"
if len(leaderServer.leader) == 0: if len(leaderServer.leader) == 0:
leaderServer.addLeader(server_uuid) leaderServer.addLeader(server_uuid)
leaderServer.addServer(server_ip) leaderServer.addServer(server_ip)
print(leaderServer.leader) print(f"Hi {leaderServer.leader}")
print(leaderServer.server_network) print(f'Hi {leaderServer.server_network}')
broadcast_socket.sendto(str(message).encode(), (broadcast_ip, broadcast_port))#for debug
else: else:
#send message #send message
broadcast_socket.sendto(str(server_ip).encode(), (broadcast_ip, broadcast_port)) broadcast_socket.sendto(str(message).encode(), (broadcast_ip, broadcast_port))
print(f'else {leaderServer.server_network}')#for debug
def broadcast_listener(ip_adress, port): def broadcast_listener(ip_adress, port):
print(leaderServer.leader) print(f"listener{leaderServer.leader}")#f for debug
print(leaderServer.server_network) print(leaderServer.server_network)
#UDP socket #UDP socket
listen_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) listen_socket = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
...@@ -42,9 +45,17 @@ def broadcast_listener(ip_adress, port): ...@@ -42,9 +45,17 @@ def broadcast_listener(ip_adress, port):
print('listener up and run at {} : {}'.format(ip_adress, port)) print('listener up and run at {} : {}'.format(ip_adress, port))
data, address = listen_socket.recvfrom(buffer_size) data, address = listen_socket.recvfrom(buffer_size)
#hier jetzt async einbauen für ständige listen? #hier jetzt async einbauen für ständige listen?
message=data.decode()
server_ip, server_uuid = message.split("::")
#if len(leaderServer.leader) == 0:
leaderServer.addLeader(server_uuid)
leaderServer.addServer(server_ip)
print(f"Hi {leaderServer.leader}")
print(f'Hi {leaderServer.server_network}')
print("Broadcast recieved from Sender: ", data.decode()) print("Broadcast recieved from Sender: ", data.decode())
print(f"this is address: {address}")
return data.decode() return data.decode()
...@@ -5,7 +5,7 @@ ...@@ -5,7 +5,7 @@
# Broadcast Informationen # Broadcast Informationen
broadcast_ip = '127.0.0.255' broadcast_ip = '127.0.0.255' #192.168.1.255
broadcast_port = 5000 broadcast_port = 5000
# Alle IP adressen der beteiligten Server # Alle IP adressen der beteiligten Server
...@@ -25,7 +25,7 @@ def addServer(Server_ip): ...@@ -25,7 +25,7 @@ def addServer(Server_ip):
# Leader hinzufügen # Leader hinzufügen
def addLeader(server_uuid): def addLeader(server_uuid):
leader.append(server_uuid) leader.append(server_uuid)
return #return leader
# löschen eines Servers # löschen eines Servers
def deleteServer(server_ip): def deleteServer(server_ip):
... ...
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment