diff options
| author |  Aliaksandr Valialkin <valyala@gmail.com>
| 2015-11-23 13:01:36 +0200 |
|---|---|---|
| committer | Aliaksandr Valialkin <valyala@gmail.com>
| 2015-11-23 13:01:36 +0200 |
| commit | bb38369834d1cf873a0be2c9a1f0a515b2d2b13c (patch) | |
| tree | 591300e3dfeb39ef18c83678b721f5e0ee2bb8a4 /workerpool.go | |
| parent | Suppress too chatty 'broken pipe' errors when serving clients, which unexpect... (diff) | |
| download | fasthttp-bb38369834d1cf873a0be2c9a1f0a515b2d2b13c.tar.gz fasthttp-bb38369834d1cf873a0be2c9a1f0a515b2d2b13c.tar.bz2 fasthttp-bb38369834d1cf873a0be2c9a1f0a515b2d2b13c.zip | |
Suppress too chatty 'reset by peer' errors when serving clients, which unexpectedly close connections
Diffstat (limited to 'workerpool.go')
| -rw-r--r-- | workerpool.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/workerpool.go b/workerpool.go index 727793b..0fc44fb 100644 --- a/workerpool.go +++ b/workerpool.go @@ -162,8 +162,11 @@ func (wp *workerPool) workerFunc(ch *workerChan) { if c == nil { break } - if err = wp.WorkerFunc(c); err != nil && !strings.Contains(err.Error(), "broken pipe") { - wp.Logger.Printf("error when serving connection %q<->%q: %s", c.LocalAddr(), c.RemoteAddr(), err) + if err = wp.WorkerFunc(c); err != nil { + errStr := err.Error() + if !strings.Contains(errStr, "broken pipe") && !strings.Contains(errStr, "reset by peer") { + wp.Logger.Printf("error when serving connection %q<->%q: %s", c.LocalAddr(), c.RemoteAddr(), err) + } } c.Close() c = nil |