Skip to content

Commit a3b51b5

Browse files
kvserver: avoid starting async raft worker on error
Epic: None Fixes: None Release note: None
1 parent 7c168dd commit a3b51b5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

pkg/kv/kvserver/scheduler.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -300,8 +300,8 @@ func (s *raftScheduler) Start(stopper *stop.Stopper) {
300300
for _, shard := range s.shards {
301301
shard.Lock()
302302
shard.stopped = true
303-
shard.Unlock()
304303
shard.cond.Broadcast()
304+
shard.Unlock()
305305
}
306306
})
307307

@@ -324,6 +324,7 @@ func (s *raftScheduler) Start(stopper *stop.Stopper) {
324324
})
325325
if err != nil {
326326
s.done.Done()
327+
continue
327328
}
328329
go f(ctx, hdl)
329330
}

0 commit comments

Comments
 (0)