diff options
| author | David Baker <dave@matrix.org> | 2017-10-02 16:20:41 +0100 |
|---|---|---|
| committer | David Baker <dave@matrix.org> | 2017-10-02 16:20:41 +0100 |
| commit | 27955056e092b440ed00da13fe6326dd438bb900 (patch) | |
| tree | 8480cf26404b89993e6ffa6cadbabc477be19661 /synapse/federation/federation_client.py | |
| parent | Merge pull request #2472 from matrix-org/erikj/groups_rooms (diff) | |
| parent | Merge pull request #2480 from matrix-org/rav/federation_client_logging (diff) | |
| download | synapse-27955056e092b440ed00da13fe6326dd438bb900.tar.xz | |
Merge branch 'develop' into erikj/groups_merged
Diffstat (limited to 'synapse/federation/federation_client.py')
| -rw-r--r-- | synapse/federation/federation_client.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/synapse/federation/federation_client.py b/synapse/federation/federation_client.py index 861441708b..7c5e5d957f 100644 --- a/synapse/federation/federation_client.py +++ b/synapse/federation/federation_client.py @@ -22,7 +22,7 @@ from synapse.api.constants import Membership from synapse.api.errors import ( CodeMessageException, HttpResponseException, SynapseError, ) -from synapse.util import unwrapFirstError +from synapse.util import unwrapFirstError, logcontext from synapse.util.caches.expiringcache import ExpiringCache from synapse.util.logutils import log_function from synapse.util.logcontext import preserve_fn, preserve_context_over_deferred @@ -189,10 +189,10 @@ class FederationClient(FederationBase): ] # FIXME: We should handle signature failures more gracefully. - pdus[:] = yield preserve_context_over_deferred(defer.gatherResults( + pdus[:] = yield logcontext.make_deferred_yieldable(defer.gatherResults( self._check_sigs_and_hashes(pdus), consumeErrors=True, - )).addErrback(unwrapFirstError) + ).addErrback(unwrapFirstError)) defer.returnValue(pdus) @@ -252,7 +252,7 @@ class FederationClient(FederationBase): pdu = pdu_list[0] # Check signatures are correct. - signed_pdu = yield self._check_sigs_and_hashes([pdu])[0] + signed_pdu = yield self._check_sigs_and_hash(pdu) break |