summary refs log tree commit diff
path: root/synapse/storage
diff options
context:
space:
mode:
authorRichard van der Hoff <1389908+richvdh@users.noreply.github.com>2019-09-11 15:14:56 +0100
committerGitHub <noreply@github.com>2019-09-11 15:14:56 +0100
commit7902bf1e1d6331e7964ac498988925cc26e18f79 (patch)
treec44d0840e4442df22a7b87dc6abb85faad3f1b37 /synapse/storage
parentAdd note about extra arg to send_membership_event, remove arg in remote_rejec... (diff)
downloadsynapse-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.py20
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