Skip to content

Commit ebb52f1

Browse files
authored
[FIXED} Possible race setting timer kv.WatchFiltered (#1879)
Signed-off-by: Waldemar Quevedo <[email protected]>
1 parent abad5e6 commit ebb52f1

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

kv.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1051,7 +1051,10 @@ func (kv *kvs) WatchFiltered(keys []string, opts ...WatchOpt) (KeyWatcher, error
10511051
w.initPending = delta
10521052
}
10531053
if w.received > w.initPending || delta == 0 {
1054-
w.initDoneTimer.Stop()
1054+
// Avoid possible race setting up timer.
1055+
if w.initDoneTimer != nil {
1056+
w.initDoneTimer.Stop()
1057+
}
10551058
w.initDone = true
10561059
w.updates <- nil
10571060
} else if w.initDoneTimer != nil {

0 commit comments

Comments
 (0)