Commit 149dacc1 authored by duanjinfei's avatar duanjinfei

add wait send count success

parent e294bb81
...@@ -60,16 +60,16 @@ func BroadcastTxArr(tranArr []*TxFromTran, cfg *tool.Config) error { ...@@ -60,16 +60,16 @@ func BroadcastTxArr(tranArr []*TxFromTran, cfg *tool.Config) error {
ethTxArr = make([]*ring.BroadcastEthTxWithFromRequest, 0) ethTxArr = make([]*ring.BroadcastEthTxWithFromRequest, 0)
} }
} }
//for { for {
// if bathHandleSendCount == allSignedTxCount { if bathHandleSendCount == allSignedTxCount {
// log.Info("beforeBathHandleSendCount:", beforeBathHandleSendCount) log.Info("beforeBathHandleSendCount:", beforeBathHandleSendCount)
// log.Infof("Send tran count: %d", bathHandleSendCount) log.Infof("Send tran count: %d", bathHandleSendCount)
// log.Infof("Since time: %d ms", time.Since(startTime).Milliseconds()) log.Infof("Since time: %d ms", time.Since(startTime).Milliseconds())
// log.Infof("Send tran total time: %d ms", totalSendTime) log.Infof("Send tran total time: %d ms", totalSendTime)
// bathHandleSendCount = 0 bathHandleSendCount = 0
// break break
// } }
//} }
return nil return nil
} }
......
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