add channel len log

startTest.go

@@ -44,6 +44,7 @@ func startTest() {
 				for {
 					select {
 					case arr := <-tranArrChan:
+						log.Info("tranArrChan len:", len(tranArrChan))
 						log.Info("-----into tranArrChan-----")
 						if err := transaction.BroadcastTxArr(arr, cfg); err != nil {
 							log.Errorf("Bath Send Tran error: %s", err)

transaction/bathTest.go

@@ -78,6 +78,7 @@ func broadcastTx(cfg *tool.Config, client ring.RingServiceClient) error {
 	for {
 		select {
 		case broadcastEthTxWithFromRequests := <-broadcastEthTxWithFromRequestsArr:
+			log.Info("broadcastEthTxWithFromRequestsArr len:", len(broadcastEthTxWithFromRequestsArr))
 			sendTranStartTime := time.Now()
 			ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
 			defer cancel()