tests: fix leak test in embeded etcd test (#1916)

pingcap · Jun 5, 2021 · 7f01111 · 7f01111
1 parent 8983126
commit 7f01111
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/pkg/etcd/etcd_test.go b/pkg/etcd/etcd_test.go
@@ -41,13 +41,19 @@ func (s *etcdSuite) SetUpTest(c *check.C) {
 	c.Assert(err, check.IsNil)
 	s.clientURL = curl
 	s.etcd = e
-	go func() {
-		c.Log(<-e.Err())
-	}()
 }
 
 func (s *etcdSuite) TearDownTest(c *check.C) {
 	s.etcd.Close()
+logEtcdError:
+	for {
+		select {
+		case err := <-s.etcd.Err():
+			c.Logf("etcd server error: %v", err)
+		default:
+			break logEtcdError
+		}
+	}
 }
 
 func (s *etcdSuite) TestEmbedEtcd(c *check.C) {