-
Notifications
You must be signed in to change notification settings - Fork 1
Open
Description
When one of nodes valkey cluster become fail, func Dispatcher.reloadTopology() does not start.
Problen in func slotsReloadLoop - it stars once
for range time.After(d.slotReloadInterval) can trigger onlu one event
my fix is:
- periodicReloadInterval := 60 * time.Second
- for range time.After(d.slotReloadInterval) {
+ for {
select {
case _, ok := <-d.slotReloadChan:
if !ok {
@@ -122,7 +121,7 @@ func (d *Dispatcher) slotsReloadLoop() {
} else {
d.slotInfoChan <- slotInfos
}
- case <-time.After(periodicReloadInterval):
+ case <-time.After(d.slotReloadInterval):
glog.Infof("periodic reload triggered")
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels