diff options
| author | David Baker <dbkr@matrix.org> | 2014-08-29 13:24:08 +0100 |
|---|---|---|
| committer | David Baker <dbkr@matrix.org> | 2014-08-29 13:24:08 +0100 |
| commit | 3e6a19cf0938423b53b17b520bb6c59b9eb4dd06 (patch) | |
| tree | c36e5b3a253499d6f5b2d44aa954f993c96c5b95 /synapse/handlers/events.py | |
| parent | Change call signalling messages to be their own types of room events rather t... (diff) | |
| parent | Show notifications only when the user is detected as idle (diff) | |
| download | synapse-3e6a19cf0938423b53b17b520bb6c59b9eb4dd06.tar.xz | |
Merge branch 'develop' of github.com:matrix-org/synapse into develop
Diffstat (limited to 'synapse/handlers/events.py')
| -rw-r--r-- | synapse/handlers/events.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/synapse/handlers/events.py b/synapse/handlers/events.py index e08231406d..980a169b25 100644 --- a/synapse/handlers/events.py +++ b/synapse/handlers/events.py @@ -16,6 +16,7 @@ from twisted.internet import defer from synapse.api.events import SynapseEvent +from synapse.util.logutils import log_function from ._base import BaseHandler @@ -44,6 +45,7 @@ class EventStreamHandler(BaseHandler): self.notifier = hs.get_notifier() @defer.inlineCallbacks + @log_function def get_stream(self, auth_user_id, pagin_config, timeout=0): auth_user = self.hs.parse_userid(auth_user_id) @@ -90,13 +92,15 @@ class EventStreamHandler(BaseHandler): # 10 seconds of grace to allow the client to reconnect again # before we think they're gone def _later(): + logger.debug("_later stopped_user_eventstream %s", auth_user) self.distributor.fire( "stopped_user_eventstream", auth_user ) del self._stop_timer_per_user[auth_user] + logger.debug("Scheduling _later: for %s", auth_user) self._stop_timer_per_user[auth_user] = ( - self.clock.call_later(5, _later) + self.clock.call_later(30, _later) ) |