From: Zooko O'Whielacronx Date: Mon, 3 Dec 2007 22:29:04 +0000 (-0700) Subject: merge patch to integrate decentralized directories with "introducer_and_vdrive.py... X-Git-Url: https://git.rkrishnan.org/components/%22news.html/provisioning?a=commitdiff_plain;h=184351d1f704f043271642263918c3669f105a04;p=tahoe-lafs%2Ftahoe-lafs.git merge patch to integrate decentralized directories with "introducer_and_vdrive.py: use logpublisher too" --- diff --git a/src/allmydata/introducer.py b/src/allmydata/introducer.py index 7b601140..86015e00 100644 --- a/src/allmydata/introducer.py +++ b/src/allmydata/introducer.py @@ -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)