mirror/bgp-stayrtr
1
0
Fork 0
mirror of https://github.com/bgp/stayrtr.git synced 2024-05-06 15:54:54 +00:00
Code Issues

Make the refresh faster when update fails

Browse Source
This commit is contained in:
Null User
2021-10-26 15:20:17 +00:00
parent 70aef8f20c
commit 2455723c87
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cmd/stayrtr/stayrtr.go
View File

@ -377,12 +377,19 @@ func (s *state) routineUpdate(file string, interval int, slurmFile string) {
log.Debugf("Starting refresh routine (file: %v, interval: %vs, slurm: %v)", file, interval, slurmFile) log.Debugf("Starting refresh routine (file: %v, interval: %vs, slurm: %v)", file, interval, slurmFile)
signals := make(chan os.Signal, 1) signals := make(chan os.Signal, 1)
signal.Notify(signals, syscall.SIGHUP) signal.Notify(signals, syscall.SIGHUP)
lastUpdateFail := false
for { for {
delay := time.NewTimer(time.Duration(interval) * time.Second) var delay *time.Timer
if (s.lastchange.IsZero()) { if (s.lastchange.IsZero()) {
log.Warn("Initial sync not complete. Refreshing every 30 seconds") log.Warn("Initial sync not complete. Refreshing every 30 seconds")
delay = time.NewTimer(time.Duration(30) * time.Second) delay = time.NewTimer(time.Duration(30) * time.Second)
} else if (lastUpdateFail) {
log.Warn("Update failure causing 30 second refresh")
delay = time.NewTimer(time.Duration(30) * time.Second)
} else {
delay = time.NewTimer(time.Duration(interval) * time.Second)
} }
lastUpdateFail = false
select { select {
case <-delay.C: case <-delay.C:
case <-signals: case <-signals:
@ -424,6 +431,7 @@ func (s *state) routineUpdate(file string, interval int, slurmFile string) {
err := s.updateFromNewState() err := s.updateFromNewState()
if err != nil { if err != nil {
log.Errorf("Error updating from new state: %v", err) log.Errorf("Error updating from new state: %v", err)
lastUpdateFail = true
} }
} }
} }