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

Remove initial delay of registering services with consul

This commit is contained in:
Diptanu Choudhury 2016-06-13 01:42:56 +02:00
parent 3bef934580
commit 751b2e1bcb
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
command/agent/consul/syncer.go
View File

@ -752,14 +752,11 @@ func (c *Syncer) deregisterCheck(checkID string) error {
// Run triggers periodic syncing of services and checks with Consul. This is // Run triggers periodic syncing of services and checks with Consul. This is
// a long lived go-routine which is stopped during shutdown. // a long lived go-routine which is stopped during shutdown.
func (c *Syncer) Run() { func (c *Syncer) Run() {
d := initialSyncDelay + lib.RandomStagger(initialSyncBuffer-initialSyncDelay) sync := time.NewTimer(0)
sync := time.NewTimer(d)
c.logger.Printf("[DEBUG] consul.syncer: sleeping %v before first sync", d)
for { for {
select { select {
case <-sync.C: case <-sync.C:
d = syncInterval - lib.RandomStagger(syncInterval/syncJitter) d := syncInterval - lib.RandomStagger(syncInterval/syncJitter)
sync.Reset(d) sync.Reset(d)
if err := c.SyncServices(); err != nil { if err := c.SyncServices(); err != nil {