Richard van der Hoff ce428a1abe Fix EventsStream raising assertions when it falls behind ... Figuring out how to correctly limit updates from this stream without dropping entries is far more complicated than just counting the number of rows being returned. We need to consider each query separately and, if any one query hits the limit, truncate the results from the others. I think this also fixes some potentially long-standing bugs where events or state changes could get missed if we hit the limit on either query.		2020-04-24 13:59:21 +01:00
..
schema	bg update to clear out duplicate outbound_device_list_pokes (#7193)	2020-04-07 23:06:39 +01:00
__init__.py	Add 'device_lists_outbound_pokes' as extra table.	2020-02-28 11:15:11 +00:00
account_data.py	…
appservice.py	Clarify list/set/dict/tuple comprehensions and enforce via flake8 (#6957)	2020-02-21 07:15:07 -05:00
cache.py	Move catchup of replication streams to worker. (#7024)	2020-03-25 14:54:01 +00:00
client_ips.py	bg update to clear out duplicate outbound_device_list_pokes (#7193)	2020-04-07 23:06:39 +01:00
deviceinbox.py	Move catchup of replication streams to worker. (#7024)	2020-03-25 14:54:01 +00:00
devices.py	bg update to clear out duplicate outbound_device_list_pokes (#7193)	2020-04-07 23:06:39 +01:00
directory.py	Transfer alias mappings when joining an upgraded room (#6946)	2020-03-30 17:53:25 +01:00
e2e_room_keys.py	Ensure is_verified on /_matrix/client/r0/room_keys/keys is a boolean (#7150)	2020-03-27 13:30:22 +00:00
end_to_end_keys.py	Remove concept of a non-limited stream. (#7011)	2020-03-20 14:40:47 +00:00
event_federation.py	Fix a potentially-huge sql query (#7274)	2020-04-15 10:16:35 +01:00
event_push_actions.py	Move `get_time_of_last_push_action_before` to the `EventPushActionsWorkerStore`	2020-03-09 13:58:38 +00:00
events.py	Move catchup of replication streams to worker. (#7024)	2020-03-25 14:54:01 +00:00
events_bg_updates.py	Clarify list/set/dict/tuple comprehensions and enforce via flake8 (#6957)	2020-02-21 07:15:07 -05:00
events_worker.py	Fix EventsStream raising assertions when it falls behind	2020-04-24 13:59:21 +01:00
filtering.py	…
group_server.py	…
keys.py	…
media_repository.py	Convert delete_url_cache_media to async/await. (#7241)	2020-04-07 21:56:34 +01:00
monthly_active_users.py	Break down monthly active users by appservice_id (#7030)	2020-03-06 18:14:19 +00:00
openid.py	…
presence.py	Remove concept of a non-limited stream. (#7011)	2020-03-20 14:40:47 +00:00
profile.py	…
push_rule.py	Fix race in replication (#7226)	2020-04-07 11:01:04 +01:00
pusher.py	Merge worker apps into one. (#6964)	2020-02-25 16:56:55 +00:00
receipts.py	Clarify list/set/dict/tuple comprehensions and enforce via flake8 (#6957)	2020-02-21 07:15:07 -05:00
registration.py	Fixed set a user as an admin with the new API (#6928)	2020-02-28 09:58:05 +00:00
rejections.py	…
relations.py	…
room.py	Extend room admin api with additional attributes (#7225)	2020-04-22 13:38:41 +01:00
roommember.py	Clarify list/set/dict/tuple comprehensions and enforce via flake8 (#6957)	2020-02-21 07:15:07 -05:00
search.py	…
signatures.py	…
state.py	Clarify list/set/dict/tuple comprehensions and enforce via flake8 (#6957)	2020-02-21 07:15:07 -05:00
state_deltas.py	Always return a deferred from `get_current_state_deltas`. (#7019)	2020-03-02 16:52:15 +00:00
stats.py	…
stream.py	Remove stream before/after debug log lines (#7207)	2020-04-06 12:40:34 +01:00
tags.py	…
transactions.py	…
user_directory.py	…
user_erasure_store.py	Clarify list/set/dict/tuple comprehensions and enforce via flake8 (#6957)	2020-02-21 07:15:07 -05:00