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

remote-challenge-sync-airbus: Handle interrupts

Browse Source
This commit is contained in:
nemunaire 2022-06-07 17:13:30 +02:00
parent cc1b212cca
commit d2d7b35623
1 changed files with 65 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

65
remote/challenge-sync-airbus/main.go
View File

@ -5,9 +5,11 @@ import (
"io/ioutil" "io/ioutil"
"log" "log"
"os" "os"
"os/signal"
"path" "path"
"path/filepath" "path/filepath"
"strconv" "strconv"
"syscall"
"gopkg.in/fsnotify.v1" "gopkg.in/fsnotify.v1"
) )
@ -102,10 +104,61 @@ func main() {
log.Fatal(err) log.Fatal(err)
} }
// Register SIGUSR1, SIGUSR2
interrupt1 := make(chan os.Signal, 1)
signal.Notify(interrupt1, syscall.SIGHUP)
interrupt2 := make(chan os.Signal, 1)
signal.Notify(interrupt2, syscall.SIGUSR1)
interrupt3 := make(chan os.Signal, 1)
signal.Notify(interrupt3, syscall.SIGUSR2)
c := time.NewTicker(5 * time.Second)
watchedNotify := fsnotify.Create watchedNotify := fsnotify.Create
for { for {
select { select {
case <-interrupt1:
log.Println("SIGHUP received, reloading files...")
teamsbindings, err := getTeams(filepath.Join(TeamsDir, "teams.json"))
if err != nil {
log.Println("Unable to open teams bindings file: ", err.Error())
return
}
w.Teams = teamsbindings
// save current timestamp for teams
err = saveTS(*tspath, w.LastSync)
if err != nil {
log.Fatal("Unable to save timestamp file: ", err.Error())
}
log.Println("SIGHUP treated.")
case <-interrupt2:
log.Println("SIGUSR1 received, resynching all teams")
// Iterate over teams scores
err = filepath.WalkDir(TeamsDir, w.WalkScore)
if err != nil {
log.Printf("Something goes wrong during walking")
}
// save current timestamp for teams
err = saveTS(*tspath, w.LastSync)
if err != nil {
log.Fatal("Unable to save timestamp file: ", err.Error())
}
log.Println("SIGUSR1 treated.")
case <-interrupt3:
log.Println("SIGUSR2 received, resynching all teams from teams.json")
teamsbindings, err := getTeams(filepath.Join(TeamsDir, "teams.json"))
if err != nil {
log.Println("Unable to open teams bindings file: ", err.Error())
return
}
w.Teams = teamsbindings
// FIXME
log.Println("SIGUSR2 treated.")
case ev := <-watcher.Events: case ev := <-watcher.Events:
if d, err := os.Lstat(ev.Name); err == nil && ev.Op&fsnotify.Create == fsnotify.Create && d.Mode().IsDir() && d.Mode()&os.ModeSymlink == 0 && d.Name() != ".tmp" { if d, err := os.Lstat(ev.Name); err == nil && ev.Op&fsnotify.Create == fsnotify.Create && d.Mode().IsDir() && d.Mode()&os.ModeSymlink == 0 && d.Name() != ".tmp" {
// Register new subdirectory // Register new subdirectory
@ -134,9 +187,21 @@ func main() {
} }
case err := <-watcher.Errors: case err := <-watcher.Errors:
log.Println("error:", err) log.Println("error:", err)
case <-ticker.C:
// save current timestamp for teams
err = saveTS(*tspath, w.LastSync)
if err != nil {
log.Fatal("Unable to save timestamp file: ", err.Error())
}
} }
} }
} }
// save current timestamp for teams
err = saveTS(*tspath, w.LastSync)
if err != nil {
log.Fatal("Unable to save timestamp file: ", err.Error())
}
} }
func watchsubdir(watcher *fsnotify.Watcher, pathname string) error { func watchsubdir(watcher *fsnotify.Watcher, pathname string) error {