macdev
quadrismegistus 4 years ago
parent c62792a66d
commit 2b4a408a48

@ -88,8 +88,8 @@ class KademliaProtocol(RPCProtocol):
def rpc_store(self, sender, nodeid, key, value):
source = Node(nodeid, sender[0], sender[1])
self.welcome_if_new(source)
log.debug("got a store request from %s, storing '%s'='%s'",
sender, key.hex(), value)
log.debug("got a store request from %s, storing '%s' -> %s (binary keys)'",
sender, key.hex(), len(value))
self.storage[key] = value
return True

@ -147,7 +147,7 @@ class HalfForgetfulStorage(IStorage):
def values(self): return [self.data[k] for k in self.keys()]
def set(self,key,value):
log(f'HFS.set({key}) -> {value}')
# log(f'HFS.set({key}) -> {value}')
# store
if key in self.data:
@ -168,11 +168,11 @@ class HalfForgetfulStorage(IStorage):
def get(self, key, default=None, incl_time=False):
#self.cull()
log(f'HFS.get({key}) -> ?')
# log(f'HFS.get({key}) -> ?')
try:
val=self.data[key]
# val=self.data.get(key)
log(f'HFS.get({key}) -> {val}')
# log(f'HFS.get({key}) -> {val}')
if val is False: raise KeyError
if val and not incl_time: val=val[1]
return val

Loading…
Cancel
Save