fix: limiter bucket

cloudwego · May 28, 2024 · 3053d51 · 3053d51
1 parent b8897fa
commit 3053d51
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/runner/runner.go b/runner/runner.go
@@ -55,7 +55,7 @@ func (r *Runner) benching(onceFn RunOnce, concurrent, qps int, total int64) {
 	r.counter.Reset(total)
 	var qpsLimiter *ratelimit.Bucket
 	if qps > 0 {
-		qpsLimiter = ratelimit.NewBucketWithRate(float64(qps), 100)
+		qpsLimiter = ratelimit.NewBucketWithRate(float64(qps), int64(concurrent))
 	}
 	for i := 0; i < concurrent; i++ {
 		go func() {

diff --git a/scripts/reports/diff.py b/scripts/reports/diff.py
@@ -35,8 +35,8 @@ def diff(from_csv, to_csv):
         result.append(diff_cell(from_reader[line_num][3], line[3]))  # tps
         result.append(diff_cell(from_reader[line_num][4], line[4]))  # p99
         result.append(diff_cell(from_reader[line_num][5], line[5]))  # p999
-        result.append(diff_cell(from_reader[line_num][6], line[6]))  # Client CPU
-        result.append(diff_cell(from_reader[line_num][7], line[7]))  # Server CPU
+        result.append(diff_cell(from_reader[line_num][6], line[6]))  # Server CPU
+        result.append(diff_cell(from_reader[line_num][7], line[7]))  # Client CPU
 
         results.append(result)