From d12bc1b0feb4493744d02fd26db6073de1da64d6 Mon Sep 17 00:00:00 2001 From: amyangfei Date: Tue, 8 Jun 2021 10:31:11 +0800 Subject: [PATCH] fix unit test --- cdc/kv/token_region_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cdc/kv/token_region_test.go b/cdc/kv/token_region_test.go index 7bd81fe8f38..b26d9b02cd5 100644 --- a/cdc/kv/token_region_test.go +++ b/cdc/kv/token_region_test.go @@ -138,7 +138,7 @@ func (s *tokenRegionSuite) TestRouterWithMultiStores(c *check.C) { r := NewSizedRegionRouter(context.Background(), limit) for _, store := range stores { - for j := 0; j < limit*5; j++ { + for j := 0; j < limit*2; j++ { r.AddRegion(singleRegionInfo{ts: uint64(j), rpcCtx: &tikv.RPCContext{Addr: store}}) } } @@ -159,7 +159,7 @@ func (s *tokenRegionSuite) TestRouterWithMultiStores(c *check.C) { r.Acquire(store) atomic.AddUint64(&received, 1) r.Release(store) - if atomic.LoadUint64(&received) == uint64(limit*10) { + if atomic.LoadUint64(&received) == uint64(limit*4*storeN) { cancel() } } @@ -168,7 +168,7 @@ func (s *tokenRegionSuite) TestRouterWithMultiStores(c *check.C) { } for _, store := range stores { - for i := 0; i < limit*5; i++ { + for i := 0; i < limit*2; i++ { r.AddRegion(singleRegionInfo{ts: uint64(i), rpcCtx: &tikv.RPCContext{Addr: store}}) } }