ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-02-02 01:08:20 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

tidy-up some comments and logging messages

Browse Source
This commit is contained in:
Zooko O'Whielacronx 2007-12-14 18:24:46 -07:00
parent ae90016845
commit 20f549baa1
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/allmydata/mutable.py
View File

@ -691,7 +691,7 @@ class Retrieve:
return plaintext
def _done(self, contents):
self.log("DONE, contents: %r" % contents)
self.log("DONE")
self._running = False
eventually(self._done_deferred.callback, contents)
@ -733,17 +733,14 @@ class Publish:
It will wait until at least wait_for_numpeers peers are connected
before it starts uploading
If wait_for_numpeers is None, then wait_for_numpeers is set to the
number of shares total (M).
If wait_for_numpeers is None then it will be set to a default value
(currently 1).
"""
if wait_for_numpeers is None:
wait_for_numpeers = 1
self.log("starting publish")
if wait_for_numpeers is None:
# TODO: perhaps the default should be something like:
# wait_for_numpeers = self._node.get_total_shares()
wait_for_numpeers = 1
d = self._node._client.introducer_client.when_enough_peers(wait_for_numpeers)
d.addCallback(lambda dummy: self._after_enough_peers(newdata))
return d
@ -1127,7 +1124,7 @@ class Publish:
# time. (Note: in the future, when we remove the _query_peers() step
# and instead speculate about [or remember] which shares are where,
# surprises here are *not* indications of UncoordinatedWriteError,
# and we'll need to respond to them more gracefully.
# and we'll need to respond to them more gracefully.)
target_map, shares_per_peer, peer_storage_servers = target_info