From f5d2514fc05e062b1425139c5064cd5bae3c3ca7 Mon Sep 17 00:00:00 2001
From: "Paul \"LeoNerd\" Evans" <paul@matrix.org>
Date: Wed, 3 Dec 2014 19:48:14 +0000
Subject: [PATCH] @log_function on PresenceStream's get_new_events_for_user()
---
synapse/handlers/presence.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/synapse/handlers/presence.py b/synapse/handlers/presence.py
index d40218dd28..84a039489f 100644
--- a/synapse/handlers/presence.py
+++ b/synapse/handlers/presence.py
@@ -804,6 +804,7 @@ class PresenceEventSource(object):
)
@defer.inlineCallbacks
+ @log_function
def get_new_events_for_user(self, user, from_key, limit):
from_key = int(from_key)
@@ -816,7 +817,8 @@ class PresenceEventSource(object):
# TODO(paul): use a DeferredList ? How to limit concurrency.
for observed_user in cachemap.keys():
cached = cachemap[observed_user]
- if not (from_key < cached.serial):
+
+ if cached.serial <= from_key:
continue
if (yield self.is_visible(observer_user, observed_user)):