Skip to content

C
ChainGrpcPro
Commit 145a6490 authored by duanjinfei's avatar duanjinfei
Browse files
Options

add broadcastEthTxWithFromRequestsArr chanel max len

parent c996a6e6
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 0 deletions
transaction/bathTest.go
View file @ 145a6490
...@@ -56,6 +56,9 @@ func BroadcastTxArr(tranArr []*TxFromTran, cfg *tool.Config) error { ...@@ -56,6 +56,9 @@ func BroadcastTxArr(tranArr []*TxFromTran, cfg *tool.Config) error {
requests := ring.BroadcastEthTxWithFromRequests{ requests := ring.BroadcastEthTxWithFromRequests{
List: ethTxArr, List: ethTxArr,
} }
if len(broadcastEthTxWithFromRequestsArr) > 500 {
time.Sleep(time.Second * 1)
}
broadcastEthTxWithFromRequestsArr <- &requests broadcastEthTxWithFromRequestsArr <- &requests
ethTxArr = make([]*ring.BroadcastEthTxWithFromRequest, 0) ethTxArr = make([]*ring.BroadcastEthTxWithFromRequest, 0)
} }
......
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