Change server receiver name.
This commit is contained in:
parent
f6181ef3e2
commit
011b748a55
4 changed files with 208 additions and 208 deletions
|
@ -10,19 +10,19 @@ import (
|
|||
"github.com/containous/traefik/log"
|
||||
)
|
||||
|
||||
func (server *Server) configureSignals() {
|
||||
signal.Notify(server.signals, syscall.SIGINT, syscall.SIGTERM, syscall.SIGUSR1)
|
||||
func (s *Server) configureSignals() {
|
||||
signal.Notify(s.signals, syscall.SIGINT, syscall.SIGTERM, syscall.SIGUSR1)
|
||||
}
|
||||
|
||||
func (server *Server) listenSignals() {
|
||||
func (s *Server) listenSignals() {
|
||||
for {
|
||||
sig := <-server.signals
|
||||
sig := <-s.signals
|
||||
switch sig {
|
||||
case syscall.SIGUSR1:
|
||||
log.Infof("Closing and re-opening log files for rotation: %+v", sig)
|
||||
|
||||
if server.accessLoggerMiddleware != nil {
|
||||
if err := server.accessLoggerMiddleware.Rotate(); err != nil {
|
||||
if s.accessLoggerMiddleware != nil {
|
||||
if err := s.accessLoggerMiddleware.Rotate(); err != nil {
|
||||
log.Errorf("Error rotating access log: %s", err)
|
||||
}
|
||||
}
|
||||
|
@ -32,13 +32,13 @@ func (server *Server) listenSignals() {
|
|||
}
|
||||
default:
|
||||
log.Infof("I have to go... %+v", sig)
|
||||
reqAcceptGraceTimeOut := time.Duration(server.globalConfiguration.LifeCycle.RequestAcceptGraceTimeout)
|
||||
reqAcceptGraceTimeOut := time.Duration(s.globalConfiguration.LifeCycle.RequestAcceptGraceTimeout)
|
||||
if reqAcceptGraceTimeOut > 0 {
|
||||
log.Infof("Waiting %s for incoming requests to cease", reqAcceptGraceTimeOut)
|
||||
time.Sleep(reqAcceptGraceTimeOut)
|
||||
}
|
||||
log.Info("Stopping server gracefully")
|
||||
server.Stop()
|
||||
s.Stop()
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue