Nucypher
/
nucypher
mirror of https://github.com/nucypher/nucypher.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fixes #98.

pull/102/head
jMyles 2017-11-06 13:44:59 -08:00
parent 93a70179a8
commit 2581c579e3
2 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
nkms/network/server.py
View File

@ -53,14 +53,10 @@ class NuCypherDHTServer(Server):
self.storage[dkey] = value
ds = []
for n in nodes:
if self.node.id == n.id:
# TOOD: Consider whether to store stuff locally. We don't really know yet. Probably at least some things.
ds.append(False)
else:
disposition, value_was_set = await self.protocol.callStore(n, dkey, value)
if value_was_set:
self.digests_set += 1
ds.append(value_was_set)
_disposition, value_was_set = await self.protocol.callStore(n, dkey, value)
if value_was_set:
self.digests_set += 1
ds.append(value_was_set)
# return true only if at least one store call succeeded
return any(ds)

3
tests/network/test_network_actors.py
View File

@ -28,8 +28,7 @@ def make_fake_ursulas(how_many):
URSULAS.append(_URSULA)
for _counter, ursula in enumerate(URSULAS):
EVENT_LOOP.run_until_complete(ursula.server.bootstrap([("127.0.0.1", URSULA_PORT)]))
# EVENT_LOOP.run_until_complete(ursula.server.bootstrap([("127.0.0.1", URSULA_PORT + _c) for _c in range(how_many)]))
EVENT_LOOP.run_until_complete(ursula.server.bootstrap([("127.0.0.1", URSULA_PORT + _c) for _c in range(how_many)]))
ursula.publish_interface_information()
return URSULAS