diff --git a/Makefile b/Makefile index a10eaef06b208..9200683f459f8 100644 --- a/Makefile +++ b/Makefile @@ -436,8 +436,8 @@ bazel_test: failpoint-enable bazel_ci_prepare bazel_coverage_test: failpoint-enable bazel_ci_prepare bazel --output_user_root=/home/jenkins/.tidb/tmp coverage --config=ci --@io_bazel_rules_go//go/config:cover_format=go_cover \ - -- //... -//cmd/... -//tests/graceshutdown/... \ - -//tests/globalkilltest/... -//tests/readonlytest/... -//br/pkg/task:task_test + -- //... -//cmd/... -//tests/... \ + -//br/pkg/task:task_test bazel_build: bazel_ci_prepare mkdir -p bin diff --git a/store/copr/coprocessor.go b/store/copr/coprocessor.go index c35d1793785df..161da48b39a1c 100644 --- a/store/copr/coprocessor.go +++ b/store/copr/coprocessor.go @@ -132,21 +132,7 @@ func (c *CopClient) Send(ctx context.Context, req *kv.Request, variables interfa it.sendRate = util.NewRateLimit(2 * it.concurrency) it.respChan = nil } else { - capacity := it.concurrency - if enabledRateLimitAction { - // The count of cached response in memory is controlled by the capacity of the it.sendRate, not capacity of the respChan. - // As the worker will send finCopResponse after each task being handled, we make the capacity of the respCh equals to - // 2*it.concurrency to avoid deadlock in the unit test caused by the `MustExec` or `Exec` - capacity = it.concurrency * 2 - } - // in paging request, a request will be returned in multi batches, - // enlarge the channel size to avoid the request blocked by buffer full. - if req.Paging { - if capacity < 2048 { - capacity = 2048 - } - } - it.respChan = make(chan *copResponse, capacity) + it.respChan = make(chan *copResponse) it.sendRate = util.NewRateLimit(it.concurrency) } it.actionOnExceed = newRateLimitAction(uint(it.sendRate.GetCapacity()))