From 7d3491c74180461dc9d49fc89dad233e240ac475 Mon Sep 17 00:00:00 2001
From: Kegan Dougal <kegan@matrix.org>
Date: Fri, 6 Mar 2015 15:17:50 +0000
Subject: Add some loggers

---
 synapse/appservice/scheduler.py | 10 ++++++++++
 1 file changed, 10 insertions(+)

(limited to 'synapse/appservice/scheduler.py')

diff --git a/synapse/appservice/scheduler.py b/synapse/appservice/scheduler.py
index 99e83747a8..2b3aa3b0ea 100644
--- a/synapse/appservice/scheduler.py
+++ b/synapse/appservice/scheduler.py
@@ -171,6 +171,10 @@ class _TransactionController(object):
 
     @defer.inlineCallbacks
     def on_recovered(self, recoverer):
+        self.recoverers.remove(recoverer)
+        logger.info("Successfully recovered application service: %s",
+                    recoverer.service)
+        logger.info("Active recoverers: %s", len(self.recoverers))
         applied_state = yield self.store.set_appservice_state(
             recoverer.service,
             ApplicationServiceState.UP
@@ -182,6 +186,8 @@ class _TransactionController(object):
     def add_recoverers(self, recoverers):
         for r in recoverers:
             self.recoverers.append(r)
+        if len(recoverers) > 0:
+            logger.info("Active recoverers: %s", len(self.recoverers))
 
     @defer.inlineCallbacks
     def _start_recoverer(self, service):
@@ -190,6 +196,10 @@ class _TransactionController(object):
             ApplicationServiceState.DOWN
         )
         if applied_state:
+            logger.info(
+                "Application service falling behind. Starting recoverer. %s",
+                service
+            )
             recoverer = self.recoverer_fn(service, self.on_recovered)
             self.add_recoverers([recoverer])
             recoverer.recover()
-- 
cgit 1.4.1