good morning!!!!

Skip to content
Snippets Groups Projects
Verified Commit 539ce65f authored by a's avatar a
Browse files

ok

parent 7aa657ab
Branches
Tags
1 merge request!23Whatthefuck
Pipeline #30105 passed
...@@ -22,12 +22,10 @@ func TestBenchmarkSuite(t *testing.T) { ...@@ -22,12 +22,10 @@ func TestBenchmarkSuite(t *testing.T) {
ctx := context.Background() ctx := context.Background()
makeTest("SingleClient", func(t *testing.T, server *server.Server, client codec.Conn) { makeTest("SingleClient", func(t *testing.T, server *server.Server, client codec.Conn) {
for i := 0; i < 10; i++ {
err := client.Do(ctx, nil, "test_ping", nil) err := client.Do(ctx, nil, "test_ping", nil)
if err != nil { if err != nil {
t.Error(err) t.Error(err)
} }
}
}) })
} }
...@@ -41,11 +39,13 @@ func runBenchmarkSuite(b *testing.B, sm jrpctest.ServerMaker) { ...@@ -41,11 +39,13 @@ func runBenchmarkSuite(b *testing.B, sm jrpctest.ServerMaker) {
} }
makeBench("SingleClient", func(b *testing.B, server *server.Server, client codec.Conn) { makeBench("SingleClient", func(b *testing.B, server *server.Server, client codec.Conn) {
for i := 0; i < b.N; i++ { for i := 0; i < b.N; i++ {
for j := 0; j < 100; j++ {
err := client.Do(ctx, nil, "test_ping", nil) err := client.Do(ctx, nil, "test_ping", nil)
if err != nil { if err != nil {
panic(err) panic(err)
} }
} }
}
}) })
} }
......
...@@ -13,7 +13,7 @@ import ( ...@@ -13,7 +13,7 @@ import (
) )
// 16mb... should be more than enough for any batch. // 16mb... should be more than enough for any batch.
// you shouldn't be batching more than this // you shouldn't be batching more than this. really, you shouldn't be using batching at all.
// TODO: make this configurable // TODO: make this configurable
const maxBatchSizeBytes = 1024 * 1024 * 1024 * 16 const maxBatchSizeBytes = 1024 * 1024 * 1024 * 16
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment