This commit is contained in:
Fabian Reinartz 2015-12-04 14:55:42 +01:00
parent 78ac6859a1
commit 7ddcc42efa

View File

@ -170,7 +170,7 @@ func (d *Dispatcher) run(it provider.AlertIterator) {
}
case <-cleanup.C:
d.mtx.RLock()
d.mtx.Lock()
for _, groups := range d.aggrGroups {
for _, ag := range groups {
@ -181,7 +181,7 @@ func (d *Dispatcher) run(it provider.AlertIterator) {
}
}
d.mtx.RUnlock()
d.mtx.Unlock()
case <-d.ctx.Done():
return