summary refs log tree commit diff
path: root/synapse/handlers/presence.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2016-09-05 14:12:11 +0100
committerErik Johnston <erik@matrix.org>2016-09-05 14:12:11 +0100
commit69054e3d4c46d99f877b3242707bbeaa43485f17 (patch)
tree3acf7755305697aa44202715e7af220cc98a2242 /synapse/handlers/presence.py
parentMerge pull request #1068 from matrix-org/erikj/bulk_push (diff)
downloadsynapse-69054e3d4c46d99f877b3242707bbeaa43485f17.tar.xz
Record why we have chosen to notify
Diffstat (limited to 'synapse/handlers/presence.py')
-rw-r--r--synapse/handlers/presence.py8
1 files changed, 8 insertions, 0 deletions
diff --git a/synapse/handlers/presence.py b/synapse/handlers/presence.py
index cf82a2336e..7ae05603f5 100644
--- a/synapse/handlers/presence.py
+++ b/synapse/handlers/presence.py
@@ -52,6 +52,8 @@ bump_active_time_counter = metrics.register_counter("bump_active_time")
 
 get_updates_counter = metrics.register_counter("get_updates", labels=["type"])
 
+notify_reason_counter = metrics.register_counter("notify_reason", labels=["reason"])
+
 
 # If a user was last active in the last LAST_ACTIVE_GRANULARITY, consider them
 # "currently_active"
@@ -940,26 +942,32 @@ def should_notify(old_state, new_state):
     """Decides if a presence state change should be sent to interested parties.
     """
     if old_state.status_msg != new_state.status_msg:
+        notify_reason_counter.inc("status_msg_change")
         return True
 
     if old_state.state == PresenceState.ONLINE:
         if new_state.state != PresenceState.ONLINE:
             # Always notify for online -> anything
+            notify_reason_counter.inc("online_to_not")
             return True
 
         if new_state.currently_active != old_state.currently_active:
+            notify_reason_counter.inc("current_active_change")
             return True
 
         if new_state.last_active_ts - old_state.last_active_ts > LAST_ACTIVE_GRANULARITY:
             # Only notify about last active bumps if we're not currently acive
             if not (old_state.currently_active and new_state.currently_active):
+                notify_reason_counter.inc("last_active_change")
                 return True
 
     elif new_state.last_active_ts - old_state.last_active_ts > LAST_ACTIVE_GRANULARITY:
         # Always notify for a transition where last active gets bumped.
+        notify_reason_counter.inc("last_active_change")
         return True
 
     if old_state.state != new_state.state:
+        notify_reason_counter.inc("state_change")
         return True
 
     return False