Fixed bug, removed debug statement

intelsdi-x · Jul 5, 2017 · 21c99d4 · 21c99d4
1 parent aef965a
commit 21c99d4
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/protocol/udp.go b/protocol/udp.go
@@ -141,7 +141,7 @@ func (u *udpListener) Start() error {
 							"peer": fmt.Sprintf("%v:%v", peer.IP.String(), peer.Port),
 						}).Error(err)
 					}
-					return
+					continue
 				}
 				if len(line) > 0 {
 					line = line[:len(line)-1] // removes trailing '/n'

diff --git a/relay/relay.go b/relay/relay.go
@@ -69,12 +69,10 @@ func (r *relay) StreamMetrics(ctx context.Context, metrics_in chan []plugin.Metr
 			if metric.Namespace[len(metric.Namespace)-1].Value == "collectd" {
 				if val, err := metric.Config.GetString("collectdPort"); err == nil {
 					metrics[idx].Data = val
-					log.Debug("collectdPort set to: %v", val)
 				}
 			} else if metric.Namespace[len(metric.Namespace)-1].Value == "statsd" {
 				if val, err := metric.Config.GetString("statsdPort"); err == nil {
 					metrics[idx].Data = val
-					log.Debug("statsdPort set to: %v", val)
 				}
 			}