mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-06-19 07:48:11 +00:00
Rename upload_ready_d to connected_enough_d.
Signed-off-by: Daira Hopwood <daira@jacaranda.org>
This commit is contained in:
committed by
Brian Warner
parent
1495d0f405
commit
976c89d2e4
@ -376,7 +376,7 @@ class Client(node.Node, pollmixin.PollMixin):
|
|||||||
connection_threshold = min(self.encoding_params["k"],
|
connection_threshold = min(self.encoding_params["k"],
|
||||||
self.encoding_params["happy"] + 1)
|
self.encoding_params["happy"] + 1)
|
||||||
helper = storage_client.ConnectedEnough(sb, connection_threshold)
|
helper = storage_client.ConnectedEnough(sb, connection_threshold)
|
||||||
self.upload_ready_d = helper.when_connected_enough()
|
self.connected_enough_d = helper.when_connected_enough()
|
||||||
|
|
||||||
# utilize the loaded static server specifications
|
# utilize the loaded static server specifications
|
||||||
for key, server in self.connections_config['servers'].items():
|
for key, server in self.connections_config['servers'].items():
|
||||||
@ -491,7 +491,7 @@ class Client(node.Node, pollmixin.PollMixin):
|
|||||||
s.startService()
|
s.startService()
|
||||||
|
|
||||||
# start processing the upload queue when we've connected to enough servers
|
# start processing the upload queue when we've connected to enough servers
|
||||||
self.upload_ready_d.addCallback(s.upload_ready)
|
self.connected_enough_d.addCallback(s.ready)
|
||||||
except Exception, e:
|
except Exception, e:
|
||||||
self.log("couldn't start drop-uploader: %r", args=(e,))
|
self.log("couldn't start drop-uploader: %r", args=(e,))
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user