Commit f43a3562 authored by 李伟@五瓣科技's avatar 李伟@五瓣科技

fix tree list

parent a105956f
...@@ -825,9 +825,7 @@ func (web *WebServicer) sendBatchTxsFromQueue(fromAddr string, toAddrs []string, ...@@ -825,9 +825,7 @@ func (web *WebServicer) sendBatchTxsFromQueue(fromAddr string, toAddrs []string,
sendToRedisBeginTime := time.Now() sendToRedisBeginTime := time.Now()
go func() { go func() {
for _, originalBatchTxs := range value.RedisTxList { for _, originalBatchTxs := range value.RedisTxList {
batchTxsForRedis <- originalBatchTxs
fmt.Printf("originalBatchTxs %v %v \n", originalBatchTxs.Hash, len(originalBatchTxs.Txs))
batchTxsForRedis <- &originalBatchTxs
} }
}() }()
...@@ -947,7 +945,7 @@ func (web *WebServicer) sendLoop(fromAddr string, toAddrs []string, txCount int, ...@@ -947,7 +945,7 @@ func (web *WebServicer) sendLoop(fromAddr string, toAddrs []string, txCount int,
batchTxs := OriginalBatchTxs{Hash: hashBytes, Txs: txs} batchTxs := OriginalBatchTxs{Hash: hashBytes, Txs: txs}
batchTxsForRedis <- &batchTxs batchTxsForRedis <- batchTxs
if j == 0 { if j == 0 {
sendRedisBeginTime = time.Now() sendRedisBeginTime = time.Now()
} }
...@@ -1083,7 +1081,7 @@ func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount in ...@@ -1083,7 +1081,7 @@ func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount in
batchTxs := OriginalBatchTxs{Hash: hashBytes, Txs: txs} batchTxs := OriginalBatchTxs{Hash: hashBytes, Txs: txs}
batchTxsForRedis <- &batchTxs batchTxsForRedis <- batchTxs
if j == 0 { if j == 0 {
sendRedisBeginTime = time.Now() sendRedisBeginTime = time.Now()
} }
......
...@@ -19,7 +19,7 @@ var originalTxParam EthClient ...@@ -19,7 +19,7 @@ var originalTxParam EthClient
var originalTxPrivateKey string = "9e0944f587e1043d6e303644738b0c7c77ed15b176ca574ed0be40c0b9bbdc3a" var originalTxPrivateKey string = "9e0944f587e1043d6e303644738b0c7c77ed15b176ca574ed0be40c0b9bbdc3a"
var originalTxsHashQueue chan *[]byte = make(chan *[]byte, 1000) var originalTxsHashQueue chan *[]byte = make(chan *[]byte, 1000)
var batchTxsForRedis chan *OriginalBatchTxs = make(chan *OriginalBatchTxs, 10000000) var batchTxsForRedis chan OriginalBatchTxs = make(chan OriginalBatchTxs, 10000000)
var conTxsQueue chan ConTxsWithId = make(chan ConTxsWithId, 1000) var conTxsQueue chan ConTxsWithId = make(chan ConTxsWithId, 1000)
const batchTxSize = 4 const batchTxSize = 4
...@@ -105,7 +105,7 @@ func ProduceOriginalTx() error { ...@@ -105,7 +105,7 @@ func ProduceOriginalTx() error {
hashesBytes = append(hashesBytes, hashBytes...) hashesBytes = append(hashesBytes, hashBytes...)
batchTxs := OriginalBatchTxs{Hash: hashBytes, Txs: txs} batchTxs := OriginalBatchTxs{Hash: hashBytes, Txs: txs}
batchTxsForRedis <- &batchTxs batchTxsForRedis <- batchTxs
} }
originalTxsHashQueue <- &hashesBytes originalTxsHashQueue <- &hashesBytes
} else { } else {
......
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