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):
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):
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):