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

Update two methods of introducer.client.IntroducerClient to match the interface definition.

Browse Source
This commit is contained in:
Jason R. Coombs
2020-11-29 13:54:39 -05:00
parent 4998c4693f
commit 50f81aa25d
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -157,15 +157,15 @@ class IntroducerClient(service.Service, Referenceable):
kwargs["facility"] = "tahoe.introducer.client" kwargs["facility"] = "tahoe.introducer.client"
return log.msg(*args, **kwargs) return log.msg(*args, **kwargs)
def subscribe_to(self, service_name, cb, *args, **kwargs): def subscribe_to(self, service_name, callback, *args, **kwargs):
self._local_subscribers.append( (service_name,cb,args,kwargs) ) self._local_subscribers.append( (service_name,callback,args,kwargs) )
self._subscribed_service_names.add(service_name) self._subscribed_service_names.add(service_name)
self._maybe_subscribe() self._maybe_subscribe()
for index,(ann,key_s,when) in self._inbound_announcements.items(): for index,(ann,key_s,when) in self._inbound_announcements.items():
precondition(isinstance(key_s, str), key_s) precondition(isinstance(key_s, str), key_s)
servicename = index[0] servicename = index[0]
if servicename == service_name: if servicename == service_name:
eventually(cb, key_s, ann, *args, **kwargs) eventually(callback, key_s, ann, *args, **kwargs)
def _maybe_subscribe(self): def _maybe_subscribe(self):
if not self._publisher: if not self._publisher:
@ -198,7 +198,7 @@ class IntroducerClient(service.Service, Referenceable):
ann_d.update(ann) ann_d.update(ann)
return ann_d return ann_d
def publish(self, service_name, ann, signing_key): def publish(self, service_name, ann, signing_key=None):
# we increment the seqnum every time we publish something new # we increment the seqnum every time we publish something new
current_seqnum, current_nonce = self._sequencer() current_seqnum, current_nonce = self._sequencer()