fic/server
1
0
Fork 0
Code Issues Pull Requests 8 Releases Wiki Activity

evdist: Add interrupts to consult state

Browse Source
This commit is contained in:
nemunaire 2024-03-16 14:47:20 +01:00
parent 0ca7aa568d
commit f32873f307
1 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
evdist/main.go
View File

@ -5,8 +5,10 @@ import (
"io/ioutil" "io/ioutil"
"log" "log"
"os" "os"
"os/signal"
"path" "path"
"strings" "strings"
"syscall"
"time" "time"
"srs.epita.fr/fic-server/settings" "srs.epita.fr/fic-server/settings"
@ -85,6 +87,12 @@ func main() {
log.Fatal(err) log.Fatal(err)
} }
// Register SIGUSR1 and SIGTERM
interrupt1 := make(chan os.Signal, 1)
signal.Notify(interrupt1, syscall.SIGUSR1)
interrupt := make(chan os.Signal, 1)
signal.Notify(interrupt, syscall.SIGTERM)
watchedNotify := fsnotify.Create watchedNotify := fsnotify.Create
treatNewFile := func(name string) { treatNewFile := func(name string) {
@ -95,8 +103,17 @@ func main() {
} }
} }
loop:
for { for {
select { select {
case <-interrupt:
break loop
case <-interrupt1:
log.Println("SIGUSR1 received, displaying queues")
log.Println("Seeing settings distlist")
lSettings.Print()
log.Println("Seeing dashboard distlist")
lDashboard.Print()
case <-lSettings.Timer.C: case <-lSettings.Timer.C:
if v := lSettings.Pop(); v != nil { if v := lSettings.Pop(); v != nil {
log.Printf("TREATING SETTINGS DIFF: %v", v) log.Printf("TREATING SETTINGS DIFF: %v", v)