From: Leif Ryge Date: Fri, 5 Feb 2016 11:37:22 +0000 (+0000) Subject: remove introducer's set_encoding_parameters X-Git-Url: https://git.rkrishnan.org/vdrive/%22news.html/simplejson?a=commitdiff_plain;h=56a9f5adaf9cddf8cf5613d153482026564e9d3b;p=tahoe-lafs%2Ftahoe-lafs.git remove introducer's set_encoding_parameters I'm not sure why this ever existed, but it doesn't appear to be used. (If an introducer called a client's set_encoding_parameters method it would keep the provided parameters in an instance attribute but would not actually use them.) --- diff --git a/src/allmydata/introducer/client.py b/src/allmydata/introducer/client.py index f463c120..be440067 100644 --- a/src/allmydata/introducer/client.py +++ b/src/allmydata/introducer/client.py @@ -28,9 +28,6 @@ class WrapV2ClientInV1Interface(Referenceable): # for_v1 for ann_v1 in announcements]) return self.original.got_announcements(anns_v1, lp) - def remote_set_encoding_parameters(self, parameters): - self.original.remote_set_encoding_parameters(parameters) - class RIStubClient(RemoteInterface): # for_v1 """Each client publishes a service announcement for a dummy object called the StubClient. This object doesn't actually offer any services, but the @@ -89,8 +86,6 @@ class IntroducerClient(service.Service, Referenceable): # after startup. self._inbound_announcements = {} - self.encoding_parameters = None - # hooks for unit tests self._debug_counts = { "inbound_message": 0, @@ -354,8 +349,5 @@ class IntroducerClient(service.Service, Referenceable): if service_name2 == service_name: eventually(cb, key_s, ann, *args, **kwargs) - def remote_set_encoding_parameters(self, parameters): - self.encoding_parameters = parameters - def connected_to_introducer(self): return bool(self._publisher) diff --git a/src/allmydata/introducer/interfaces.py b/src/allmydata/introducer/interfaces.py index 53d875ac..8d46b666 100644 --- a/src/allmydata/introducer/interfaces.py +++ b/src/allmydata/introducer/interfaces.py @@ -31,23 +31,6 @@ class RIIntroducerSubscriberClient_v2(RemoteInterface): """I accept announcements from the publisher.""" return None - def set_encoding_parameters(parameters=(int, int, int)): - """Advise the client of the recommended k-of-n encoding parameters - for this grid. 'parameters' is a tuple of (k, desired, n), where 'n' - is the total number of shares that will be created for any given - file, while 'k' is the number of shares that must be retrieved to - recover that file, and 'desired' is the minimum number of shares that - must be placed before the uploader will consider its job a success. - n/k is the expansion ratio, while k determines the robustness. - - Introducers should specify 'n' according to the expected size of the - grid (there is no point to producing more shares than there are - peers), and k according to the desired reliability-vs-overhead goals. - - Note that setting k=1 is equivalent to simple replication. - """ - return None - SubscriberInfo = DictOf(str, Any()) class RIIntroducerPublisherAndSubscriberService_v2(RemoteInterface): diff --git a/src/allmydata/introducer/old.py b/src/allmydata/introducer/old.py index 3c2fcb71..acb3c3f7 100644 --- a/src/allmydata/introducer/old.py +++ b/src/allmydata/introducer/old.py @@ -37,23 +37,6 @@ class RIIntroducerSubscriberClient_v1(RemoteInterface): """I accept announcements from the publisher.""" return None - def set_encoding_parameters(parameters=(int, int, int)): - """Advise the client of the recommended k-of-n encoding parameters - for this grid. 'parameters' is a tuple of (k, desired, n), where 'n' - is the total number of shares that will be created for any given - file, while 'k' is the number of shares that must be retrieved to - recover that file, and 'desired' is the minimum number of shares that - must be placed before the uploader will consider its job a success. - n/k is the expansion ratio, while k determines the robustness. - - Introducers should specify 'n' according to the expected size of the - grid (there is no point to producing more shares than there are - peers), and k according to the desired reliability-vs-overhead goals. - - Note that setting k=1 is equivalent to simple replication. - """ - return None - # When Foolscap can handle multiple interfaces (Foolscap#17), the # full-powered introducer will implement both RIIntroducerPublisher and # RIIntroducerSubscriberService. Until then, we define @@ -164,8 +147,6 @@ class IntroducerClient_v1(service.Service, Referenceable): # for clients who subscribe after startup. self._current_announcements = {} - self.encoding_parameters = None - # hooks for unit tests self._debug_counts = { "inbound_message": 0, @@ -345,9 +326,6 @@ class IntroducerClient_v1(service.Service, Referenceable): if service_name2 == service_name: eventually(cb, nodeid, ann_d, *args, **kwargs) - def remote_set_encoding_parameters(self, parameters): - self.encoding_parameters = parameters - def connected_to_introducer(self): return bool(self._publisher) diff --git a/src/allmydata/introducer/server.py b/src/allmydata/introducer/server.py index 92c2497e..598325ae 100644 --- a/src/allmydata/introducer/server.py +++ b/src/allmydata/introducer/server.py @@ -95,9 +95,6 @@ class WrapV1SubscriberInV2Interface: # for_v1 def wrap_announce_v2(self, announcements): anns_v1 = [convert_announcement_v2_to_v1(ann) for ann in announcements] return self.original.callRemote("announce", set(anns_v1)) - def wrap_set_encoding_parameters(self, parameters): - # note: unused - return self.original.callRemote("set_encoding_parameters", parameters) def notifyOnDisconnect(self, *args, **kwargs): return self.original.notifyOnDisconnect(*args, **kwargs)