luxolus
/
open-consul
2
0
Fork 0
Code Issues 1 Pull Requests Packages Releases Wiki Activity

fix formatting

This commit is contained in:
tarat44 2021-04-11 15:12:33 -04:00
parent f2ba70d559
commit 9a2e630f86
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
agent/checks/check.go
View File

@ -519,7 +519,7 @@ type CheckH2PING struct {
stop bool stop bool
stopCh chan struct{} stopCh chan struct{}
stopLock sync.Mutex stopLock sync.Mutex
stopWg sync.WaitGroup stopWg sync.WaitGroup
} }
func (c *CheckH2PING) check() { func (c *CheckH2PING) check() {
@ -560,11 +560,11 @@ func (c *CheckH2PING) Stop() {
c.stop = true c.stop = true
close(c.stopCh) close(c.stopCh)
} }
c.stopWg.Wait() c.stopWg.Wait()
} }
func (c *CheckH2PING) run() { func (c *CheckH2PING) run() {
defer c.stopWg.Done() defer c.stopWg.Done()
// Get the randomized initial pause time // Get the randomized initial pause time
initialPauseTime := lib.RandomStagger(c.Interval) initialPauseTime := lib.RandomStagger(c.Interval)
next := time.After(initialPauseTime) next := time.After(initialPauseTime)
@ -587,7 +587,7 @@ func (c *CheckH2PING) Start() {
} }
c.stop = false c.stop = false
c.stopCh = make(chan struct{}) c.stopCh = make(chan struct{})
c.stopWg.Add(1) c.stopWg.Add(1)
go c.run() go c.run()
} }