kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-01 16:05:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

style: add comments

Browse Source
This commit is contained in:
Juanadelacuesta
2025-04-23 15:47:37 +02:00
parent c5c4272aee
commit b375974bc3
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
command/agent/command.go
View File

@@ -979,6 +979,7 @@ func (c *Command) handleRetryJoin(config *Config) error {
}
func (c *Command) terminate(signalCh chan os.Signal, sdSock io.Writer) int {
// Bail fast if not doing a graceful leave
if !c.agent.GetConfig().LeaveOnInt {
return 1
}
@@ -986,6 +987,8 @@ func (c *Command) terminate(signalCh chan os.Signal, sdSock io.Writer) int {
// Attempt a graceful leave
sdNotify(sdSock, sdStopping)
gracefulCh := make(chan struct{})
defer close(gracefulCh)
c.Ui.Output("Gracefully shutting down agent...")
go func() {
if err := c.agent.Leave(); err != nil {
@@ -1002,13 +1005,16 @@ func (c *Command) terminate(signalCh chan os.Signal, sdSock io.Writer) int {
case <-time.After(gracefulTimeout):
return 1
case <-gracefulCh:
return 0
}
return 0
}
// handleSignals blocks until we get an exit-causing signal
func (c *Command) handleSignals() int {
signalCh := make(chan os.Signal, 4)
defer close(signalCh)
signal.Notify(signalCh, os.Interrupt, syscall.SIGTERM, syscall.SIGHUP, syscall.SIGPIPE)
// Signal readiness only once signal handlers are setup