Merge pull request #69 from markrechler/fix_listener_close

ensure listener does not close on parse errors
bitly · May 18, 2015 · b8e9317 · b8e9317
2 parents fcbcfd0 + e7ff264
commit b8e9317
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/statsdaemon.go b/statsdaemon.go
@@ -569,12 +569,10 @@ func parseTo(conn io.ReadCloser, partialReads bool, out chan<- *Packet) {
 	parser := NewParser(conn, partialReads)
 	for {
 		p, more := parser.Next()
-		if p == nil {
-			break
+		if p != nil {
+			out <- p
 		}
 
-		out <- p
-
 		if !more {
 			break
 		}

diff --git a/statsdaemon_test.go b/statsdaemon_test.go
@@ -604,6 +604,8 @@ func TestMultipleUDPSends(t *testing.T) {
 	assert.Equal(t, nil, err)
 	assert.Equal(t, len("deploys.test.myservice:2|c"), n)
 
+	n, err = conn.Write([]byte("deploys.test.my:service:2|c"))
+
 	n, err = conn.Write([]byte("deploys.test.myservice:1|c"))
 	assert.Equal(t, nil, err)
 	assert.Equal(t, len("deploys.test.myservice:1|c"), n)

diff --git a/version.go b/version.go
@@ -1,3 +1,3 @@
 package main
 
-const VERSION = "0.7"
+const VERSION = "0.8-alpha"