summary refs log tree commit diff
diff options
context:
space:
mode:
authorRichard van der Hoff <richard@matrix.org>2017-10-11 14:37:20 +0100
committerRichard van der Hoff <richard@matrix.org>2017-10-11 14:37:20 +0100
commitc3e190ce671ed37a31a1543f42e26277fea582ce (patch)
tree3c595d57f2528e55cdef9a4ae3dcbe0a852fda68
parentMerge pull request #2517 from matrix-org/rav/fed_server_refactor (diff)
downloadsynapse-c3e190ce671ed37a31a1543f42e26277fea582ce.tar.xz
fix a logcontext leak in read receipt handling
-rw-r--r--synapse/handlers/receipts.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/synapse/handlers/receipts.py b/synapse/handlers/receipts.py
index e1cd3a48e9..0525765272 100644
--- a/synapse/handlers/receipts.py
+++ b/synapse/handlers/receipts.py
@@ -12,6 +12,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+from synapse.util import logcontext
 
 from ._base import BaseHandler
 
@@ -59,6 +60,8 @@ class ReceiptsHandler(BaseHandler):
         is_new = yield self._handle_new_receipts([receipt])
 
         if is_new:
+            # fire off a process in the background to send the receipt to
+            # remote servers
             self._push_remotes([receipt])
 
     @defer.inlineCallbacks
@@ -126,6 +129,7 @@ class ReceiptsHandler(BaseHandler):
 
             defer.returnValue(True)
 
+    @logcontext.preserve_fn   # caller should not yield on this
     @defer.inlineCallbacks
     def _push_remotes(self, receipts):
         """Given a list of receipts, works out which remote servers should be