From b450a62816b0f91dd1d5feea81c77c65f6ba8921 Mon Sep 17 00:00:00 2001
From: Linh Vo <lvo@umbel.com>
Date: Tue, 25 Apr 2017 09:22:30 -0500
Subject: [PATCH] add entropy statsD

---
 fragment.go | 2 +-
 server.go   | 5 +++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/fragment.go b/fragment.go
index d3f7ddb8b..092f8bd8d 100644
--- a/fragment.go
+++ b/fragment.go
@@ -1376,11 +1376,11 @@ func (s *FragmentSyncer) SyncFragment() error {
 		if byteSlicesEqual(checksums) {
 			continue
 		}
-
 		// Synchronize block.
 		if err := s.syncBlock(blockID); err != nil {
 			return fmt.Errorf("sync block: id=%d, err=%s", blockID, err)
 		}
+		s.Fragment.stats.Count("BlockRepair", 1)
 	}
 
 	return nil
diff --git a/server.go b/server.go
index 2ce8a9f9c..fc1f11020 100644
--- a/server.go
+++ b/server.go
@@ -171,6 +171,7 @@ func (s *Server) Addr() net.Addr {
 func (s *Server) logger() *log.Logger { return log.New(s.LogOutput, "", log.LstdFlags) }
 
 func (s *Server) monitorAntiEntropy() {
+	t := time.Now()
 	ticker := time.NewTicker(s.AntiEntropyInterval)
 	defer ticker.Stop()
 
@@ -182,6 +183,7 @@ func (s *Server) monitorAntiEntropy() {
 		case <-s.closing:
 			return
 		case <-ticker.C:
+			s.Holder.Stats.Count("AntiEntropy", 1)
 		}
 
 		s.logger().Printf("holder sync beginning")
@@ -199,9 +201,12 @@ func (s *Server) monitorAntiEntropy() {
 			continue
 		}
 
+
 		// Record successful sync in log.
 		s.logger().Printf("holder sync complete")
 	}
+	dif := time.Since(t)
+	s.Holder.Stats.Histogram("AntiEntropyDuration", float64(dif))
 }
 
 // monitorMaxSlices periodically pulls the highest slice from each node in the cluster.