fix goroutine leaks bug

leopoldxx · leopoldxx · commit eeb5f65291b9 · 2017-07-25T22:36:35.000+08:00
diff --git a/net/ping.go b/net/ping.go
@@ -110,6 +110,7 @@ func (p pinger) recvEchoReplyMessage(ctx context.Context, cb *concurrency.Barrie
 	defer cancel()
 
 	retryCh := make(chan string, retryQueueLen)
+	defer close(retryCh)
 
 	go func(retry <-chan string) {
 		for ip := range retry {
