diff options
| author |  Aliaksandr Valialkin <valyala@gmail.com>
| 2015-12-30 14:30:37 +0200 |
|---|---|---|
| committer | Aliaksandr Valialkin <valyala@gmail.com>
| 2015-12-30 14:30:37 +0200 |
| commit | f85708c120ac3c0a2e755acdd28ea24518c503a9 (patch) | |
| tree | 59459cce44484d6ed5c3b45823d74cf6ccd6843f /client_timing_test.go | |
| parent | code cleanup: removed unused pendingFiles member from fsHandler (diff) | |
| download | fasthttp-f85708c120ac3c0a2e755acdd28ea24518c503a9.tar.gz fasthttp-f85708c120ac3c0a2e755acdd28ea24518c503a9.tar.bz2 fasthttp-f85708c120ac3c0a2e755acdd28ea24518c503a9.zip | |
Client-Server end-to-end benchmarks' tuning
Diffstat (limited to 'client_timing_test.go')
| -rw-r--r-- | client_timing_test.go | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/client_timing_test.go b/client_timing_test.go index f8ee3d1..a378651 100644 --- a/client_timing_test.go +++ b/client_timing_test.go @@ -6,6 +6,7 @@ import ( "io/ioutil" "net" "net/http" + "runtime" "strings" "sync" "sync/atomic" @@ -183,10 +184,6 @@ func BenchmarkClientGetEndToEnd100(b *testing.B) { benchmarkClientGetEndToEnd(b, 100) } -func BenchmarkClientGetEndToEnd1000(b *testing.B) { - benchmarkClientGetEndToEnd(b, 1000) -} - func benchmarkClientGetEndToEnd(b *testing.B, parallelism int) { addr := "127.0.0.1:8543" @@ -203,13 +200,17 @@ func benchmarkClientGetEndToEnd(b *testing.B, parallelism int) { close(ch) }() + c := &Client{ + MaxConnsPerHost: runtime.GOMAXPROCS(-1) * parallelism, + } + requestURI := "/foo/bar?baz=123" url := "http://" + addr + requestURI b.SetParallelism(parallelism) b.RunParallel(func(pb *testing.PB) { var buf []byte for pb.Next() { - statusCode, body, err := Get(buf, url) + statusCode, body, err := c.Get(buf, url) if err != nil { b.Fatalf("unexpected error: %s", err) } @@ -243,10 +244,6 @@ func BenchmarkNetHTTPClientGetEndToEnd100(b *testing.B) { benchmarkNetHTTPClientGetEndToEnd(b, 100) } -func BenchmarkNetHTTPClientGetEndToEnd1000(b *testing.B) { - benchmarkNetHTTPClientGetEndToEnd(b, 1000) -} - func benchmarkNetHTTPClientGetEndToEnd(b *testing.B, parallelism int) { addr := "127.0.0.1:8542" |