other_mirrors/ Xray-core
1
0
Fork 0
mirror of https://github.com/XTLS/Xray-core.git synced 2024-11-26 06:39:20 +02:00
Code Issues Packages Projects Releases Wiki Activity

Reduce size and time of UDP test 

In the past, the UDP test in mass parallel proved to be the source of instability. This change try to improve pass rate.
This commit is contained in:
yuhan6665 2024-01-12 21:56:22 -05:00
parent 7f7f57d3b6
commit 77376ed94f
4 changed files with 22 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
testing/scenarios/dokodemo_test.go
View File

@ -171,7 +171,7 @@ func TestDokodemoUDP(t *testing.T) {
common.Must(err) common.Must(err)
defer CloseServer(server) defer CloseServer(server)
clientPortRange := uint32(5) clientPortRange := uint32(3)
retry := 1 retry := 1
clientPort := uint32(udp.PickPort()) clientPort := uint32(udp.PickPort())
for { for {

20
testing/scenarios/shadowsocks_2022_test.go
View File

@ -32,14 +32,22 @@ func TestShadowsocks2022Tcp(t *testing.T) {
} }
} }
func TestShadowsocks2022Udp(t *testing.T) { func TestShadowsocks2022UdpAES128(t *testing.T) {
for _, method := range shadowaead_2022.List {
password := make([]byte, 32) password := make([]byte, 32)
rand.Read(password) rand.Read(password)
t.Run(method, func(t *testing.T) { testShadowsocks2022Udp(t, shadowaead_2022.List[0], base64.StdEncoding.EncodeToString(password))
testShadowsocks2022Udp(t, method, base64.StdEncoding.EncodeToString(password))
})
} }
func TestShadowsocks2022UdpAES256(t *testing.T) {
password := make([]byte, 32)
rand.Read(password)
testShadowsocks2022Udp(t, shadowaead_2022.List[1], base64.StdEncoding.EncodeToString(password))
}
func TestShadowsocks2022UdpChacha(t *testing.T) {
password := make([]byte, 32)
rand.Read(password)
testShadowsocks2022Udp(t, shadowaead_2022.List[2], base64.StdEncoding.EncodeToString(password))
} }
func testShadowsocks2022Tcp(t *testing.T, method string, password string) { func testShadowsocks2022Tcp(t *testing.T, method string, password string) {
@ -199,7 +207,7 @@ func testShadowsocks2022Udp(t *testing.T, method string, password string) {
defer CloseAllServers(servers) defer CloseAllServers(servers)
var errGroup errgroup.Group var errGroup errgroup.Group
for i := 0; i < 10; i++ { for i := 0; i < 2; i++ {
errGroup.Go(testUDPConn(udpClientPort, 1024, time.Second*5)) errGroup.Go(testUDPConn(udpClientPort, 1024, time.Second*5))
} }

4
testing/scenarios/shadowsocks_test.go
View File

@ -289,7 +289,7 @@ func TestShadowsocksAES128GCMUDP(t *testing.T) {
defer CloseAllServers(servers) defer CloseAllServers(servers)
var errGroup errgroup.Group var errGroup errgroup.Group
for i := 0; i < 10; i++ { for i := 0; i < 2; i++ {
errGroup.Go(testUDPConn(clientPort, 1024, time.Second*5)) errGroup.Go(testUDPConn(clientPort, 1024, time.Second*5))
} }
if err := errGroup.Wait(); err != nil { if err := errGroup.Wait(); err != nil {
@ -391,7 +391,7 @@ func TestShadowsocksAES128GCMUDPMux(t *testing.T) {
defer CloseAllServers(servers) defer CloseAllServers(servers)
var errGroup errgroup.Group var errGroup errgroup.Group
for i := 0; i < 10; i++ { for i := 0; i < 2; i++ {
errGroup.Go(testUDPConn(clientPort, 1024, time.Second*5)) errGroup.Go(testUDPConn(clientPort, 1024, time.Second*5))
} }
if err := errGroup.Wait(); err != nil { if err := errGroup.Wait(); err != nil {

4
testing/scenarios/vmess_test.go
View File

@ -475,7 +475,7 @@ func TestVMessGCMUDP(t *testing.T) {
defer CloseAllServers(servers) defer CloseAllServers(servers)
var errg errgroup.Group var errg errgroup.Group
for i := 0; i < 10; i++ { for i := 0; i < 2; i++ {
errg.Go(testUDPConn(clientPort, 1024, time.Second*5)) errg.Go(testUDPConn(clientPort, 1024, time.Second*5))
} }
if err := errg.Wait(); err != nil { if err := errg.Wait(); err != nil {
@ -1176,7 +1176,7 @@ func TestVMessGCMMuxUDP(t *testing.T) {
for range "ab" { for range "ab" {
var errg errgroup.Group var errg errgroup.Group
for i := 0; i < 16; i++ { for i := 0; i < 2; i++ {
errg.Go(testTCPConn(clientPort, 1024, time.Second*10)) errg.Go(testTCPConn(clientPort, 1024, time.Second*10))
errg.Go(testUDPConn(clientUDPPort, 1024, time.Second*10)) errg.Go(testUDPConn(clientUDPPort, 1024, time.Second*10))
} }