From: kevan Date: Sat, 17 Sep 2011 23:47:08 +0000 (-0700) Subject: mutable/publish: add errback immediately after write, don't consume errors from other... X-Git-Url: https://git.rkrishnan.org/?p=tahoe-lafs%2Ftahoe-lafs.git;a=commitdiff_plain;h=8c7406508a72f5ddeb86b5c9cc2baa7a6230b0b1 mutable/publish: add errback immediately after write, don't consume errors from other parts of the publisher --- diff --git a/src/allmydata/mutable/publish.py b/src/allmydata/mutable/publish.py index e74be2ec..e5f44c78 100644 --- a/src/allmydata/mutable/publish.py +++ b/src/allmydata/mutable/publish.py @@ -867,12 +867,12 @@ class Publish: for (shnum, writer) in self.writers.iteritems(): writer.put_verification_key(verification_key) d = writer.finish_publishing() + d.addErrback(self._connection_problem, writer) # Add the (peerid, shnum) tuple to our list of outstanding # queries. This gets used by _loop if some of our queries # fail to place shares. self.outstanding.add((writer.peerid, writer.shnum)) d.addCallback(self._got_write_answer, writer, started) - d.addErrback(self._connection_problem, writer) ds.append(d) self._record_verinfo() self._status.timings['pack'] = time.time() - started