mirror of https://github.com/status-im/consul.git
fix formatting
This commit is contained in:
parent
a2e6ca1226
commit
1ca5fa9769
|
@ -519,7 +519,7 @@ type CheckH2PING struct {
|
|||
stop bool
|
||||
stopCh chan struct{}
|
||||
stopLock sync.Mutex
|
||||
stopWg sync.WaitGroup
|
||||
stopWg sync.WaitGroup
|
||||
}
|
||||
|
||||
func (c *CheckH2PING) check() {
|
||||
|
@ -560,11 +560,11 @@ func (c *CheckH2PING) Stop() {
|
|||
c.stop = true
|
||||
close(c.stopCh)
|
||||
}
|
||||
c.stopWg.Wait()
|
||||
c.stopWg.Wait()
|
||||
}
|
||||
|
||||
func (c *CheckH2PING) run() {
|
||||
defer c.stopWg.Done()
|
||||
defer c.stopWg.Done()
|
||||
// Get the randomized initial pause time
|
||||
initialPauseTime := lib.RandomStagger(c.Interval)
|
||||
next := time.After(initialPauseTime)
|
||||
|
@ -587,7 +587,7 @@ func (c *CheckH2PING) Start() {
|
|||
}
|
||||
c.stop = false
|
||||
c.stopCh = make(chan struct{})
|
||||
c.stopWg.Add(1)
|
||||
c.stopWg.Add(1)
|
||||
go c.run()
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue