rra/meshenger
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
Roel 2014-04-24 16:37:30 +02:00
parent 7a6d139280
commit 70711312b0
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
main.py
View File

@ -52,11 +52,13 @@ class Meshenger:
nodepath = self.ip_to_hash(device) #make a folder for the node (nodes/'hash'/) nodepath = self.ip_to_hash(device) #make a folder for the node (nodes/'hash'/)
nodeupdatepath = os.path.join(self.ip_to_hash(device), 'lastupdate') nodeupdatepath = os.path.join(self.ip_to_hash(device), 'lastupdate')
print 'Checking age of foreign node index' print 'Checking age of foreign node index'
print self.devices[device] print self.devices[device]
foreign_node_update = open(nodeupdatepath).read() foreign_node_update = open(nodeupdatepath).read()
print foreign_node_update print foreign_node_update
if self.devices[device] > foreign_node_update: if self.devices[device] > foreign_node_update:
print 'Foreign node"s index is newer, proceed to download index' print 'Foreign node"s index is newer, proceed to download index'
self.get_index(device, nodepath) self.get_index(device, nodepath)
@ -101,15 +103,19 @@ Discover other devices by listening to the Meshenger announce port
while not self.exitapp: while not self.exitapp:
result = select.select([s],[],[])[0][0].recvfrom(bufferSize) result = select.select([s],[],[])[0][0].recvfrom(bufferSize)
if result[1][0] not in self.devices and result[1][0] != self.own_ip:
#loop for first time
self.devices[result[1][0]] = result[0]
node_timestamp(result[1][0])
if result[1][0] in self.devices and result[1][0] != self.own_ip: if result[1][0] in self.devices and result[1][0] != self.own_ip:
print 'node al een keer gezien'
self.devices[result[1][0]] = result[0] self.devices[result[1][0]] = result[0]
#self.devices.append(result[1][0]) #self.devices.append(result[1][0])
elif result[1][0] not in self.devices and result[1][0] != self.own_ip:
print 'node eerste keer'
#loop for first time
self.devices[result[1][0]] = result[0]
self.node_timestamp(result[1][0])
time.sleep(1) time.sleep(1)
def serve(self): def serve(self):