summary refs log tree commit diff
path: root/synapse/replication/slave
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2017-02-03 18:12:53 +0000
committerErik Johnston <erik@matrix.org>2017-02-14 13:39:41 +0000
commit095b45c1653bc93788a45b891f29efc30f0b1b07 (patch)
tree71b7a50533d9828adaed6f455e18960ae518c572 /synapse/replication/slave
parentMerge pull request #1873 from matrix-org/erikj/delete_push_actions (diff)
downloadsynapse-095b45c1653bc93788a45b891f29efc30f0b1b07.tar.xz
Aggregate event push actions
Diffstat (limited to 'synapse/replication/slave')
-rw-r--r--synapse/replication/slave/storage/events.py6
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/events.py b/synapse/replication/slave/storage/events.py
index d72ff6055c..622b2d8540 100644
--- a/synapse/replication/slave/storage/events.py
+++ b/synapse/replication/slave/storage/events.py
@@ -85,6 +85,12 @@ class SlavedEventStore(BaseSlavedStore):
     get_unread_event_push_actions_by_room_for_user = (
         EventPushActionsStore.__dict__["get_unread_event_push_actions_by_room_for_user"]
     )
+    _get_unread_counts_by_receipt_txn = (
+        DataStore._get_unread_counts_by_receipt_txn.__func__
+    )
+    _get_unread_counts_by_pos_txn = (
+        DataStore._get_unread_counts_by_pos_txn.__func__
+    )
     _get_state_group_for_events = (
         StateStore.__dict__["_get_state_group_for_events"]
     )