From 20f549baa139ab347112e9e074ac0f25434252cf Mon Sep 17 00:00:00 2001
From: Zooko O'Whielacronx <zooko@zooko.com>
Date: Fri, 14 Dec 2007 18:24:46 -0700
Subject: [PATCH] tidy-up some comments and logging messages
---
src/allmydata/mutable.py | 15 ++++++---------
1 file changed, 6 insertions(+), 9 deletions(-)
diff --git a/src/allmydata/mutable.py b/src/allmydata/mutable.py
index 29e1ba2a..8fde8981 100644
--- a/src/allmydata/mutable.py
+++ b/src/allmydata/mutable.py
@@ -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).
"""
-
- 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
+ self.log("starting publish")
+
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
--
2.45.2