Following up in introducing getReadTimeout()
This commit is contained in:
parent
f735bb9dcb
commit
ef07b9a69a
10
server.go
10
server.go
|
@ -356,10 +356,7 @@ func (srv *Server) serveTCP(l *net.TCPListener) error {
|
||||||
if handler == nil {
|
if handler == nil {
|
||||||
handler = DefaultServeMux
|
handler = DefaultServeMux
|
||||||
}
|
}
|
||||||
rtimeout := dnsTimeout
|
rtimeout := srv.getReadTimeout()
|
||||||
if srv.ReadTimeout != 0 {
|
|
||||||
rtimeout = srv.ReadTimeout
|
|
||||||
}
|
|
||||||
// deadline is not used here
|
// deadline is not used here
|
||||||
done := int32(0)
|
done := int32(0)
|
||||||
go func() {
|
go func() {
|
||||||
|
@ -391,10 +388,7 @@ func (srv *Server) serveUDP(l *net.UDPConn) error {
|
||||||
if handler == nil {
|
if handler == nil {
|
||||||
handler = DefaultServeMux
|
handler = DefaultServeMux
|
||||||
}
|
}
|
||||||
rtimeout := dnsTimeout
|
rtimeout := srv.getReadTimeout()
|
||||||
if srv.ReadTimeout != 0 {
|
|
||||||
rtimeout = srv.ReadTimeout
|
|
||||||
}
|
|
||||||
// deadline is not used here
|
// deadline is not used here
|
||||||
done := int32(0)
|
done := int32(0)
|
||||||
go func() {
|
go func() {
|
||||||
|
|
Loading…
Reference in New Issue