mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-04-19 00:06:57 +00:00
separate queen's service of introduction-to-the-network from queen's service of providing-access-to-the-vdrive
This commit is contained in:
parent
ca33c8f848
commit
c77eace162
@ -96,6 +96,7 @@ class Client(node.Node, Referenceable):
|
||||
nodeid=self.nodeid,
|
||||
node=self,
|
||||
pburl=self.my_pburl)
|
||||
d.addCallback(lambda x: queen.callRemote("get_global_vdrive"))
|
||||
d.addCallback(self._got_vdrive_root)
|
||||
|
||||
def _got_vdrive_root(self, root):
|
||||
|
@ -19,7 +19,11 @@ RIMutableFileNode_ = Any()
|
||||
|
||||
class RIQueenRoster(RemoteInterface):
|
||||
def hello(nodeid=Nodeid, node=RIClient_, pburl=PBURL):
|
||||
return None
|
||||
|
||||
def get_global_vdrive():
|
||||
return RIMutableDirectoryNode_ # the virtual drive root
|
||||
|
||||
|
||||
class RIClient(RemoteInterface):
|
||||
def get_service(name=str):
|
||||
|
@ -39,6 +39,8 @@ class Roster(service.MultiService, Referenceable):
|
||||
eventually(self._announce_new_peer,
|
||||
nodeid, pburl, list(self.connections.values()))
|
||||
node.notifyOnDisconnect(self._lost_node, nodeid)
|
||||
|
||||
def remote_get_global_vdrive(self):
|
||||
return self.gvd_root
|
||||
|
||||
def _educate_the_new_peer(self, nodeid, node, new_peers):
|
||||
|
Loading…
x
Reference in New Issue
Block a user