start to factor server-connection-management into a distinct 'StorageServerFarmBroker...

[tahoe-lafs/tahoe-lafs.git] / src / allmydata / immutable / download.py

diff --git a/src/allmydata/immutable/download.py b/src/allmydata/immutable/download.py
index 326bd572ffa8fe4d315dbdff8c332d5866a03de6..3884102478e27b8c37b08dfb08d95d0c2aaff002 100644 (file)
--- a/src/allmydata/immutable/download.py
+++ b/src/allmydata/immutable/download.py
@@ -743,8 +743,8 @@ class CiphertextDownloader(log.PrefixingLogMixin):
 
     def _get_all_shareholders(self):
         dl = []
-        for (peerid,ss) in self._client.get_permuted_peers("storage",
-                                                           self._storage_index):
+        sb = self._client.storage_broker
+        for (peerid,ss) in sb.get_servers(self._storage_index):
             d = ss.callRemote("get_buckets", self._storage_index)
             d.addCallbacks(self._got_response, self._got_error,
                            callbackArgs=(peerid,))