change interval

Signed-off-by: lhy1024 <[email protected]>
tikv · Mar 19, 2024 · bbb2470 · bbb2470
1 parent 2fac014
commit bbb2470
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/pkg/utils/etcdutil/etcdutil.go b/pkg/utils/etcdutil/etcdutil.go
@@ -165,7 +165,7 @@ func EtcdKVGet(c *clientv3.Client, key string, opts ...clientv3.OpOption) (*clie
 func IsHealthy(ctx context.Context, client *clientv3.Client) bool {
 	timeout := DefaultRequestTimeout
 	failpoint.Inject("fastTick", func() {
-		timeout = 10 * time.Millisecond
+		timeout = 20 * time.Millisecond
 	})
 	ctx, cancel := context.WithTimeout(clientv3.WithRequireLeader(ctx), timeout)
 	defer cancel()
@@ -265,7 +265,7 @@ func CreateEtcdClient(tlsConfig *tls.Config, acURLs []url.URL, sourceOpt ...stri
 
 	tickerInterval := defaultDialKeepAliveTime
 	failpoint.Inject("fastTick", func() {
-		tickerInterval = 10 * time.Millisecond
+		tickerInterval = 20 * time.Millisecond
 	})
 	failpoint.Inject("closeTick", func() {
 		failpoint.Return(client, err)

diff --git a/pkg/utils/etcdutil/etcdutil_test.go b/pkg/utils/etcdutil/etcdutil_test.go
@@ -661,7 +661,7 @@ func (suite *loopWatcherTestSuite) TestWatcherBreak() {
 		func([]*clientv3.Event) error { return nil },
 		false, /* withPrefix */
 	)
-	watcher.watchChangeRetryInterval = 100 * time.Millisecond
+	watcher.watchChangeRetryInterval = 20 * time.Millisecond
 	watcher.StartWatchLoop()
 	err := watcher.WaitLoad()
 	re.NoError(err)