|
@@ -89,8 +89,8 @@ func (wb *watchBroadcast) bcast(wr clientv3.WatchResponse) {
|
|
|
for r := range wb.receivers {
|
|
for r := range wb.receivers {
|
|
|
r.send(wr)
|
|
r.send(wr)
|
|
|
}
|
|
}
|
|
|
- if wb.size() > 0 {
|
|
|
|
|
- eventsCoalescing.Add(float64(wb.size() - 1))
|
|
|
|
|
|
|
+ if len(wb.receivers) > 0 {
|
|
|
|
|
+ eventsCoalescing.Add(float64(len(wb.receivers) - 1))
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -135,7 +135,7 @@ func (wb *watchBroadcast) delete(w *watcher) {
|
|
|
panic("deleting missing watcher from broadcast")
|
|
panic("deleting missing watcher from broadcast")
|
|
|
}
|
|
}
|
|
|
delete(wb.receivers, w)
|
|
delete(wb.receivers, w)
|
|
|
- if !wb.empty() {
|
|
|
|
|
|
|
+ if len(wb.receivers) > 0 {
|
|
|
// do not dec the only left watcher for coalescing.
|
|
// do not dec the only left watcher for coalescing.
|
|
|
watchersCoalescing.Dec()
|
|
watchersCoalescing.Dec()
|
|
|
}
|
|
}
|