mirror of https://github.com/curusarn/resh
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
65 lines
1.5 KiB
65 lines
1.5 KiB
package signalhandler
|
|
|
|
import (
|
|
"context"
|
|
"log"
|
|
"net/http"
|
|
"os"
|
|
"os/signal"
|
|
"strconv"
|
|
"syscall"
|
|
"time"
|
|
)
|
|
|
|
func sendSignals(sig os.Signal, subscribers []chan os.Signal, done chan string) {
|
|
for _, sub := range subscribers {
|
|
sub <- sig
|
|
}
|
|
chanCount := len(subscribers)
|
|
start := time.Now()
|
|
delay := time.Millisecond * 100
|
|
timeout := time.Millisecond * 2000
|
|
|
|
for {
|
|
select {
|
|
case _ = <-done:
|
|
chanCount--
|
|
if chanCount == 0 {
|
|
log.Println("signalhandler: All components shut down successfully")
|
|
return
|
|
}
|
|
default:
|
|
time.Sleep(delay)
|
|
}
|
|
if time.Since(start) > timeout {
|
|
log.Println("signalhandler: Timouted while waiting for proper shutdown - " + strconv.Itoa(chanCount) + " boxes are up after " + timeout.String())
|
|
return
|
|
}
|
|
}
|
|
}
|
|
|
|
// Run catches and handles signals
|
|
func Run(subscribers []chan os.Signal, done chan string, server *http.Server) {
|
|
signals := make(chan os.Signal, 1)
|
|
|
|
signal.Notify(signals, syscall.SIGINT, syscall.SIGTERM, syscall.SIGSTOP, syscall.SIGQUIT)
|
|
|
|
var sig os.Signal
|
|
for {
|
|
sig := <-signals
|
|
log.Println("signalhandler: Got signal " + sig.String())
|
|
if sig == syscall.SIGTERM {
|
|
// Shutdown daemon on SIGTERM
|
|
break
|
|
}
|
|
log.Printf("signalhandler: Ignoring signal %s. Send SIGTERM to trigger shutdown.\n", sig.String())
|
|
}
|
|
|
|
log.Println("signalhandler: Sending shutdown signals to components")
|
|
sendSignals(sig, subscribers, done)
|
|
|
|
log.Println("signalhandler: Shutting down the server")
|
|
if err := server.Shutdown(context.Background()); err != nil {
|
|
log.Printf("HTTP server Shutdown: %v", err)
|
|
}
|
|
}
|
|
|