mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-23 23:03:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Use latest events updater to row-lock prev events

Browse source
This commit is contained in:
Neil Alexander 2020-10-07 12:46:01 +01:00
parent 4e96930f55
commit a270a1012a
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 15 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
roomserver/storage/shared/storage.go
View file

@ -468,12 +468,22 @@ func (d *Database) StoreEvent(
if !isRejected { // ignore rejected redaction events if !isRejected { // ignore rejected redaction events
redactionEvent, redactedEventID, err = d.handleRedactions(ctx, txn, eventNID, event) redactionEvent, redactedEventID, err = d.handleRedactions(ctx, txn, eventNID, event)
} }
for _, prev := range event.PrevEvents() {
if err = d.PrevEventsTable.InsertPreviousEvent(ctx, txn, prev.EventID, prev.EventSHA256, eventNID); err != nil { var roomInfo *types.RoomInfo
return fmt.Errorf("d.PrevEventsTable.InsertPreviousEvent: %w", err) var updater *LatestEventsUpdater
} roomInfo, err = d.RoomInfo(ctx, event.RoomID())
if err != nil {
return fmt.Errorf("d.RoomInfo: %w", err)
} }
return nil updater, err = d.GetLatestEventsForUpdate(ctx, *roomInfo)
if err != nil {
return fmt.Errorf("NewLatestEventsUpdater: %w", err)
}
if err = updater.StorePreviousEvents(eventNID, event.PrevEvents()); err != nil {
return fmt.Errorf("updater.StorePreviousEvents: %w", err)
}
succeeded := false
return sqlutil.EndTransaction(updater, &succeeded)
}) })
if err != nil { if err != nil {
return 0, types.StateAtEvent{}, nil, "", fmt.Errorf("d.Writer.Do: %w", err) return 0, types.StateAtEvent{}, nil, "", fmt.Errorf("d.Writer.Do: %w", err)