ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-01-19 11:16:24 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

introducer: simplify get_permuted_peers() implementation and add get_peers()

Browse Source
This commit is contained in:
Zooko O'Whielacronx 2008-12-08 16:57:25 -07:00
parent d1d2d0b686
commit a84581fcff
1 changed files with 6 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/allmydata/introducer/client.py
View File

@ -295,21 +295,16 @@ class IntroducerClient(service.Service, Referenceable):
for c in self._connections
if c[1] == service_name])
def get_peers(self, service_name):
"""Return a set of (peerid, versioned-rref) tuples."""
return frozenset([(pid, r) for (pid, servname, r) in self._connections if servname == servname])
def get_permuted_peers(self, service_name, key):
"""Return an ordered list of (peerid, versioned-rref) tuples."""
results = []
for (c_peerid, c_service_name, rref) in self._connections:
assert isinstance(c_peerid, str)
if c_service_name != service_name:
continue
permuted = sha.new(key + c_peerid).digest()
results.append((permuted, c_peerid, rref))
results.sort(lambda a,b: cmp(a[0], b[0]))
return [ (r[1], r[2]) for r in results ]
servers = self.get_peers(service_name)
return sorted(servers, key=lambda x: sha.new(key+x[0]).digest())
def remote_set_encoding_parameters(self, parameters):
self.encoding_parameters = parameters