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

merge patch to integrate decentralized directories with "introducer_and_vdrive.py: use logpublisher too"

Browse Source
This commit is contained in:
Zooko O'Whielacronx 2007-12-03 15:29:04 -07:00
parent d3e782a226
commit 184351d1f7
1 changed files with 1 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/allmydata/introducer.py
View File

@ -16,24 +16,6 @@ class IntroducerNode(node.Node):
DEFAULT_K, DEFAULT_DESIRED, DEFAULT_N = 3, 7, 10
def tub_ready(self):
i = Introducer()
r = self.add_service(i)
self.urls["introducer"] = self.tub.registerReference(r, "introducer")
self.log(" introducer is at %s" % self.urls["introducer"])
self.write_config("introducer.furl", self.urls["introducer"] + "\n")
vdrive_dir = os.path.join(self.basedir, self.VDRIVEDIR)
vds = self.add_service(VirtualDriveServer(vdrive_dir))
vds_furl = self.tub.registerReference(vds, "vdrive")
vds.set_furl(vds_furl)
self.urls["vdrive"] = vds_furl
self.log(" vdrive is at %s" % self.urls["vdrive"])
self.write_config("vdrive.furl", self.urls["vdrive"] + "\n")
encoding_parameters = self._read_encoding_parameters()
i.set_encoding_parameters(encoding_parameters)
def _read_encoding_parameters(self):
k, desired, n = self.DEFAULT_K, self.DEFAULT_DESIRED, self.DEFAULT_N
data = self.get_config("encoding_parameters")
if data is not None:
@ -103,7 +85,7 @@ class IntroducerClient(service.Service, Referenceable):
self.introducer_reconnector = self.tub.connectTo(self.introducer_furl,
self._got_introducer)
def connect_failed(failure):
self.log("\n\nInitial IntroducerAndVdrive connection failed: "
self.log("\n\nInitial Introducer connection failed: "
"perhaps it's down\n")
self.log(str(failure))
d = self.tub.getReference(self.introducer_furl)