From 7ca2d28baa3ffda2167e169da34180fd8bba4d9b Mon Sep 17 00:00:00 2001
From: Diptanu Choudhury <diptanuc@gmail.com>
Date: Sat, 2 Apr 2016 14:48:10 -0700
Subject: [PATCH] Not logging if consul is unavailable

---
 client/consul/sync.go | 17 ++++++++++++++---
 1 file changed, 14 insertions(+), 3 deletions(-)

diff --git a/client/consul/sync.go b/client/consul/sync.go
index 19014f343..029b3e03e 100644
--- a/client/consul/sync.go
+++ b/client/consul/sync.go
@@ -19,7 +19,8 @@ import (
 
 // ConsulService allows syncing of services and checks with Consul
 type ConsulService struct {
-	client *consul.Client
+	client   *consul.Client
+	availble bool
 
 	task           *structs.Task
 	allocID        string
@@ -349,7 +350,12 @@ func (c *ConsulService) PeriodicSync() {
 		select {
 		case <-sync.C:
 			if err := c.performSync(); err != nil {
-				c.logger.Printf("[DEBUG] consul: error in syncing task %q: %v", c.task.Name, err)
+				if c.availble {
+					c.logger.Printf("[DEBUG] consul: error in syncing task %q: %v", c.task.Name, err)
+				}
+				c.availble = false
+			} else {
+				c.availble = true
 			}
 		case <-c.shutdownCh:
 			sync.Stop()
@@ -438,6 +444,11 @@ func (c *ConsulService) runCheck(check Check) {
 		state = consul.HealthCritical
 	}
 	if err := c.client.Agent().UpdateTTL(check.ID(), output, state); err != nil {
-		c.logger.Printf("[DEBUG] error updating ttl check for check %q: %v", check.ID(), err)
+		if c.availble {
+			c.logger.Printf("[DEBUG] error updating ttl check for check %q: %v", check.ID(), err)
+			c.availble = false
+		} else {
+			c.availble = true
+		}
 	}
 }