0x2620/openmedialibrary
1
0
Fork 0
Code Issues 131 Pull requests Releases Wiki Activity

send local node announcement every 60 seconds

Browse source
This commit is contained in:
j 2015-03-07 13:06:00 +05:30
parent 67788f2a04
commit 2a7122d7fb
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
oml/localnodes.py
View file

@ -37,6 +37,7 @@ class LocalNodesBase(Thread):
_PORT = 9851 _PORT = 9851
_TTL = 1 _TTL = 1
_TIMEOUT = 30
def __init__(self, nodes): def __init__(self, nodes):
self._socket = None self._socket = None
@ -74,6 +75,7 @@ class LocalNodesBase(Thread):
while self._active: while self._active:
try: try:
s = self.get_socket() s = self.get_socket()
s.settimeout(self._TIMEOUT)
s.bind(('', self._PORT)) s.bind(('', self._PORT))
while self._active: while self._active:
data, addr = s.recvfrom(1024) data, addr = s.recvfrom(1024)
@ -84,15 +86,17 @@ class LocalNodesBase(Thread):
if data: if data:
self.update_node(data) self.update_node(data)
except socket.timeout: except socket.timeout:
pass
except:
if self._active:
logger.debug('receive failed. restart later', exc_info=1)
time.sleep(10)
finally:
if self._active: if self._active:
now = time.mktime(time.localtime()) now = time.mktime(time.localtime())
if now - last > 60: if now - last > 60:
last = now last = now
_thread.start_new_thread(self.send, ()) _thread.start_new_thread(self.send, ())
except:
if self._active:
logger.debug('receive failed. restart later', exc_info=1)
time.sleep(10)
def verify(self, data): def verify(self, data):
try: try: