change default

Signed-off-by: Chengxuan Xing <[email protected]>
hyperledger · Aug 12, 2024 · 9af06f4 · 9af06f4
1 parent 79519e1
commit 9af06f4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/pkg/rpcbackend/backend.go b/pkg/rpcbackend/backend.go
@@ -72,10 +72,10 @@ func NewRPCClientWithOption(ctx context.Context, client *resty.Client, options R
 			batchDelay = *options.BatchOptions.BatchDelay
 		}
 
-		if options.BatchOptions.BatchSize > 1 {
+		if options.BatchOptions.BatchSize != 0 {
 			batchSize = options.BatchOptions.BatchSize
 		}
-		if options.BatchOptions.BatchWorkerCount > 1 {
+		if options.BatchOptions.BatchWorkerCount != 0 {
 			batchWorkerCount = options.BatchOptions.BatchWorkerCount
 		}
 		rpcClient.requestBatchWorkerSlots = make(chan bool, batchWorkerCount)

diff --git a/pkg/rpcbackend/backend_test.go b/pkg/rpcbackend/backend_test.go
@@ -674,8 +674,9 @@ func TestBatchRequestsTestWorkerCounts(t *testing.T) {
 	rb := NewRPCClientWithOption(ctx, c, RPCClientOptions{
 		MaxConcurrentRequest: 10,
 		BatchOptions: &RPCClientBatchOptions{
-			BatchDelay: &tH, // very long delay, so need to rely on batch size to be hit for sending a batch
-			BatchSize:  2,
+			BatchDelay:       &tH, // very long delay, so need to rely on batch size to be hit for sending a batch
+			BatchSize:        2,
+			BatchWorkerCount: 1,
 		},
 	}).(*RPCClient)