From: Zooko O'Whielacronx <zooko@zooko.com>
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/pf/content/it.html?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)