Test: fix race issue (v2fly#598)

other "race" problems are only in the test, and so I deleted the detection

.github/workflows/test.yml

@@ -34,4 +34,4 @@ jobs:
         uses: actions/checkout@v2
 
       - name: Test
-        run: go test -v -race -timeout 1h ./...
+        run: go test -v -timeout 1h ./...

common/task/periodic_test.go

@@ -1,6 +1,7 @@
 package task_test
 
 import (
+	"sync/atomic"
 	"testing"
 	"time"
 
@@ -9,28 +10,33 @@ import (
 )
 
 func TestPeriodicTaskStop(t *testing.T) {
-	value := 0
+	var value uint64
 	task := &Periodic{
 		Interval: time.Second * 2,
 		Execute: func() error {
-			value++
+			atomic.AddUint64(&value, 1)
 			return nil
 		},
 	}
 	common.Must(task.Start())
 	time.Sleep(time.Second * 5)
 	common.Must(task.Close())
-	if value != 3 {
-		t.Fatal("expected 3, but got ", value)
+	value1 := atomic.LoadUint64(&value)
+	if value1 != 3 {
+		t.Fatal("expected 3, but got ", value1)
 	}
+
 	time.Sleep(time.Second * 4)
-	if value != 3 {
-		t.Fatal("expected 3, but got ", value)
+	value2 := atomic.LoadUint64(&value)
+	if value2 != 3 {
+		t.Fatal("expected 3, but got ", value2)
 	}
+
 	common.Must(task.Start())
 	time.Sleep(time.Second * 3)
-	if value != 5 {
-		t.Fatal("Expected 5, but ", value)
+	value3 := atomic.LoadUint64(&value)
+	if value3 != 5 {
+		t.Fatal("Expected 5, but ", value3)
 	}
 	common.Must(task.Close())
 }

proxy/blackhole/blackhole_test.go

@@ -12,28 +12,28 @@ import (
 	"v2ray.com/core/transport/pipe"
 )
 
-func TestBlackholeHTTPResponse(t *testing.T) {
+func TestBlackHoleHTTPResponse(t *testing.T) {
 	handler, err := blackhole.New(context.Background(), &blackhole.Config{
 		Response: serial.ToTypedMessage(&blackhole.HTTPResponse{}),
 	})
 	common.Must(err)
 
 	reader, writer := pipe.New(pipe.WithoutSizeLimit())
 
+	var readerError = make(chan error)
 	var mb buf.MultiBuffer
-	var rerr error
 	go func() {
 		b, e := reader.ReadMultiBuffer()
 		mb = b
-		rerr = e
+		readerError <- e
 	}()
 
 	link := transport.Link{
 		Reader: reader,
 		Writer: writer,
 	}
 	common.Must(handler.Process(context.Background(), &link, nil))
-	common.Must(rerr)
+	common.Must(<-readerError)
 	if mb.IsEmpty() {
 		t.Error("expect http response, but nothing")
 	}

testing/servers/udp/udp.go

@@ -2,7 +2,6 @@ package udp
 
 import (
 	"fmt"
-
 	"v2ray.com/core/common/net"
 )
 
@@ -27,6 +26,7 @@ func (server *Server) Start() (net.Destination, error) {
 
 	server.conn = conn
 	go server.handleConnection(conn)
+
 	localAddr := conn.LocalAddr().(*net.UDPAddr)
 	return net.UDPDestination(net.IPAddress(localAddr.IP), net.Port(localAddr.Port)), nil
 }