status-im/consul
2
0
Fork 0
mirror of https://github.com/status-im/consul.git synced 2025-02-19 17:14:37 +00:00
Code Issues Projects Releases Wiki Activity

agent: log differnt shutdown stages

Browse Source 
Log the different code paths during shutdown.
This commit is contained in:
Frank Schroeder 2017-06-07 13:11:04 +02:00
parent 9224daf585
commit 46c055d57b
No known key found for this signature in database
GPG Key ID: 4D65C6EAEC87DECD
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
command/agent/command.go
View File

@ -800,6 +800,7 @@ func (cmd *Command) Run(args []string) int {
graceful := (sig == os.Interrupt && !(*config.SkipLeaveOnInt)) || (sig == syscall.SIGTERM && (*config.LeaveOnTerm)) graceful := (sig == os.Interrupt && !(*config.SkipLeaveOnInt)) || (sig == syscall.SIGTERM && (*config.LeaveOnTerm))
if !graceful { if !graceful {
cmd.UI.Output("Graceful shutdown disabled. Exiting")
return 1 return 1
} }
@ -807,7 +808,7 @@ func (cmd *Command) Run(args []string) int {
gracefulCh := make(chan struct{}) gracefulCh := make(chan struct{})
go func() { go func() {
if err := agent.Leave(); err != nil { if err := agent.Leave(); err != nil {
cmd.UI.Error(fmt.Sprintf("Error: %s", err)) cmd.UI.Error(fmt.Sprintf("Error on leave: %s", err))
return return
} }
close(gracefulCh) close(gracefulCh)
@ -816,10 +817,13 @@ func (cmd *Command) Run(args []string) int {
gracefulTimeout := 5 * time.Second gracefulTimeout := 5 * time.Second
select { select {
case <-signalCh: case <-signalCh:
cmd.UI.Output(fmt.Sprintf("Caught second signal: %v. Exiting", sig))
return 1 return 1
case <-time.After(gracefulTimeout): case <-time.After(gracefulTimeout):
cmd.UI.Output("Timeout on graceful leave. Exiting")
return 1 return 1
case <-gracefulCh: case <-gracefulCh:
cmd.UI.Output("Graceful exit completed")
return 0 return 0
} }
} }