hoernschen/dendrite
1
0
Fork 0
mirror of https://github.com/hoernschen/dendrite.git synced 2025-04-06 12:03:38 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Make it build

Browse source
This commit is contained in:
Erik Johnston 2018-01-02 17:06:12 +00:00
parent ed375d1d76
commit 1dcc896893
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/github.com/matrix-org/dendrite/roomserver/input/latest_events.go
View file

@ -57,16 +57,19 @@ func (e *EventSender) Send(
func (e *EventSender) SendMany( func (e *EventSender) SendMany(
ctx context.Context, ctx context.Context,
roomNID types.RoomNID, roomNID types.RoomNID,
roomID string,
events []EventSenderValue, events []EventSenderValue,
) (err error) { ) (err error) {
e.linearizer.Await(event.RoomID(), func() { e.linearizer.Await(roomID, func() {
for i := range events { for i := range events {
err = updateLatestEvents(ctx, e.db, e.outputWriter, roomNID, stateAtEvent, event, sendAsServer, transactionID) err = updateLatestEvents(ctx, e.db, e.outputWriter, roomNID, events[i].stateAtEvent, events[i].event, events[i].sendAsServer, events[i].transactionID)
if err != nil { if err != nil {
return return
} }
} }
}) })
return
} }
// updateLatestEvents updates the list of latest events for this room in the database and writes the // updateLatestEvents updates the list of latest events for this room in the database and writes the