diff options
| author | Erik Johnston <erik@matrix.org> | 2016-11-16 17:34:44 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-11-16 17:34:44 +0000 |
| commit | ed787cf09edd77e39ad9da0b957359214de85287 (patch) | |
| tree | befff8fe0284099e1e2df9eccd729ff1eedd4727 /synapse/replication/slave | |
| parent | Add initial cut of federation send queue (diff) | |
| download | synapse-ed787cf09edd77e39ad9da0b957359214de85287.tar.xz | |
Hook up the send queue and create a federation sender worker
Diffstat (limited to 'synapse/replication/slave')
| -rw-r--r-- | synapse/replication/slave/storage/deviceinbox.py | 5 | ||||
| -rw-r--r-- | synapse/replication/slave/storage/transactions.py | 3 |
2 files changed, 8 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/deviceinbox.py b/synapse/replication/slave/storage/deviceinbox.py index 3bfd5e8213..373212d42d 100644 --- a/synapse/replication/slave/storage/deviceinbox.py +++ b/synapse/replication/slave/storage/deviceinbox.py @@ -29,9 +29,14 @@ class SlavedDeviceInboxStore(BaseSlavedStore): "DeviceInboxStreamChangeCache", self._device_inbox_id_gen.get_current_token() ) + self._device_federation_outbox_stream_cache = StreamChangeCache( + "DeviceFederationOutboxStreamChangeCache", + self._device_inbox_id_gen.get_current_token() + ) get_to_device_stream_token = DataStore.get_to_device_stream_token.__func__ get_new_messages_for_device = DataStore.get_new_messages_for_device.__func__ + get_new_device_msgs_for_remote = DataStore.get_new_device_msgs_for_remote.__func__ delete_messages_for_device = DataStore.delete_messages_for_device.__func__ def stream_positions(self): diff --git a/synapse/replication/slave/storage/transactions.py b/synapse/replication/slave/storage/transactions.py index 6f2ba98af5..c459301b76 100644 --- a/synapse/replication/slave/storage/transactions.py +++ b/synapse/replication/slave/storage/transactions.py @@ -25,6 +25,9 @@ class TransactionStore(BaseSlavedStore): ].orig _get_destination_retry_timings = DataStore._get_destination_retry_timings.__func__ + def prep_send_transaction(self, transaction_id, destination, origin_server_ts): + return [] + # For now, don't record the destination rety timings def set_destination_retry_timings(*args, **kwargs): return defer.succeed(None) |