KurlesHS/restic
1
0
Fork 0
forked from TrueCloudLab/restic
Code Pull requests Activity

Make all signal.Notify channels buffered

Browse source
This commit is contained in:
greatroar 2020-03-12 19:55:46 +01:00
parent c542a509f0
commit 47d4d5bf1b
4 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cmd/restic/cleanup.go
View file

@ -20,7 +20,7 @@ var cleanupHandlers struct {
var stderr = os.Stderr var stderr = os.Stderr
func init() { func init() {
cleanupHandlers.ch = make(chan os.Signal) cleanupHandlers.ch = make(chan os.Signal, 1)
go CleanupHandler(cleanupHandlers.ch) go CleanupHandler(cleanupHandlers.ch)
signal.Notify(cleanupHandlers.ch, syscall.SIGINT) signal.Notify(cleanupHandlers.ch, syscall.SIGINT)
} }

2
internal/restic/lock.go
View file

@ -253,7 +253,7 @@ var ignoreSIGHUP sync.Once
func init() { func init() {
ignoreSIGHUP.Do(func() { ignoreSIGHUP.Do(func() {
go func() { go func() {
c := make(chan os.Signal) c := make(chan os.Signal, 1)
signal.Notify(c, syscall.SIGHUP) signal.Notify(c, syscall.SIGHUP)
for s := range c { for s := range c {
debug.Log("Signal received: %v\n", s) debug.Log("Signal received: %v\n", s)

2
internal/restic/progress_unix.go
View file

@ -11,7 +11,7 @@ import (
) )
func init() { func init() {
c := make(chan os.Signal) c := make(chan os.Signal, 1)
signal.Notify(c, syscall.SIGUSR1) signal.Notify(c, syscall.SIGUSR1)
go func() { go func() {
for s := range c { for s := range c {

5
internal/restic/progress_unix_with_siginfo.go
View file

@ -11,9 +11,8 @@ import (
) )
func init() { func init() {
c := make(chan os.Signal) c := make(chan os.Signal, 1)
signal.Notify(c, syscall.SIGUSR1) signal.Notify(c, syscall.SIGINFO, syscall.SIGUSR1)
signal.Notify(c, syscall.SIGINFO)
go func() { go func() {
for s := range c { for s := range c {
debug.Log("Signal received: %v\n", s) debug.Log("Signal received: %v\n", s)