diff --git a/server/server.go b/server/server.go index d5a68cfba..1f82e0759 100644 --- a/server/server.go +++ b/server/server.go @@ -164,6 +164,22 @@ func (s serverEntryPoint) Shutdown(ctx context.Context) { wg.Wait() } +// tcpKeepAliveListener sets TCP keep-alive timeouts on accepted +// connections. +type tcpKeepAliveListener struct { + *net.TCPListener +} + +func (ln tcpKeepAliveListener) Accept() (net.Conn, error) { + tc, err := ln.AcceptTCP() + if err != nil { + return nil, err + } + tc.SetKeepAlive(true) + tc.SetKeepAlivePeriod(3 * time.Minute) + return tc, nil +} + // NewServer returns an initialized Server. func NewServer(globalConfiguration configuration.GlobalConfiguration, provider provider.Provider, entrypoints map[string]EntryPoint) *Server { server := &Server{} @@ -560,6 +576,8 @@ func (s *Server) prepareServer(entryPointName string, entryPoint *configuration. return nil, nil, fmt.Errorf("error opening listener: %v", err) } + listener = tcpKeepAliveListener{listener.(*net.TCPListener)} + if entryPoint.ProxyProtocol != nil { listener, err = buildProxyProtocolListener(entryPoint, listener) if err != nil {