lordwelch/router7
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

dhcp6: port dhcp4 backoff logic

Browse Source
This commit is contained in:
Michael Stapelberg 2020-07-02 22:07:26 +02:00
parent ae8cfee616
commit f86e20be53
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
cmd/dhcp6/dhcp6.go
View File

@ -27,6 +27,7 @@ import (
"time" "time"
"github.com/google/renameio" "github.com/google/renameio"
"github.com/jpillora/backoff"
"github.com/rtr7/router7/internal/dhcp6" "github.com/rtr7/router7/internal/dhcp6"
"github.com/rtr7/router7/internal/notify" "github.com/rtr7/router7/internal/notify"
"github.com/rtr7/router7/internal/teelogger" "github.com/rtr7/router7/internal/teelogger"
@ -54,12 +55,21 @@ func logic() error {
} }
usr2 := make(chan os.Signal, 1) usr2 := make(chan os.Signal, 1)
signal.Notify(usr2, syscall.SIGUSR2) signal.Notify(usr2, syscall.SIGUSR2)
backoff := backoff.Backoff{
Factor: 2,
Jitter: true,
Min: 10 * time.Second,
Max: 1 * time.Minute,
}
for c.ObtainOrRenew() { for c.ObtainOrRenew() {
if err := c.Err(); err != nil { if err := c.Err(); err != nil {
log.Printf("Temporary error: %v", err) dur := backoff.Duration()
time.Sleep(10 * time.Second) log.Printf("Temporary error: %v (waiting %v)", err, dur)
time.Sleep(dur)
continue continue
} }
backoff.Reset()
log.Printf("lease: %+v", c.Config()) log.Printf("lease: %+v", c.Config())
b, err := json.Marshal(c.Config()) b, err := json.Marshal(c.Config())
if err != nil { if err != nil {