From 8e671e0154791eb6486333e92a830aff8f1595f2 Mon Sep 17 00:00:00 2001
From: HUANG Wei <grubbyfans@gmail.com>
Date: Fri, 18 Mar 2016 10:21:09 +0800
Subject: [PATCH] Inherit previous instance's stats in statsd plugin.

This way, after a reload, the stats wont restart again at least for the
counter type.

closes #887
---
 plugins/inputs/statsd/statsd.go | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/plugins/inputs/statsd/statsd.go b/plugins/inputs/statsd/statsd.go
index 943188353..5e1e85667 100644
--- a/plugins/inputs/statsd/statsd.go
+++ b/plugins/inputs/statsd/statsd.go
@@ -26,6 +26,8 @@ const (
 var dropwarn = "ERROR: Message queue full. Discarding line [%s] " +
 	"You may want to increase allowed_pending_messages in the config\n"
 
+var prevInstance *Statsd
+
 type Statsd struct {
 	// Address & Port to serve from
 	ServiceAddress string
@@ -234,10 +236,18 @@ func (s *Statsd) Start(_ telegraf.Accumulator) error {
 	// Make data structures
 	s.done = make(chan struct{})
 	s.in = make(chan []byte, s.AllowedPendingMessages)
-	s.gauges = make(map[string]cachedgauge)
-	s.counters = make(map[string]cachedcounter)
-	s.sets = make(map[string]cachedset)
-	s.timings = make(map[string]cachedtimings)
+
+	if prevInstance == nil {
+		s.gauges = make(map[string]cachedgauge)
+		s.counters = make(map[string]cachedcounter)
+		s.sets = make(map[string]cachedset)
+		s.timings = make(map[string]cachedtimings)
+	} else {
+		s.gauges = prevInstance.gauges
+		s.counters = prevInstance.counters
+		s.sets = prevInstance.sets
+		s.timings = prevInstance.timings
+	}
 
 	s.wg.Add(2)
 	// Start the UDP listener
@@ -245,6 +255,7 @@ func (s *Statsd) Start(_ telegraf.Accumulator) error {
 	// Start the line parser
 	go s.parser()
 	log.Printf("Started the statsd service on %s\n", s.ServiceAddress)
+	prevInstance = s
 	return nil
 }