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

fix from addr

parent e39cf657
...@@ -504,7 +504,7 @@ func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount in ...@@ -504,7 +504,7 @@ func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount in
if fromAddr != systemFromAddr && first { if fromAddr != systemFromAddr && first {
tx, err = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(fromAddr), amount*int64(txCount), big.NewInt(256), nil) tx, err = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(fromAddr), amount*int64(txCount), big.NewInt(256), nil)
first = false
} else { } else {
tx, err = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(toAddrs[i%addrsL]), amount, big.NewInt(256), nil) tx, err = buildOriginalTx(originalTxParam.Nonce, common.HexToAddress(toAddrs[i%addrsL]), amount, big.NewInt(256), nil)
} }
...@@ -532,6 +532,7 @@ func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount in ...@@ -532,6 +532,7 @@ func (web *WebServicer) ProduceTxs(fromAddr string, toAddrs []string, txCount in
txs = append(txs, TxWithFrom{ txs = append(txs, TxWithFrom{
[]byte(systemFromAddr), []byte(systemFromAddr),
tx}) tx})
first = false
} else { } else {
txs = append(txs, TxWithFrom{ txs = append(txs, TxWithFrom{
common.HexToAddress(fromAddr).Bytes(), common.HexToAddress(fromAddr).Bytes(),
......
...@@ -85,21 +85,13 @@ func Start(redisAddr, passwd string) { ...@@ -85,21 +85,13 @@ func Start(redisAddr, passwd string) {
panic(err) panic(err)
} }
// hashlistAsJson, err := json.Marshal(hashs)
// if err != nil {
// panic(err)
// }
hashstr := []string{} hashstr := []string{}
for _, v := range hashs { for _, v := range hashs {
//fmt.Printf("idx: %d key: %s v: %s \n", k, fmt.Sprintf("%x", batchTxs.Hash), v.Hex())
hashstr = append(hashstr, v.Hex()) hashstr = append(hashstr, v.Hex())
} }
fmt.Printf("batchTxHash %s list: %v \n", fmt.Sprintf("%x", batchTxs.Hash), hashstr) fmt.Printf("batchTxHash %s listLen: %d list: %v \n", fmt.Sprintf("%x", batchTxs.Hash), len(hashstr), hashstr)
if err := client.LPush(context.Background(), fmt.Sprintf("%x", batchTxs.Hash), hashstr); err != nil { if err := client.LPush(context.Background(), fmt.Sprintf("%x", batchTxs.Hash), hashstr); err != 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