diff options
| author | Richard van der Hoff <github@rvanderhoff.org.uk> | 2017-03-23 22:22:54 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-03-23 22:22:54 +0000 |
| commit | 06ce7335e94d51e7b750e7c51a3445a05e191c3e (patch) | |
| tree | 4a0f43cd52dbbcc9c5eea365b4c404a7b29c3179 /synapse/util | |
| parent | Merge pull request #1783 from pik/filter-validation (diff) | |
| parent | Fix time_bound_deferred to throw the right exception (diff) | |
| download | synapse-06ce7335e94d51e7b750e7c51a3445a05e191c3e.tar.xz | |
Merge pull request #2052 from matrix-org/rav/time_bound_deferred
Fix time_bound_deferred to throw the right exception
Diffstat (limited to 'synapse/util')
| -rw-r--r-- | synapse/util/__init__.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/synapse/util/__init__.py b/synapse/util/__init__.py index 30fc480108..98a5a26ac5 100644 --- a/synapse/util/__init__.py +++ b/synapse/util/__init__.py @@ -26,7 +26,7 @@ logger = logging.getLogger(__name__) class DeferredTimedOutError(SynapseError): def __init__(self): - super(SynapseError).__init__(504, "Timed out") + super(SynapseError, self).__init__(504, "Timed out") def unwrapFirstError(failure): @@ -93,8 +93,10 @@ class Clock(object): ret_deferred = defer.Deferred() def timed_out_fn(): + e = DeferredTimedOutError() + try: - ret_deferred.errback(DeferredTimedOutError()) + ret_deferred.errback(e) except: pass @@ -114,7 +116,7 @@ class Clock(object): ret_deferred.addBoth(cancel) - def sucess(res): + def success(res): try: ret_deferred.callback(res) except: @@ -128,7 +130,7 @@ class Clock(object): except: pass - given_deferred.addCallbacks(callback=sucess, errback=err) + given_deferred.addCallbacks(callback=success, errback=err) timer = self.call_later(time_out, timed_out_fn) |