diff --git a/runner/runner.go b/runner/runner.go index d8e93d7..cb4e944 100644 --- 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 index 60b51b3..e4e57ba 100644 --- 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)