diff options
author | Aliaksandr Valialkin <valyala@gmail.com> | 2015-10-23 13:26:15 +0300 |
---|---|---|
committer | Aliaksandr Valialkin <valyala@gmail.com> | 2015-10-23 13:26:15 +0300 |
commit | 7874b9245a1bb3a444b5bf00cc9be6656384637c (patch) | |
tree | 2705d5b35b0c3ed5bcc063e98ad6a485f5070479 /server_timing_test.go | |
parent | microoptimization: convert io.ReadWriter to remoteAddrer only before use (diff) | |
download | fasthttp-7874b9245a1bb3a444b5bf00cc9be6656384637c.tar.gz fasthttp-7874b9245a1bb3a444b5bf00cc9be6656384637c.tar.bz2 fasthttp-7874b9245a1bb3a444b5bf00cc9be6656384637c.zip |
Properly implement request read timeout via SetReadDeadline(). Implement response write timeout
Diffstat (limited to 'server_timing_test.go')
-rw-r--r-- | server_timing_test.go | 40 |
1 files changed, 8 insertions, 32 deletions
diff --git a/server_timing_test.go b/server_timing_test.go index af8fb09..a48db45 100644 --- a/server_timing_test.go +++ b/server_timing_test.go @@ -78,22 +78,6 @@ func BenchmarkNetHTTPServerPost10000ReqPerConn(b *testing.B) { benchmarkNetHTTPServerPost(b, 10000) } -func BenchmarkServerGetRequestReadTimeout1ReqPerConn(b *testing.B) { - benchmarkServerGetRequestReadTimeout(b, 1) -} - -func BenchmarkServerGetRequestReadTimeout2ReqPerConn(b *testing.B) { - benchmarkServerGetRequestReadTimeout(b, 2) -} - -func BenchmarkServerGetRequestReadTimeout10ReqPerConn(b *testing.B) { - benchmarkServerGetRequestReadTimeout(b, 10) -} - -func BenchmarkServerGetRequestReadTimeout10000ReqPerConn(b *testing.B) { - benchmarkServerGetRequestReadTimeout(b, 10000) -} - func BenchmarkServerTimeoutError(b *testing.B) { requestsPerConn := 10 ch := make(chan struct{}, b.N) @@ -153,6 +137,14 @@ func (c *fakeServerConn) Close() error { return nil } +func (c *fakeServerConn) SetReadDeadline(t time.Time) error { + return nil +} + +func (c *fakeServerConn) SetWriteDeadline(t time.Time) error { + return nil +} + type fakeListener struct { addr net.TCPAddr stop chan struct{} @@ -280,22 +272,6 @@ func benchmarkNetHTTPServerPost(b *testing.B, requestsPerConn int) { verifyRequestsServed(b, requestsSent, ch) } -func benchmarkServerGetRequestReadTimeout(b *testing.B, requestsPerConn int) { - ch := make(chan struct{}, b.N) - s := &Server{ - Handler: func(ctx *RequestCtx) { - if !ctx.Request.Header.IsMethodGet() { - b.Fatalf("Unexpected request method: %s", ctx.Request.Header.Method) - } - ctx.Success("text/plain", fakeResponse) - registerServedRequest(b, ch) - }, - RequestReadTimeout: 5 * time.Second, - } - requestsSent := benchmarkServer(b, &testServer{s}, requestsPerConn, getRequest) - verifyRequestsServed(b, requestsSent, ch) -} - func registerServedRequest(b *testing.B, ch chan<- struct{}) { select { case ch <- struct{}{}: |