diff options
author | David Baker <dave@matrix.org> | 2015-01-27 15:58:27 +0000 |
---|---|---|
committer | David Baker <dave@matrix.org> | 2015-01-27 15:58:27 +0000 |
commit | 1d779691248be2fcdd43e97352d13c2cef239c10 (patch) | |
tree | 0b6b40aec503ca42f77b968c6d84b204edefeb48 | |
parent | Support membership events and more camelcase/underscores (diff) | |
download | synapse-1d779691248be2fcdd43e97352d13c2cef239c10.tar.xz |
Unbreak bad presence merge - don't add these blocks together with an and: they're different things.
-rw-r--r-- | synapse/handlers/events.py | 26 |
1 files changed, 14 insertions, 12 deletions
diff --git a/synapse/handlers/events.py b/synapse/handlers/events.py index 75fb941008..f1a3e4a4ad 100644 --- a/synapse/handlers/events.py +++ b/synapse/handlers/events.py @@ -51,19 +51,21 @@ class EventStreamHandler(BaseHandler): auth_user = self.hs.parse_userid(auth_user_id) try: - if affect_presence and auth_user not in self._streams_per_user: - self._streams_per_user[auth_user] = 0 - if auth_user in self._stop_timer_per_user: - try: - self.clock.cancel_call_later( - self._stop_timer_per_user.pop(auth_user) + if affect_presence: + if auth_user not in self._streams_per_user: + self._streams_per_user[auth_user] = 0 + if auth_user in self._stop_timer_per_user: + try: + print "cancel",auth_user + self.clock.cancel_call_later( + self._stop_timer_per_user.pop(auth_user) + ) + except: + logger.exception("Failed to cancel event timer") + else: + yield self.distributor.fire( + "started_user_eventstream", auth_user ) - except: - logger.exception("Failed to cancel event timer") - else: - yield self.distributor.fire( - "started_user_eventstream", auth_user - ) self._streams_per_user[auth_user] += 1 if pagin_config.from_token is None: |