Merge 8f04b9a into 6f8c96e

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)