diff options
author | Erik Johnston <erik@matrix.org> | 2016-02-23 15:51:39 +0000 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2016-02-23 15:51:39 +0000 |
commit | 6451fcd08580cc6142d15b4be5f8956ba496f178 (patch) | |
tree | 240af12525e0cbe23e410a9328aa9ee75454dbdd | |
parent | Handle get_all_entities_changed returning None (diff) | |
download | synapse-6451fcd08580cc6142d15b4be5f8956ba496f178.tar.xz |
Create a new stream_id per presence update
-rw-r--r-- | synapse/storage/presence.py | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/synapse/storage/presence.py b/synapse/storage/presence.py index 70ece56548..3ef91d34db 100644 --- a/synapse/storage/presence.py +++ b/synapse/storage/presence.py @@ -58,17 +58,20 @@ class UserPresenceState(namedtuple("UserPresenceState", class PresenceStore(SQLBaseStore): @defer.inlineCallbacks def update_presence(self, presence_states): - stream_id_manager = yield self._presence_id_gen.get_next(self) - with stream_id_manager as stream_id: + stream_ordering_manager = yield self._presence_id_gen.get_next_mult( + self, len(presence_states) + ) + + with stream_ordering_manager as stream_orderings: yield self.runInteraction( "update_presence", - self._update_presence_txn, stream_id, presence_states, + self._update_presence_txn, stream_orderings, presence_states, ) - defer.returnValue((stream_id, self._presence_id_gen.get_max_token())) + defer.returnValue((stream_orderings[-1], self._presence_id_gen.get_max_token())) - def _update_presence_txn(self, txn, stream_id, presence_states): - for state in presence_states: + def _update_presence_txn(self, txn, stream_orderings, presence_states): + for stream_id, state in zip(stream_orderings, presence_states): txn.call_after( self.presence_stream_cache.entity_has_changed, state.user_id, stream_id, |