serv/mox
1
0
Fork 0
mirror of https://github.com/mjl-/mox.git synced 2024-12-26 16:33:47 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

add jitter to the retries by the queue

Browse source
This commit is contained in:
Mechiel Lukkien 2023-02-06 16:08:21 +01:00
parent e2516444b1
commit 1617b7c0d6
No known key found for this signature in database
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
queue/queue.go
View file

@ -68,6 +68,8 @@ var dial = func(ctx context.Context, timeout time.Duration, addr string, laddr n
return dialer.DialContext(ctx, "tcp", addr) return dialer.DialContext(ctx, "tcp", addr)
} }
var jitter = mox.NewRand()
var queueDB *bstore.DB var queueDB *bstore.DB
// Msg is a message in the queue. // Msg is a message in the queue.
@ -456,7 +458,7 @@ func deliver(resolver dns.Resolver, m Msg) {
// 8h, 16h (send permanent failure DSN). // 8h, 16h (send permanent failure DSN).
// ../rfc/5321:3703 // ../rfc/5321:3703
// todo future: make the back off times configurable. ../rfc/5321:3713 // todo future: make the back off times configurable. ../rfc/5321:3713
backoff := (7*60 + 30) * time.Second backoff := time.Duration(7*60+30+jitter.Intn(10)-5) * time.Second
for i := 0; i < m.Attempts; i++ { for i := 0; i < m.Attempts; i++ {
backoff *= time.Duration(2) backoff *= time.Duration(2)
} }