Flip the check in InputRoomEvents

This commit is contained in:
Neil Alexander 2020-08-20 16:02:15 +01:00
parent 83ee76369d
commit ac3f24315e
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944

View file

@ -73,9 +73,9 @@ func (r *RoomserverInternalAPI) InputRoomEvents(
response *api.InputRoomEventsResponse,
) (err error) {
for i, e := range request.InputRoomEvents {
roomID := e.Event.RoomID()
if !r.DB.SupportsConcurrentRoomInputs() {
roomID = "global"
roomID := "global"
if r.DB.SupportsConcurrentRoomInputs() {
roomID = e.Event.RoomID()
}
mutex, _ := r.mutexes.LoadOrStore(roomID, &sync.Mutex{})
mutex.(*sync.Mutex).Lock()