From eeb588ffa0aa60dcf5f23666bafb02e9e4e5b659 Mon Sep 17 00:00:00 2001
From: Darien Raymond <admin@v2ray.com>
Date: Tue, 13 Nov 2018 20:55:34 +0100
Subject: [PATCH] update wss test

---
 testing/scenarios/tls_test.go | 38 +++++++++++++++++++++--------------
 1 file changed, 23 insertions(+), 15 deletions(-)

diff --git a/testing/scenarios/tls_test.go b/testing/scenarios/tls_test.go
index b36a4f98d..c2d19b38a 100644
--- a/testing/scenarios/tls_test.go
+++ b/testing/scenarios/tls_test.go
@@ -500,25 +500,33 @@ func TestTLSOverWebSocket(t *testing.T) {
 	}
 
 	servers, err := InitializeServerConfigs(serverConfig, clientConfig)
-	assert(err, IsNil)
+	common.Must(err)
+	defer CloseAllServers(servers)
 
-	conn, err := net.DialTCP("tcp", nil, &net.TCPAddr{
-		IP:   []byte{127, 0, 0, 1},
-		Port: int(clientPort),
-	})
-	assert(err, IsNil)
+	var wg sync.WaitGroup
+	for i := 0; i < 10; i++ {
+		wg.Add(1)
+		go func() {
+			defer wg.Done()
 
-	payload := make([]byte, 10240*1024)
-	rand.Read(payload)
-	nBytes, err := conn.Write([]byte(payload))
-	assert(err, IsNil)
-	assert(nBytes, Equals, len(payload))
+			conn, err := net.DialTCP("tcp", nil, &net.TCPAddr{
+				IP:   []byte{127, 0, 0, 1},
+				Port: int(clientPort),
+			})
+			common.Must(err)
 
-	response := readFrom(conn, time.Second*20, len(payload))
-	assert(response, Equals, xor([]byte(payload)))
-	assert(conn.Close(), IsNil)
+			payload := make([]byte, 10240*1024)
+			rand.Read(payload)
+			nBytes, err := conn.Write([]byte(payload))
+			assert(err, IsNil)
+			assert(nBytes, Equals, len(payload))
 
-	CloseAllServers(servers)
+			response := readFrom(conn, time.Second*20, len(payload))
+			assert(response, Equals, xor([]byte(payload)))
+			assert(conn.Close(), IsNil)
+		}()
+	}
+	wg.Wait()
 }
 
 func TestHTTP2(t *testing.T) {