From 8c7406508a72f5ddeb86b5c9cc2baa7a6230b0b1 Mon Sep 17 00:00:00 2001 From: kevan <kevan@isnotajoke.com> Date: Sat, 17 Sep 2011 16:47:08 -0700 Subject: [PATCH] mutable/publish: add errback immediately after write, don't consume errors from other parts of the publisher --- src/allmydata/mutable/publish.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 -- 2.45.2