-
Notifications
You must be signed in to change notification settings - Fork 10
/
signal.go
43 lines (36 loc) · 1.23 KB
/
signal.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
// Copyright (c) 2015-2023 The Decred developers
// Use of this source code is governed by an ISC
// license that can be found in the LICENSE file.
package main
import (
"context"
"log"
"os"
"os/signal"
)
// interruptSignals defines the default signals to catch in order to do a proper
// shutdown. This may be modified during init depending on the platform.
var interruptSignals = []os.Signal{os.Interrupt}
// shutdownListener returns a context whose done channel will be closed when OS
// signals such as SIGINT (Ctrl+C) are received.
func shutdownListener() (context.Context, context.CancelFunc) {
ctx, cancel := context.WithCancel(context.Background())
go func() {
interruptChannel := make(chan os.Signal, 1)
signal.Notify(interruptChannel, interruptSignals...)
// Listen for initial shutdown signal and cancel the context.
select {
case sig := <-interruptChannel:
log.Printf("Received signal (%s). Shutting down...", sig)
cancel()
case <-ctx.Done():
}
// Listen for repeated signals and display a message so the user knows
// the shutdown is in progress and the process is not hung.
for {
sig := <-interruptChannel
log.Printf("Received signal (%s). Already shutting down...", sig)
}
}()
return ctx, cancel
}