From d2475d69f670fe3906810ff2202d3abae614fbca Mon Sep 17 00:00:00 2001 From: CharlesCheung96 Date: Wed, 29 May 2024 15:55:29 +0800 Subject: [PATCH] fix ut --- pkg/cmd/server/server_test.go | 18 +++++++++--------- pkg/config/config_test_data.go | 6 +++--- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/pkg/cmd/server/server_test.go b/pkg/cmd/server/server_test.go index 3a140110f85..0c2c6502851 100644 --- a/pkg/cmd/server/server_test.go +++ b/pkg/cmd/server/server_test.go @@ -183,12 +183,12 @@ func TestParseCfg(t *testing.T) { // We expect the default configuration here. Messages: &config.MessagesConfig{ ClientMaxBatchInterval: config.TomlDuration(time.Millisecond * 10), - ClientMaxBatchSize: 8 * 1024 * 1024, - ClientMaxBatchCount: 128, + ClientMaxBatchSize: 64 * 1024 * 1024, + ClientMaxBatchCount: 1024, ClientRetryRateLimit: 1.0, ServerMaxPendingMessageCount: 102400, ServerAckInterval: config.TomlDuration(time.Millisecond * 100), - ServerWorkerPoolSize: 4, + ServerWorkerPoolSize: 8, MaxRecvMsgSize: 256 * 1024 * 1024, KeepAliveTimeout: config.TomlDuration(time.Second * 10), KeepAliveTime: config.TomlDuration(time.Second * 30), @@ -469,12 +469,12 @@ cert-allowed-cn = ["dd","ee"] // We expect the default configuration here. Messages: &config.MessagesConfig{ ClientMaxBatchInterval: config.TomlDuration(time.Millisecond * 10), - ClientMaxBatchSize: 8 * 1024 * 1024, - ClientMaxBatchCount: 128, + ClientMaxBatchSize: 64 * 1024 * 1024, + ClientMaxBatchCount: 1024, ClientRetryRateLimit: 1.0, ServerMaxPendingMessageCount: 102400, ServerAckInterval: config.TomlDuration(time.Millisecond * 100), - ServerWorkerPoolSize: 4, + ServerWorkerPoolSize: 8, MaxRecvMsgSize: 256 * 1024 * 1024, KeepAliveTimeout: config.TomlDuration(time.Second * 10), KeepAliveTime: config.TomlDuration(time.Second * 30), @@ -534,12 +534,12 @@ unknown3 = 3 // We expect the default configuration here. Messages: &config.MessagesConfig{ ClientMaxBatchInterval: config.TomlDuration(time.Millisecond * 10), - ClientMaxBatchSize: 8 * 1024 * 1024, - ClientMaxBatchCount: 128, + ClientMaxBatchSize: 64 * 1024 * 1024, + ClientMaxBatchCount: 1024, ClientRetryRateLimit: 1.0, ServerMaxPendingMessageCount: 102400, ServerAckInterval: config.TomlDuration(time.Millisecond * 100), - ServerWorkerPoolSize: 4, + ServerWorkerPoolSize: 8, MaxRecvMsgSize: 256 * 1024 * 1024, KeepAliveTimeout: config.TomlDuration(time.Second * 10), KeepAliveTime: config.TomlDuration(time.Second * 30), diff --git a/pkg/config/config_test_data.go b/pkg/config/config_test_data.go index 6a801e6907d..7739addd13b 100644 --- a/pkg/config/config_test_data.go +++ b/pkg/config/config_test_data.go @@ -166,12 +166,12 @@ const ( }, "messages": { "client-max-batch-interval": 10000000, - "client-max-batch-size": 8388608, - "client-max-batch-count": 128, + "client-max-batch-size": 67108864, + "client-max-batch-count": 1024, "client-retry-rate-limit": 1, "server-max-pending-message-count": 102400, "server-ack-interval": 100000000, - "server-worker-pool-size": 4, + "server-worker-pool-size": 8, "max-recv-msg-size": 268435456, "keep-alive-time": 30000000000, "keep-alive-timeout": 10000000000