sigpipe signal processing
This commit is contained in:
commit
b6594afdda
|
@ -1,2 +1,4 @@
|
||||||
|
.idea
|
||||||
|
.vscode
|
||||||
/categraf*
|
/categraf*
|
||||||
*.log
|
*.log
|
||||||
|
|
5
main.go
5
main.go
|
@ -55,7 +55,7 @@ func main() {
|
||||||
|
|
||||||
func handleSignal(ag *agent.Agent) {
|
func handleSignal(ag *agent.Agent) {
|
||||||
sc := make(chan os.Signal, 1)
|
sc := make(chan os.Signal, 1)
|
||||||
signal.Notify(sc, syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT)
|
signal.Notify(sc, syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT, syscall.SIGPIPE)
|
||||||
|
|
||||||
EXIT:
|
EXIT:
|
||||||
for {
|
for {
|
||||||
|
@ -66,6 +66,9 @@ EXIT:
|
||||||
break EXIT
|
break EXIT
|
||||||
case syscall.SIGHUP:
|
case syscall.SIGHUP:
|
||||||
ag.Reload()
|
ag.Reload()
|
||||||
|
case syscall.SIGPIPE:
|
||||||
|
// https://pkg.go.dev/os/signal#hdr-SIGPIPE
|
||||||
|
// do nothing
|
||||||
default:
|
default:
|
||||||
break EXIT
|
break EXIT
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue