qbit/go
1
0
Fork 0
mirror of https://github.com/golang/go synced 2024-11-13 17:20:22 -07:00
Code Releases Activity

net/http: don't spin on temporary accept failure

Browse Source 
R=golang-dev, rsc
CC=golang-dev
https://golang.org/cl/5658049
This commit is contained in:
Brad Fitzpatrick 2012-02-14 15:04:29 +11:00
parent 11f6f7afd6
commit 913abfee3b
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/pkg/net/http/server.go
View File

@ -1007,15 +1007,26 @@ func (srv *Server) ListenAndServe() error {
// then call srv.Handler to reply to them. // then call srv.Handler to reply to them.
func (srv *Server) Serve(l net.Listener) error { func (srv *Server) Serve(l net.Listener) error {
defer l.Close() defer l.Close()
var tempDelay time.Duration // how long to sleep on accept failure
for { for {
rw, e := l.Accept() rw, e := l.Accept()
if e != nil { if e != nil {
if ne, ok := e.(net.Error); ok && ne.Temporary() { if ne, ok := e.(net.Error); ok && ne.Temporary() {
log.Printf("http: Accept error: %v", e) if tempDelay == 0 {
tempDelay = 5 * time.Millisecond
} else {
tempDelay *= 2
}
if max := 1 * time.Second; tempDelay > max {
tempDelay = max
}
log.Printf("http: Accept error: %v; retrying in %v", e, tempDelay)
time.Sleep(tempDelay)
continue continue
} }
return e return e
} }
tempDelay = 0
if srv.ReadTimeout != 0 { if srv.ReadTimeout != 0 {
rw.SetReadDeadline(time.Now().Add(srv.ReadTimeout)) rw.SetReadDeadline(time.Now().Add(srv.ReadTimeout))
} }