From 2122ba78b3b16aeadcb9225a71100d330930de0a Mon Sep 17 00:00:00 2001 From: Zooko O'Whielacronx Date: Wed, 7 Jan 2009 11:00:05 -0700 Subject: [PATCH] util: deferredutil: undo my recent patch to use our own implementation of gatherResults It seems to cause lots of failures on some builders. --- src/allmydata/util/deferredutil.py | 32 ++++++++++-------------------- 1 file changed, 11 insertions(+), 21 deletions(-) diff --git a/src/allmydata/util/deferredutil.py b/src/allmydata/util/deferredutil.py index fd6cd0ce..a1767417 100644 --- a/src/allmydata/util/deferredutil.py +++ b/src/allmydata/util/deferredutil.py @@ -21,25 +21,15 @@ def _unwrapFirstError(f): f.trap(defer.FirstError) raise f.value.subFailure -class ResultsGatherer: - def __init__(self, deferredlist): - self.deferredlist = deferredlist - self.fired = 0 - self.results = [] - self.d = defer.Deferred() - for d in deferredlist: - d.addCallbacks(self._cb, self._eb) - def start(self): - return self.d - def _cb(self, res): - self.results.append(res) - self.fired += 1 - if self.fired >= len(self.deferredlist): - self.d.callback(self.results) - def _eb(self, f): - self.d.errback(f) +def gatherResults(deferredList): + """Returns list with result of given Deferreds. + + This builds on C{DeferredList} but is useful since you don't + need to parse the result for success/failure. + + @type deferredList: C{list} of L{Deferred}s + """ + d = defer.DeferredList(deferredList, fireOnOneErrback=True, consumeErrors=True) + d.addCallbacks(_parseDListResult, _unwrapFirstError) + return d -def gatherResults(deferredlist): - """ Return a deferred that fires with a list of the results of the deferreds, or else errbacks with any error. """ - r = ResultsGatherer(deferredlist) - return r.start() -- 2.45.2