Ilgrim/kademlia
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use timers not affected by system clock updates (#42)

Browse Source 
See paragraph two of https://docs.python.org/3/library/time.html#time.time
This commit is contained in:
NixNodes 2018-01-25 19:06:17 +01:00 committed by Brian Muller
parent 3b93189ef2
commit ecde2c9258
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kademlia/routing.py
View File

@ -16,7 +16,7 @@ class KBucket(object):
self.ksize = ksize self.ksize = ksize
def touchLastUpdated(self): def touchLastUpdated(self):
self.lastUpdated = time.time() self.lastUpdated = time.monotonic()
def getNodes(self): def getNodes(self):
return list(self.nodes.values()) return list(self.nodes.values())
@ -136,7 +136,7 @@ class RoutingTable(object):
Get all of the buckets that haven't been updated in over Get all of the buckets that haven't been updated in over
an hour. an hour.
""" """
hrago = time.time() - 3600 hrago = time.monotonic() - 3600
return [b for b in self.buckets if b.lastUpdated < hrago] return [b for b in self.buckets if b.lastUpdated < hrago]
def removeContact(self, node): def removeContact(self, node):

4
kademlia/storage.py
View File

@ -52,7 +52,7 @@ class ForgetfulStorage(IStorage):
def __setitem__(self, key, value): def __setitem__(self, key, value):
if key in self.data: if key in self.data:
del self.data[key] del self.data[key]
self.data[key] = (time.time(), value) self.data[key] = (time.monotonic(), value)
self.cull() self.cull()
def cull(self): def cull(self):
@ -78,7 +78,7 @@ class ForgetfulStorage(IStorage):
return repr(self.data) return repr(self.data)
def iteritemsOlderThan(self, secondsOld): def iteritemsOlderThan(self, secondsOld):
minBirthday = time.time() - secondsOld minBirthday = time.monotonic() - secondsOld
zipped = self._tripleIterable() zipped = self._tripleIterable()
matches = takewhile(lambda r: minBirthday >= r[1], zipped) matches = takewhile(lambda r: minBirthday >= r[1], zipped)
return list(map(operator.itemgetter(0, 2), matches)) return list(map(operator.itemgetter(0, 2), matches))