diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2020-12-09 10:03:22 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-12-09 10:03:22 +0000 |
| commit | f64c8822bc5b930d65ef32792df4d7b279143bce (patch) | |
| tree | c958145e8fb45bb03738272de8c30668e1b49fe0 /federationsender/storage/tables/interface.go | |
| parent | e1d32e2ff1bef346836f6b9d795d33ec49dd3864 (diff) | |
Federation sender refactor (#1621)
* Refactor federation sender, again
* Clean up better
* Missing operators
* Try to get overflowed events from database
* Fix queries
* Log less
* Comments
* nil PDUs/EDUs shouldn't happen but guard against them for safety
* Tweak logging
* Fix transaction coalescing
* Update comments
* Check nils more
* Remove channels as they add extra complexity and possibly will deadlock
* Don't hold lock while sending transaction
* Less spam about sleeping queues
* Comments
* Bug-fixing
* Don't try to rehydrate twice
* Don't queue in memory for blacklisted destinations
* Don't queue in memory for blacklisted destinations
* Fix a couple of bugs
* Check for duplicates when pulling things out of the database
* Durable transactions, some more refactoring
* Revert "Durable transactions, some more refactoring"
This reverts commit 5daf924eaaefec5e4f7c12c16ca24e898de4adbb.
* Fix deadlock
Diffstat (limited to 'federationsender/storage/tables/interface.go')
| -rw-r--r-- | federationsender/storage/tables/interface.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/federationsender/storage/tables/interface.go b/federationsender/storage/tables/interface.go index 1167a212..69e952de 100644 --- a/federationsender/storage/tables/interface.go +++ b/federationsender/storage/tables/interface.go @@ -25,10 +25,9 @@ import ( type FederationSenderQueuePDUs interface { InsertQueuePDU(ctx context.Context, txn *sql.Tx, transactionID gomatrixserverlib.TransactionID, serverName gomatrixserverlib.ServerName, nid int64) error DeleteQueuePDUs(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName, jsonNIDs []int64) error - SelectQueuePDUNextTransactionID(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName) (gomatrixserverlib.TransactionID, error) SelectQueuePDUReferenceJSONCount(ctx context.Context, txn *sql.Tx, jsonNID int64) (int64, error) SelectQueuePDUCount(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName) (int64, error) - SelectQueuePDUs(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName, transactionID gomatrixserverlib.TransactionID, limit int) ([]int64, error) + SelectQueuePDUs(ctx context.Context, txn *sql.Tx, serverName gomatrixserverlib.ServerName, limit int) ([]int64, error) SelectQueuePDUServerNames(ctx context.Context, txn *sql.Tx) ([]gomatrixserverlib.ServerName, error) } |