summary refs log tree commit diff
path: root/synapse/replication/slave/storage/deviceinbox.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Remove old empty/redundant slaved stores. (#13349)Nick Mills-Barrett2022-07-211-19/+0
|
* Use cache store remove base slaved (#13329)Nick Mills-Barrett2022-07-211-2/+1
| | | This comes from two identical definitions in each of the base stores, and means the base slaved store is now empty and can be removed.
* Remove redundant "coding: utf-8" lines (#9786)Jonathan de Jong2021-04-141-1/+0
| | | | | | | Part of #9744 Removes all redundant `# -*- coding: utf-8 -*-` lines from files, as python 3 automatically reads source code as utf-8 now. `Signed-off-by: Jonathan de Jong <jonathan@automatia.nl>`
* Allow running sendToDevice on workers (#9044)Erik Johnston2021-01-071-31/+1
|
* Some cleanups to device inbox store. (#9041)Erik Johnston2021-01-071-8/+0
|
* Simplify super() calls to Python 3 syntax. (#8344)Patrick Cloke2020-09-181-1/+1
| | | | | | | This converts calls like super(Foo, self) -> super(). Generated with: sed -i "" -Ee 's/super\([^\(]+\)/super()/g' **/*.py
* Make SlavedIdTracker.advance have same interface as MultiWriterIDGenerator ↵Erik Johnston2020-08-261-1/+1
| | | | (#8171)
* Rename database classes to make some sense (#8033)Erik Johnston2020-08-051-3/+3
|
* Stop using 'device_max_stream_id' (#7882)Erik Johnston2020-07-171-1/+1
| | | | | It serves no purpose and updating everytime we write to the device inbox stream means all such transactions will conflict, causing lots of transaction failures and retries.
* Use symbolic names for replication stream names (#7768)Richard van der Hoff2020-07-011-1/+2
| | | This makes it much easier to find where streams are referenced.
* Support any process writing to cache invalidation stream. (#7436)Erik Johnston2020-05-071-4/+2
|
* Use `stream.current_token()` and remove `stream_positions()` (#7172)Erik Johnston2020-05-011-5/+0
| | | | We move the processing of typing and federation replication traffic into their handlers so that `Stream.current_token()` points to a valid token. This allows us to remove `get_streams_to_replicate()` and `stream_positions()`.
* Change DataStores to accept 'database' param.Erik Johnston2019-12-061-2/+3
|
* Move storage classes into a main "data store".Erik Johnston2019-10-211-1/+1
| | | | | This is in preparation for having multiple data stores that offer different functionality, e.g. splitting out state or event storage.
* Run Black. (#5482)Amber Brown2019-06-201-3/+3
|
* Fixup slave storesErik Johnston2019-03-041-11/+4
|
* Make workers work on Py3 (#4027)Amber Brown2018-10-131-6/+6
|
* run isortAmber Brown2018-07-091-3/+4
|
* Change slave storage to use new replication interfaceErik Johnston2017-04-031-13/+10
| | | | | | | As the TCP replication uses a slightly different API and streams than the HTTP replication. This breaks HTTP replication.
* Fix it for the workersErik Johnston2017-03-101-0/+8
|
* Handle sending events and device messages over federationErik Johnston2016-11-171-4/+11
|
* Hook up the send queue and create a federation sender workerErik Johnston2016-11-161-0/+5
|
* Track the max_stream_device_id in a separate table, since we delete from the ↵Mark Haines2016-09-091-1/+1
| | | | inbox table
* Fix the stream change cache to work over replicationMark Haines2016-09-071-0/+11
|
* Add a replication stream for direct to device messagesMark Haines2016-08-311-0/+12
|
* Add new direct message storage functions to slave storeErik Johnston2016-08-301-0/+30