summary refs log tree commit diff
path: root/synapse/util/__init__.py
diff options
context:
space:
mode:
authorErik Johnston <erikj@jki.re>2018-10-09 10:12:10 +0100
committerGitHub <noreply@github.com>2018-10-09 10:12:10 +0100
commit9eb1a7910020cbe867cb9b89414e95a9e342a81b (patch)
tree849d18757759d02f65c7e5c186876fad8d8ee947 /synapse/util/__init__.py
parentMerge pull request #4017 from matrix-org/rav/optimise_filter_events_for_server (diff)
parentRemove unnecessary extra function call layer (diff)
downloadsynapse-9eb1a7910020cbe867cb9b89414e95a9e342a81b.tar.xz
Merge pull request #4008 from matrix-org/erikj/log_looping_exceptions
Log looping call exceptions
Diffstat (limited to 'synapse/util/__init__.py')
-rw-r--r--synapse/util/__init__.py31
1 files changed, 30 insertions, 1 deletions
diff --git a/synapse/util/__init__.py b/synapse/util/__init__.py
index 680ea928c7..9a8fae0497 100644
--- a/synapse/util/__init__.py
+++ b/synapse/util/__init__.py
@@ -68,7 +68,10 @@ class Clock(object):
         """
         call = task.LoopingCall(f)
         call.clock = self._reactor
-        call.start(msec / 1000.0, now=False)
+        d = call.start(msec / 1000.0, now=False)
+        d.addErrback(
+            log_failure, "Looping call died", consumeErrors=False,
+        )
         return call
 
     def call_later(self, delay, callback, *args, **kwargs):
@@ -109,3 +112,29 @@ def batch_iter(iterable, size):
     sourceiter = iter(iterable)
     # call islice until it returns an empty tuple
     return iter(lambda: tuple(islice(sourceiter, size)), ())
+
+
+def log_failure(failure, msg, consumeErrors=True):
+    """Creates a function suitable for passing to `Deferred.addErrback` that
+    logs any failures that occur.
+
+    Args:
+        msg (str): Message to log
+        consumeErrors (bool): If true consumes the failure, otherwise passes
+            on down the callback chain
+
+    Returns:
+        func(Failure)
+    """
+
+    logger.error(
+        msg,
+        exc_info=(
+            failure.type,
+            failure.value,
+            failure.getTracebackObject()
+        )
+    )
+
+    if not consumeErrors:
+        return failure