From 8f04b9a86f0c80ce300c29ae74d053a34b7c84b0 Mon Sep 17 00:00:00 2001 From: David Stainton Date: Tue, 2 Aug 2016 14:42:14 +0000 Subject: [PATCH] Add missing got_static_announcement --- src/allmydata/storage_client.py | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/allmydata/storage_client.py b/src/allmydata/storage_client.py index 2d1cf56a7c..06adc30a21 100644 --- a/src/allmydata/storage_client.py +++ b/src/allmydata/storage_client.py @@ -126,6 +126,19 @@ def _check_connected_high_water_mark(self): remaining.append( (threshold, d) ) self._threshold_listeners = remaining + def got_static_announcement(self, key_s, ann, transport_plugins): + if key_s is not None: + precondition(isinstance(key_s, str), key_s) + precondition(key_s.startswith("v0-"), key_s) + assert ann["service-name"] == "storage" + s = NativeStorageServer(key_s, ann) + server_id = s.get_serverid() + assert server_id not in self.static_servers # XXX + self.static_servers.append(server_id) + self.servers[server_id] = s + self._ensure_tub_created(server_id, transport_plugins) + s.start_connecting(self.tubs[server_id], self._trigger_connections) + def _got_announcement(self, key_s, ann): if key_s is not None: precondition(isinstance(key_s, str), key_s)