mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-27 00:33:10 -06:00
83c6f07629
This has numerous benefits: - Prevents us doing lots of state resolutions in busy rooms. Previously, room forks would always result in a state resolution being performed immediately, without checking if we were already doing this in a different transaction. Now they will queue up, resulting in fewer calls to `/state_ids`, `/g_m_e`, etc. - Prevents memory usage from growing too large as a result and potentially OOMing. And costs: - High traffic rooms will be slightly slower due to head-of-line blocking from other servers, though this has always been an issue as roomserver has a per-room mutex already.
37 lines
669 B
Go
37 lines
669 B
Go
package internal
|
|
|
|
import "sync"
|
|
|
|
type MutexByRoom struct {
|
|
mu *sync.Mutex // protects the map
|
|
roomToMu map[string]*sync.Mutex
|
|
}
|
|
|
|
func NewMutexByRoom() *MutexByRoom {
|
|
return &MutexByRoom{
|
|
mu: &sync.Mutex{},
|
|
roomToMu: make(map[string]*sync.Mutex),
|
|
}
|
|
}
|
|
|
|
func (m *MutexByRoom) Lock(roomID string) {
|
|
m.mu.Lock()
|
|
defer m.mu.Unlock()
|
|
roomMu := m.roomToMu[roomID]
|
|
if roomMu == nil {
|
|
roomMu = &sync.Mutex{}
|
|
}
|
|
roomMu.Lock()
|
|
m.roomToMu[roomID] = roomMu
|
|
}
|
|
|
|
func (m *MutexByRoom) Unlock(roomID string) {
|
|
m.mu.Lock()
|
|
defer m.mu.Unlock()
|
|
roomMu := m.roomToMu[roomID]
|
|
if roomMu == nil {
|
|
panic("MutexByRoom: Unlock before Lock")
|
|
}
|
|
roomMu.Unlock()
|
|
}
|