diff options
| author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2019-07-05 12:59:42 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-07-05 12:59:42 +0100 |
| commit | a6a776f3d80e441d416c384b7ad9344ee1967d31 (patch) | |
| tree | cfd8c0a1354dbf06d8b4c9a082249b9ed1e05be3 /synapse/federation/sender | |
| parent | Fixes to the federation rate limiter (#5621) (diff) | |
| download | synapse-a6a776f3d80e441d416c384b7ad9344ee1967d31.tar.xz | |
remove dead transaction persist code (#5622)
this hasn't done anything for years
Diffstat (limited to 'synapse/federation/sender')
| -rw-r--r-- | synapse/federation/sender/transaction_manager.py | 9 |
1 files changed, 0 insertions, 9 deletions
diff --git a/synapse/federation/sender/transaction_manager.py b/synapse/federation/sender/transaction_manager.py index c987bb9a0d..0460a8c4ac 100644 --- a/synapse/federation/sender/transaction_manager.py +++ b/synapse/federation/sender/transaction_manager.py @@ -63,8 +63,6 @@ class TransactionManager(object): len(edus), ) - logger.debug("TX [%s] Persisting transaction...", destination) - transaction = Transaction.create_new( origin_server_ts=int(self.clock.time_msec()), transaction_id=txn_id, @@ -76,9 +74,6 @@ class TransactionManager(object): self._next_txn_id += 1 - yield self._transaction_actions.prepare_to_send(transaction) - - logger.debug("TX [%s] Persisted transaction", destination) logger.info( "TX [%s] {%s} Sending transaction [%s]," " (PDUs: %d, EDUs: %d)", destination, @@ -118,10 +113,6 @@ class TransactionManager(object): logger.info("TX [%s] {%s} got %d response", destination, txn_id, code) - yield self._transaction_actions.delivered(transaction, code, response) - - logger.debug("TX [%s] {%s} Marked as delivered", destination, txn_id) - if code == 200: for e_id, r in response.get("pdus", {}).items(): if "error" in r: |