mirror of
https://github.com/lightninglabs/pool.git
synced 2026-08-13 12:33:04 +02:00
24d2f6127e
In this commit, we fix an existing issue that would cause sidecar negotiation to halt if either the server restarted, or if the main connection was torn down. To address this, we add a simple abstraction that implements stateful exponential back-off that'll wait for a period of time before trying to read from the mailbox again.
42 lines
1.1 KiB
Go
42 lines
1.1 KiB
Go
package pool
|
|
|
|
import "time"
|
|
|
|
const (
|
|
// maxBackOff is the maximum amount of that that we'll wait to retry to
|
|
// w/e operation we're wanting to back off.
|
|
maxBackOff = time.Minute
|
|
|
|
// minBackOff is the smallest amount of time we'll wait until we retry
|
|
// the given operation.
|
|
minBackOff = time.Millisecond * 100
|
|
)
|
|
|
|
// backOffer implements a simple exponential back off scheme using a channel
|
|
// and a timer.
|
|
type backOffer struct {
|
|
backOffPeriod time.Duration
|
|
}
|
|
|
|
// backOff returns a channel that should be used to wait for the current back
|
|
// off period before doubling the period for the subsequent call to this
|
|
// method.
|
|
func (b *backOffer) backOff(logID string) <-chan time.Time {
|
|
// The first time around, this'll multiply by zero meaning there's no
|
|
// back off, which'll trigger the base case below to use the min back
|
|
// off.
|
|
b.backOffPeriod *= 2
|
|
|
|
if b.backOffPeriod == 0 {
|
|
b.backOffPeriod = minBackOff
|
|
}
|
|
|
|
if b.backOffPeriod > maxBackOff {
|
|
b.backOffPeriod = maxBackOff
|
|
}
|
|
|
|
log.Debugf("Backing off for period of time %v for %v", b.backOffPeriod,
|
|
logID)
|
|
|
|
return time.After(b.backOffPeriod)
|
|
}
|