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

Even more comments

Browse source
This commit is contained in:
Mark Haines 2017-06-28 14:14:46 +01:00
parent 9dcd71745b
commit 5f0bdd68be
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/github.com/matrix-org/dendrite/federationsender/consumers/roomserver.go
View file

@ -134,18 +134,19 @@ func (s *OutputRoomEvent) processMessage(ore api.OutputRoomEvent, ev gomatrixser
return nil return nil
} }
joinedHosts, err := s.joinedHostsAtEvent(ore, ev, oldJoinedHosts) // Work out which hosts were joined at the event itself.
joinedHostsAtEvent, err := s.joinedHostsAtEvent(ore, ev, oldJoinedHosts)
if err != nil { if err != nil {
return err return err
} }
// Send the event.
if err = s.queues.SendEvent( if err = s.queues.SendEvent(
&ev, gomatrixserverlib.ServerName(ore.SendAsServer), joinedHosts, &ev, gomatrixserverlib.ServerName(ore.SendAsServer), joinedHostsAtEvent,
); err != nil { ); err != nil {
return err return err
} }
// TODO: Add the event to the transaction queue
return nil return nil
} }