Commit e27d3291 authored by duanjinfei's avatar duanjinfei

add log print

parent 8ca586a4
...@@ -73,22 +73,16 @@ func BroadcastTxArr(tranArr []*types.Transaction, cfg *tool.Config) error { ...@@ -73,22 +73,16 @@ func BroadcastTxArr(tranArr []*types.Transaction, cfg *tool.Config) error {
// BatchSendTran 处理批量发送的签名交易 // BatchSendTran 处理批量发送的签名交易
func broadcastTx(client ring.RingServiceClient) error { func broadcastTx(client ring.RingServiceClient) error {
var beforeSendTxTime time.Time
for { for {
select { select {
case broadcastEthTxWithFromRequests := <-broadcastEthTxWithFromRequestsArr: case broadcastEthTxWithFromRequests := <-broadcastEthTxWithFromRequestsArr:
sendTranStartTime := time.Now() sendTranStartTime := time.Now()
if beforeSendTxTime.UnixMilli() > 0 && time.Since(beforeSendTxTime).Milliseconds() < 1 {
time.Sleep(time.Millisecond * time.Duration(1))
}
ctx, cancel := context.WithTimeout(context.Background(), time.Second*9) ctx, cancel := context.WithTimeout(context.Background(), time.Second*9)
defer cancel() defer cancel()
txs, err := client.BroadcastTxs(ctx, broadcastEthTxWithFromRequests) _, err := client.BroadcastTxs(ctx, broadcastEthTxWithFromRequests)
if err != nil { if err != nil {
log.Error("BroadcastTxs Error:", err) log.Error("BroadcastTxs Error:", err)
} }
log.Info("BroadcastTxs Res:", txs)
beforeSendTxTime = time.Now()
atomic.AddInt64(&bathHandleSendCount, int64(len(broadcastEthTxWithFromRequests.List))) atomic.AddInt64(&bathHandleSendCount, int64(len(broadcastEthTxWithFromRequests.List)))
sinceTime := time.Since(sendTranStartTime).Milliseconds() sinceTime := time.Since(sendTranStartTime).Milliseconds()
atomic.AddInt64(&totalSendTime, sinceTime) atomic.AddInt64(&totalSendTime, sinceTime)
......
...@@ -105,6 +105,7 @@ func SignedTxArr(sendTxAccountArr [][]string, cfg *tool.Config) []*types.Transac ...@@ -105,6 +105,7 @@ func SignedTxArr(sendTxAccountArr [][]string, cfg *tool.Config) []*types.Transac
return nil return nil
} }
nonce := new(big.Int).SetUint64(response.Nonce) nonce := new(big.Int).SetUint64(response.Nonce)
log.Infof("from addr:%s,nonce:%d", fromAddr, nonce)
for signCount := 0; signCount < cfg.SignCount; signCount++ { for signCount := 0; signCount < cfg.SignCount; signCount++ {
tranCfg := TranConfig{ tranCfg := TranConfig{
Amount: cfg.Amount, Amount: cfg.Amount,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment