Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-10-01 08:25:44 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add ts column to device_lists_outbound_pokes

Browse Source
This commit is contained in:
Erik Johnston 2017-01-27 15:23:48 +00:00
parent 252b503fc8
commit d1e1fd6210
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
synapse/storage/devices.py
View File

@ -486,6 +486,8 @@ class DeviceStore(SQLBaseStore):
defer.returnValue(stream_id) defer.returnValue(stream_id)
def _add_device_change_txn(self, txn, user_id, device_ids, hosts, stream_id): def _add_device_change_txn(self, txn, user_id, device_ids, hosts, stream_id):
now = self._clock.time_msec()
txn.call_after( txn.call_after(
self._device_list_stream_cache.entity_has_changed, self._device_list_stream_cache.entity_has_changed,
user_id, stream_id, user_id, stream_id,
@ -519,6 +521,7 @@ class DeviceStore(SQLBaseStore):
"user_id": user_id, "user_id": user_id,
"device_id": device_id, "device_id": device_id,
"sent": False, "sent": False,
"ts": now,
} }
for destination in hosts for destination in hosts
for device_id in device_ids for device_id in device_ids

3
synapse/storage/schema/delta/40/device_list_streams.sql
View File

@ -51,7 +51,8 @@ CREATE TABLE device_lists_outbound_pokes (
stream_id BIGINT NOT NULL, stream_id BIGINT NOT NULL,
user_id TEXT NOT NULL, user_id TEXT NOT NULL,
device_id TEXT NOT NULL, device_id TEXT NOT NULL,
sent BOOLEAN NOT NULL sent BOOLEAN NOT NULL,
ts BIGINT NOT NULL -- So that in future we can clear out pokes to dead servers
); );
CREATE INDEX device_lists_outbound_pokes_id ON device_lists_outbound_pokes(destination, stream_id); CREATE INDEX device_lists_outbound_pokes_id ON device_lists_outbound_pokes(destination, stream_id);