apiserver: Update genericapiserver to panic on listener error

Previously runServer would try to listen again if a listener error
occurred.  This commit changes the response to a panic to allow a
process manager (systemd/kubelet/etc) to react to the failure.
pull/6/head
Maru Newby 2017-02-28 08:46:12 -08:00
parent c9b9b38ced
commit 30fb3be4d2
1 changed files with 13 additions and 38 deletions

View File

@ -23,7 +23,6 @@ import (
"net"
"net/http"
"strings"
"sync"
"time"
utilruntime "k8s.io/apimachinery/pkg/util/runtime"
@ -100,7 +99,6 @@ func RunServer(server *http.Server, network string, stopCh <-chan struct{}) (int
network = "tcp"
}
// first listen is synchronous (fail early!)
ln, err := net.Listen(network, server.Addr)
if err != nil {
return 0, fmt.Errorf("failed to listen on %v: %v", server.Addr, err)
@ -113,18 +111,15 @@ func RunServer(server *http.Server, network string, stopCh <-chan struct{}) (int
return 0, fmt.Errorf("invalid listen address: %q", ln.Addr().String())
}
lock := sync.Mutex{} // to avoid we close an old listener during a listen retry
// Stop the server by closing the listener
go func() {
<-stopCh
lock.Lock()
defer lock.Unlock()
ln.Close()
}()
go func() {
defer utilruntime.HandleCrash()
for {
var listener net.Listener
listener = tcpKeepAliveListener{ln.(*net.TCPListener)}
if server.TLSConfig != nil {
@ -132,33 +127,13 @@ func RunServer(server *http.Server, network string, stopCh <-chan struct{}) (int
}
err := server.Serve(listener)
glog.Errorf("Error serving %v (%v); will try again.", server.Addr, err)
// listen again
func() {
lock.Lock()
defer lock.Unlock()
for {
time.Sleep(15 * time.Second)
ln, err = net.Listen(network, server.Addr)
if err == nil {
return
}
msg := fmt.Sprintf("Stopped listening on %s", tcpAddr.String())
select {
case <-stopCh:
return
glog.Info(msg)
default:
}
glog.Errorf("Error listening on %v (%v); will try again.", server.Addr, err)
}
}()
select {
case <-stopCh:
return
default:
}
panic(fmt.Sprintf("%s due to error: %v", msg, err))
}
}()