summary refs log tree commit diff
path: root/synapse/storage/deviceinbox.py (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Opentrace device lists (#5853)Jorik Schellekens2019-09-031-0/+21
| | | Trace device list changes.
* Remove unnecessary parentheses around return statements (#5931)Andrew Morgan2019-08-301-2/+2
| | | | | Python will return a tuple whether there are parentheses around the returned values or not. I'm just sick of my editor complaining about this all over the place :)
* Replace returnValue with return (#5736)Amber Brown2019-07-231-5/+5
|
* Fix bug sending federation transactions with lots of EDUsErik Johnston2019-06-101-0/+4
| | | | | | If we try and send a transaction with lots of EDUs and we run out of space, we call get_new_device_msgs_for_remote with a limit of 0, which then failed.
* Limit the number of EDUs in transactions to 100 as expected by receiver (#5138)Quentin Dufour2019-05-091-1/+1
| | | Fixes #3951.
* Run black on the rest of the storage module (#4996)Amber Brown2019-04-031-39/+24
|
* Fixup slave storesErik Johnston2019-03-041-161/+163
|
* Port storage/ to Python 3 (#3725)Amber Brown2018-08-311-1/+1
|
* run isortAmber Brown2018-07-091-2/+1
|
* Attempt to be more performant on PyPy (#3462)Amber Brown2018-06-281-6/+7
|
* Replace ujson with simplejsonErik Johnston2018-03-151-6/+6
|
* Make __init__ consitstent across Store heirarchyRichard van der Hoff2017-11-131-2/+2
| | | | | | Add db_conn parameters to the `__init__` methods of the *Store classes, so that they are all consistent, which makes the multiple inheritance work correctly (and so that we can later extract mixins which can be used in the slavedstores)
* Deduplicate new deviceinbox rows for replicationErik Johnston2017-04-041-4/+7
|
* User Cursor.__iter__ instead of fetchallErik Johnston2017-03-231-5/+5
| | | | This prevents unnecessary construction of lists
* Fix assertion to stop transaction queue getting wedgedRichard van der Hoff2017-03-151-3/+3
| | | | | | | | ... and update some docstrings to correctly reflect the types being used. get_new_device_msgs_for_remote can return a long under some circumstances, which was being stored in last_device_list_stream_id_by_dest, and was then upsetting things on the next loop.
* Noop repated delete device inbox calls from /syncErik Johnston2017-03-101-1/+35
|
* Explicitly close the cursorErik Johnston2017-01-101-0/+1
|
* Don't disable autocommitErik Johnston2017-01-101-8/+4
|
* Change device_inbox stream index to include userErik Johnston2017-01-101-2/+36
| | | | | This makes fetching the nost recently changed users much tricker, and brings it in line with e.g. presence_stream indices.
* Add some logging for syncing to_device eventsRichard van der Hoff2016-12-151-1/+2
| | | | | Attempt to track down the loss of to_device events (https://github.com/vector-im/riot-web/issues/2711 etc).
* Handle sending events and device messages over federationErik Johnston2016-11-171-12/+14
|
* Fix direct to device messages recieved over federation to notify syncMark Haines2016-09-121-0/+2
|
* Track the max_stream_device_id in a separate table, since we delete from the ↵Mark Haines2016-09-091-2/+15
| | | | inbox table
* Support wildcard device_ids for direct to device messagesMark Haines2016-09-081-18/+36
|
* Add stream change caches for device messagesMark Haines2016-09-071-0/+25
|
* Comment the add_messages storage functionsMark Haines2016-09-071-8/+16
|
* Send device messages over federationMark Haines2016-09-061-11/+8
|
* Add storage methods for federated device messagesMark Haines2016-09-061-7/+132
|
* Move _add_messages_to_device_inbox_txn into a separate methodMark Haines2016-09-061-37/+32
|
* Only return new device messages in /syncMark Haines2016-09-021-3/+5
|
* Return the current stream position from add_messages_to_device_inboxMark Haines2016-08-311-1/+4
|
* Add a replication stream for direct to device messagesMark Haines2016-08-311-0/+39
|
* Fix the deduplication of incoming direct-to-device messagesMark Haines2016-08-251-0/+4
|
* Add store-and-forward direct-to-device messagingMark Haines2016-08-251-0/+136