fix bathHandleSendCount

transaction/bathTest.go

@@ -32,7 +32,7 @@ func BroadcastTxArr(tranArr []*types.Transaction, cfg *tool.Config) error {
 	}
 	ringServiceClient := ring.NewRingServiceClient(client)
 	for i := 0; i < cfg.GoRoutineCount; i++ {
-		go broadcastTx(ringServiceClient)
+		go broadcastTx(cfg, ringServiceClient)
 	}
 	allSignedTxCount = int64(len(tranArr))
 	startTime := time.Now()
@@ -72,7 +72,7 @@ func BroadcastTxArr(tranArr []*types.Transaction, cfg *tool.Config) error {
 }
 
 // BatchSendTran 处理批量发送的签名交易
-func broadcastTx(client ring.RingServiceClient) error {
+func broadcastTx(cfg *tool.Config, client ring.RingServiceClient) error {
 	for {
 		select {
 		case broadcastEthTxWithFromRequests := <-broadcastEthTxWithFromRequestsArr:
@@ -83,8 +83,8 @@ func broadcastTx(client ring.RingServiceClient) error {
 			if err != nil {
 				log.Error("BroadcastTxs Error:", err)
 			}
-			atomic.AddInt64(&bathHandleSendCount, int64(len(broadcastEthTxWithFromRequests.List)))
 			sinceTime := time.Since(sendTranStartTime).Milliseconds()
+			atomic.AddInt64(&bathHandleSendCount, int64(cfg.BatchCount))
 			atomic.AddInt64(&totalSendTime, sinceTime)
 			log.Infof("Send transaction time: %d ms ", sinceTime)
 		}