mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-12-29 23:30:04 +01:00
4cd173bbaa
Previously VictoriaMetrics apps could stop responding to SIGINT and SIGTERM signals if they hang for some reason in graceful shutdown procedure.
50 lines
1.2 KiB
Go
50 lines
1.2 KiB
Go
//go:build !windows
|
|
// +build !windows
|
|
|
|
package procutil
|
|
|
|
import (
|
|
"os"
|
|
"os/signal"
|
|
"syscall"
|
|
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/lib/logger"
|
|
)
|
|
|
|
// WaitForSigterm waits for either SIGTERM or SIGINT
|
|
//
|
|
// Returns the caught signal.
|
|
//
|
|
// It also prevent from program termination on SIGHUP signal,
|
|
// since this signal is frequently used for config reloading.
|
|
func WaitForSigterm() os.Signal {
|
|
ch := make(chan os.Signal, 1)
|
|
signal.Notify(ch, os.Interrupt, syscall.SIGTERM, syscall.SIGHUP)
|
|
for {
|
|
sig := <-ch
|
|
if sig == syscall.SIGHUP {
|
|
// Prevent from the program stop on SIGHUP
|
|
continue
|
|
}
|
|
// Stop listening for SIGINT and SIGTERM signals,
|
|
// so the app could be interrupted by sending these signals again
|
|
// in the case if the caller doesn't finish the app gracefully.
|
|
signal.Stop(ch)
|
|
return sig
|
|
}
|
|
}
|
|
|
|
// SelfSIGHUP sends SIGHUP signal to the current process.
|
|
func SelfSIGHUP() {
|
|
if err := syscall.Kill(syscall.Getpid(), syscall.SIGHUP); err != nil {
|
|
logger.Panicf("FATAL: cannot send SIGHUP to itself: %s", err)
|
|
}
|
|
}
|
|
|
|
// NewSighupChan returns a channel, which is triggered on every SIGHUP.
|
|
func NewSighupChan() <-chan os.Signal {
|
|
ch := make(chan os.Signal, 1)
|
|
signal.Notify(ch, syscall.SIGHUP)
|
|
return ch
|
|
}
|