Skip to content

Commit 638e338

Browse files
committed
kvserver: don't swallow errors in forceScanOnAllReplicationQueues
1 parent 3c1a191 commit 638e338

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

pkg/kv/kvserver/replicate_queue_test.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1786,11 +1786,13 @@ func toggleReplicationQueues(tc *testcluster.TestCluster, active bool) {
17861786

17871787
func forceScanOnAllReplicationQueues(tc *testcluster.TestCluster) (err error) {
17881788
for _, s := range tc.Servers {
1789-
err = s.GetStores().(*kvserver.Stores).VisitStores(func(store *kvserver.Store) error {
1789+
if err := s.GetStores().(*kvserver.Stores).VisitStores(func(store *kvserver.Store) error {
17901790
return store.ForceReplicationScanAndProcess()
1791-
})
1791+
}); err != nil {
1792+
return err
1793+
}
17921794
}
1793-
return err
1795+
return nil
17941796
}
17951797

17961798
func toggleSplitQueues(tc *testcluster.TestCluster, active bool) {

0 commit comments

Comments
 (0)