Commit a8af19e7 authored by lyn's avatar lyn Committed by vipwzw

add para mempool

parent ce7ffc5b
......@@ -3,11 +3,12 @@ package para
import (
"bytes"
"context"
"fmt"
log "github.com/33cn/chain33/common/log/log15"
"github.com/33cn/chain33/queue"
"github.com/33cn/chain33/rpc/grpcclient"
"github.com/33cn/chain33/types"
"fmt"
)
var mlog = log.New("module", "mempool.para")
......@@ -49,7 +50,7 @@ func (mem *Mempool) SetQueueClient(client queue.Client) {
reply, err := mem.mainGrpcCli.SendTransaction(context.Background(), tx)
if err != nil {
//进行重试
for i := 0; i < 3; i ++ {
for i := 0; i < 3; i++ {
reply, err = mem.mainGrpcCli.SendTransaction(context.Background(), tx)
if err != nil {
continue
......
......@@ -20,5 +20,5 @@ func init() {
//New 创建price cache 结构的 mempool
func New(cfg *types.Mempool, sub []byte) queue.Module {
return NewMempool(cfg)
return NewMempool(cfg)
}
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