diff options
| author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2019-09-11 15:14:56 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-09-11 15:14:56 +0100 |
| commit | 7902bf1e1d6331e7964ac498988925cc26e18f79 (patch) | |
| tree | c44d0840e4442df22a7b87dc6abb85faad3f1b37 /synapse/storage | |
| parent | Add note about extra arg to send_membership_event, remove arg in remote_rejec... (diff) | |
| download | synapse-7902bf1e1d6331e7964ac498988925cc26e18f79.tar.xz | |
Clean up some code in the retry logic (#6017)
* remove some unused code * make things which were constants into constants for efficiency and clarity
Diffstat (limited to 'synapse/storage')
| -rw-r--r-- | synapse/storage/transactions.py | 20 |
1 files changed, 0 insertions, 20 deletions
diff --git a/synapse/storage/transactions.py b/synapse/storage/transactions.py index b3c3bf55bc..d81ace0ece 100644 --- a/synapse/storage/transactions.py +++ b/synapse/storage/transactions.py @@ -250,26 +250,6 @@ class TransactionStore(SQLBaseStore): }, ) - def get_destinations_needing_retry(self): - """Get all destinations which are due a retry for sending a transaction. - - Returns: - list: A list of dicts - """ - - return self.runInteraction( - "get_destinations_needing_retry", self._get_destinations_needing_retry - ) - - def _get_destinations_needing_retry(self, txn): - query = ( - "SELECT * FROM destinations" - " WHERE retry_last_ts > 0 and retry_next_ts < ?" - ) - - txn.execute(query, (self._clock.time_msec(),)) - return self.cursor_to_dict(txn) - def _start_cleanup_transactions(self): return run_as_background_process( "cleanup_transactions", self._cleanup_transactions |