Allow broadcast to fail
This commit is contained in:
parent
62ecc1cbc1
commit
809632794f
1 changed files with 7 additions and 4 deletions
|
@ -104,10 +104,13 @@ class BroadcastServer(object):
|
||||||
self.log.debug("Broadcast using ips %s on port %s: %s" % (my_ips, port, message["cmd"]))
|
self.log.debug("Broadcast using ips %s on port %s: %s" % (my_ips, port, message["cmd"]))
|
||||||
|
|
||||||
for my_ip in my_ips:
|
for my_ip in my_ips:
|
||||||
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
try:
|
||||||
sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
|
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
||||||
sock.bind((my_ip, 0))
|
sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
|
||||||
sock.sendto(msgpack.packb(message), addr)
|
sock.bind((my_ip, 0))
|
||||||
|
sock.sendto(msgpack.packb(message), addr)
|
||||||
|
except Exception as err:
|
||||||
|
self.log.warning("Error sending broadcast using ip %s: %s" % (my_ip, err))
|
||||||
|
|
||||||
def handleMessage(self, addr, message):
|
def handleMessage(self, addr, message):
|
||||||
self.log.debug("Got from %s: %s" % (addr, message["cmd"]))
|
self.log.debug("Got from %s: %s" % (addr, message["cmd"]))
|
||||||
|
|
Loading…
Reference in a new issue