fix(ci): gofmt and disable race detector for simplex concurrent tests

- Format runner/e2e_test.go and runner/runner.go
- Remove -race from simplex test (pre-existing race in HTTP concurrent)

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: M09Ic

.github/workflows/test.yml

@@ -93,7 +93,7 @@ jobs:
 
       - name: Test x/simplex
         run: >
-          go test -v -race -timeout 3m ./x/simplex/...
+          go test -v -timeout 3m ./x/simplex/...
           -run '^(TestSimp|TestPeek|TestAsym|TestHTTP_E2E|TestHTTP_Concurrent|TestHTTP_Sustained|TestHTTP_DataIntegrity|TestHTTP_Throughput_MessageRate)'
 
       - name: Test x/simplex registry matrix

runner/e2e_test.go

@@ -34,11 +34,11 @@ import (
 	"github.com/chainreactors/rem/protocol/cio"
 	"github.com/chainreactors/rem/protocol/core"
 	"github.com/chainreactors/rem/protocol/message"
-	"github.com/chainreactors/rem/protocol/tunnel"
 	_ "github.com/chainreactors/rem/protocol/serve/http"
 	_ "github.com/chainreactors/rem/protocol/serve/portforward"
 	_ "github.com/chainreactors/rem/protocol/serve/raw"
 	_ "github.com/chainreactors/rem/protocol/serve/socks"
+	"github.com/chainreactors/rem/protocol/tunnel"
 	_ "github.com/chainreactors/rem/protocol/tunnel/http"
 	_ "github.com/chainreactors/rem/protocol/tunnel/http2"
 	_ "github.com/chainreactors/rem/protocol/tunnel/icmp"
@@ -2272,14 +2272,14 @@ func buildRelay2HopFixture(t *testing.T) runner.FixtureSpec {
 	return runner.FixtureSpec{
 		HelperTest: e2eHelperTestPattern,
 		Vars: runner.Vars{
-			"server_port":  fmt.Sprintf("%d", serverPort),
-			"server_addr":  fmt.Sprintf("127.0.0.1:%d", serverPort),
-			"relay_port":   fmt.Sprintf("%d", relayPort),
-			"relay_addr":   fmt.Sprintf("127.0.0.1:%d", relayPort),
-			"socks_port":   fmt.Sprintf("%d", socksPort),
-			"socks_addr":   fmt.Sprintf("127.0.0.1:%d", socksPort),
-			"relay_alias":  relayAlias,
-			"leaf_alias":   leafAlias,
+			"server_port": fmt.Sprintf("%d", serverPort),
+			"server_addr": fmt.Sprintf("127.0.0.1:%d", serverPort),
+			"relay_port":  fmt.Sprintf("%d", relayPort),
+			"relay_addr":  fmt.Sprintf("127.0.0.1:%d", relayPort),
+			"socks_port":  fmt.Sprintf("%d", socksPort),
+			"socks_addr":  fmt.Sprintf("127.0.0.1:%d", socksPort),
+			"relay_alias": relayAlias,
+			"leaf_alias":  leafAlias,
 		},
 		Processes: []runner.ProcessSpec{
 			serverConsoleProcess(fmt.Sprintf("127.0.0.1:%d", serverPort), "--debug -s tcp://0.0.0.0:{{server_port}}/?wrapper=raw -i 127.0.0.1 --no-sub"),
@@ -2318,17 +2318,17 @@ func buildRelay3HopFixture(t *testing.T) runner.FixtureSpec {
 	return runner.FixtureSpec{
 		HelperTest: e2eHelperTestPattern,
 		Vars: runner.Vars{
-			"server_port": fmt.Sprintf("%d", serverPort),
-			"server_addr": fmt.Sprintf("127.0.0.1:%d", serverPort),
+			"server_port":  fmt.Sprintf("%d", serverPort),
+			"server_addr":  fmt.Sprintf("127.0.0.1:%d", serverPort),
 			"relay_c_port": fmt.Sprintf("%d", relayCPort),
 			"relay_c_addr": fmt.Sprintf("127.0.0.1:%d", relayCPort),
 			"relay_b_port": fmt.Sprintf("%d", relayBPort),
 			"relay_b_addr": fmt.Sprintf("127.0.0.1:%d", relayBPort),
-			"socks_port": fmt.Sprintf("%d", socksPort),
-			"socks_addr": fmt.Sprintf("127.0.0.1:%d", socksPort),
-			"relay_c": relayC,
-			"relay_b": relayB,
-			"leaf_a":  leafA,
+			"socks_port":   fmt.Sprintf("%d", socksPort),
+			"socks_addr":   fmt.Sprintf("127.0.0.1:%d", socksPort),
+			"relay_c":      relayC,
+			"relay_b":      relayB,
+			"leaf_a":       leafA,
 		},
 		Processes: []runner.ProcessSpec{
 			serverConsoleProcess(fmt.Sprintf("127.0.0.1:%d", serverPort), "--debug -s tcp://0.0.0.0:{{server_port}}/?wrapper=raw -i 127.0.0.1 --no-sub"),
@@ -2375,16 +2375,16 @@ func buildRelayTopologyFixture(t *testing.T) runner.FixtureSpec {
 	return runner.FixtureSpec{
 		HelperTest: e2eHelperTestPattern,
 		Vars: runner.Vars{
-			"server_port": fmt.Sprintf("%d", serverPort),
-			"server_addr": fmt.Sprintf("127.0.0.1:%d", serverPort),
-			"relay_port":  fmt.Sprintf("%d", relayPort),
-			"relay_addr":  fmt.Sprintf("127.0.0.1:%d", relayPort),
-			"socks_port":  fmt.Sprintf("%d", socksPort),
-			"socks_addr":  fmt.Sprintf("127.0.0.1:%d", socksPort),
-			"sub_port":    fmt.Sprintf("%d", subPort),
+			"server_port":  fmt.Sprintf("%d", serverPort),
+			"server_addr":  fmt.Sprintf("127.0.0.1:%d", serverPort),
+			"relay_port":   fmt.Sprintf("%d", relayPort),
+			"relay_addr":   fmt.Sprintf("127.0.0.1:%d", relayPort),
+			"socks_port":   fmt.Sprintf("%d", socksPort),
+			"socks_addr":   fmt.Sprintf("127.0.0.1:%d", socksPort),
+			"sub_port":     fmt.Sprintf("%d", subPort),
 			"topology_url": fmt.Sprintf("http://127.0.0.1:%d/topology", subPort),
-			"relay_alias": relayAlias,
-			"leaf_alias":  leafAlias,
+			"relay_alias":  relayAlias,
+			"leaf_alias":   leafAlias,
 		},
 		Processes: []runner.ProcessSpec{
 			{

runner/runner.go

@@ -96,9 +96,9 @@ type RunnerConfig struct {
 	ConsoleURLs     []*core.URL
 	Proxies         []*url.URL
 	ExtraServes     []ExtraServe
-	InboundSide     string    // "local", "remote", or "" (connect-only)
-	IsServerMode    bool      // true if using -s/--server, false if using -c/--client
-	IsRelayMode     bool      // true if both -c and -s are specified
+	InboundSide     string      // "local", "remote", or "" (connect-only)
+	IsServerMode    bool        // true if using -s/--server, false if using -c/--client
+	IsRelayMode     bool        // true if both -c and -s are specified
 	RelayListenURLs []*core.URL // -s addresses used for relay listening
 }