From e3ac29768d475b2ae882f5b6cc02cdbc9074ec72 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Thu, 27 Aug 2020 10:33:48 +0100 Subject: [PATCH] Additional fix to writers --- federationsender/storage/shared/storage_edus.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/federationsender/storage/shared/storage_edus.go b/federationsender/storage/shared/storage_edus.go index 19c55504e..529b46aa9 100644 --- a/federationsender/storage/shared/storage_edus.go +++ b/federationsender/storage/shared/storage_edus.go @@ -21,7 +21,6 @@ import ( "errors" "fmt" - "github.com/matrix-org/dendrite/internal/sqlutil" "github.com/matrix-org/gomatrixserverlib" ) @@ -33,7 +32,7 @@ func (d *Database) AssociateEDUWithDestination( serverName gomatrixserverlib.ServerName, receipt *Receipt, ) error { - return sqlutil.WithTransaction(d.DB, func(txn *sql.Tx) error { + return d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error { for _, nid := range receipt.nids { if err := d.FederationSenderQueueEDUs.InsertQueueEDU( ctx, // context