mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-20 12:33:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix panic in database GetAsyncTransaction

Browse source
This commit is contained in:
Devon Hudson 2022-12-06 13:56:04 -07:00
parent fea8b5787a
commit 5d45b5baad
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
federationapi/storage/shared/storage.go
View file

@ -384,7 +384,11 @@ func (d *Database) GetAsyncTransaction(
return nil, nil, nil return nil, nil, nil
} }
txns, err := d.FederationTransactionJSON.SelectTransactionJSON(ctx, nil, nids) txns := map[int64][]byte{}
err = d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
txns, err = d.FederationTransactionJSON.SelectTransactionJSON(ctx, txn, nids)
return err
})
if err != nil { if err != nil {
return nil, nil, fmt.Errorf("d.SelectTransactionJSON: %w", err) return nil, nil, fmt.Errorf("d.SelectTransactionJSON: %w", err)
} }