Austin/mihomo
1
0
Fork 0
mirror of https://github.com/MetaCubeX/mihomo.git synced 2024-11-16 11:42:43 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Chore: add benchmark r/w

Browse Source
This commit is contained in:
gVisor bot 2022-05-23 12:27:34 +08:00
parent 6867e0d819
commit 155470d455
4 changed files with 29 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
test/clash_test.go
View File

@ -602,6 +602,10 @@ func benchmarkProxy(b *testing.B, proxy C.ProxyAdapter) {
require.NoError(b, err) require.NoError(b, err)
defer l.Close() defer l.Close()
chunkSize := int64(16 * 1024)
chunk := make([]byte, chunkSize)
rand.Read(chunk)
go func() { go func() {
c, err := l.Accept() c, err := l.Accept()
if err != nil { if err != nil {
@ -609,12 +613,17 @@ func benchmarkProxy(b *testing.B, proxy C.ProxyAdapter) {
} }
defer c.Close() defer c.Close()
go func() {
for {
_, err := c.Write(chunk)
if err != nil {
return
}
}
}()
io.Copy(io.Discard, c) io.Copy(io.Discard, c)
}() }()
chunkSize := int64(16 * 1024)
chunk := make([]byte, chunkSize)
rand.Read(chunk)
conn, err := proxy.DialContext(context.Background(), &C.Metadata{ conn, err := proxy.DialContext(context.Background(), &C.Metadata{
Host: localIP.String(), Host: localIP.String(),
DstPort: "10001", DstPort: "10001",
@ -625,11 +634,20 @@ func benchmarkProxy(b *testing.B, proxy C.ProxyAdapter) {
_, err = conn.Write([]byte("skip protocol handshake")) _, err = conn.Write([]byte("skip protocol handshake"))
require.NoError(b, err) require.NoError(b, err)
b.SetBytes(chunkSize) b.Run("Write", func(b *testing.B) {
b.ResetTimer() b.SetBytes(chunkSize)
for i := 0; i < b.N; i++ { for i := 0; i < b.N; i++ {
conn.Write(chunk) conn.Write(chunk)
} }
})
b.Run("Read", func(b *testing.B) {
b.SetBytes(chunkSize)
buf := make([]byte, chunkSize)
for i := 0; i < b.N; i++ {
conn.Read(buf)
}
})
} }
func TestClash_Basic(t *testing.T) { func TestClash_Basic(t *testing.T) {

2
test/snell_test.go
View File

@ -151,7 +151,7 @@ func Benchmark_Snell(b *testing.B) {
Binds: []string{fmt.Sprintf("%s:/config.conf", C.Path.Resolve("snell-http.conf"))}, Binds: []string{fmt.Sprintf("%s:/config.conf", C.Path.Resolve("snell-http.conf"))},
} }
id, err := startContainer(cfg, hostCfg, "snell-http") id, err := startContainer(cfg, hostCfg, "snell-bench")
require.NoError(b, err) require.NoError(b, err)
b.Cleanup(func() { b.Cleanup(func() {

2
test/ss_test.go
View File

@ -168,7 +168,7 @@ func Benchmark_Shadowsocks(b *testing.B) {
PortBindings: defaultPortBindings, PortBindings: defaultPortBindings,
} }
id, err := startContainer(cfg, hostCfg, "ss") id, err := startContainer(cfg, hostCfg, "ss-bench")
require.NoError(b, err) require.NoError(b, err)
b.Cleanup(func() { b.Cleanup(func() {

2
test/vmess_test.go
View File

@ -372,7 +372,7 @@ func Benchmark_Vmess(b *testing.B) {
Binds: []string{fmt.Sprintf("%s:/etc/v2ray/config.json", configPath)}, Binds: []string{fmt.Sprintf("%s:/etc/v2ray/config.json", configPath)},
} }
id, err := startContainer(cfg, hostCfg, "vmess-aead") id, err := startContainer(cfg, hostCfg, "vmess-bench")
require.NoError(b, err) require.NoError(b, err)
b.Cleanup(func() { b.Cleanup(func() {