mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-03 17:30:00 +00:00
Fix client-go request benchmark
This commit is contained in:
parent
f20876908f
commit
85763127c0
@ -1440,15 +1440,20 @@ func BenchmarkCheckRetryClosesBody(b *testing.B) {
|
|||||||
defer testServer.Close()
|
defer testServer.Close()
|
||||||
|
|
||||||
c := testRESTClient(b, testServer)
|
c := testRESTClient(b, testServer)
|
||||||
r := c.Verb("POST").
|
|
||||||
Prefix("foo", "bar").
|
|
||||||
Suffix("baz").
|
|
||||||
Timeout(time.Second).
|
|
||||||
Body([]byte(strings.Repeat("abcd", 1000)))
|
|
||||||
|
|
||||||
|
requests := make([]*Request, 0, b.N)
|
||||||
for i := 0; i < b.N; i++ {
|
for i := 0; i < b.N; i++ {
|
||||||
if _, err := r.DoRaw(); err != nil {
|
requests = append(requests, c.Verb("POST").
|
||||||
b.Fatalf("Unexpected error: %v %#v", err, err)
|
Prefix("foo", "bar").
|
||||||
|
Suffix("baz").
|
||||||
|
Timeout(time.Second).
|
||||||
|
Body([]byte(strings.Repeat("abcd", 1000))))
|
||||||
|
}
|
||||||
|
|
||||||
|
b.ResetTimer()
|
||||||
|
for i := 0; i < b.N; i++ {
|
||||||
|
if _, err := requests[i].DoRaw(); err != nil {
|
||||||
|
b.Fatalf("Unexpected error (%d/%d): %v", i, b.N, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user