(cfg *types.Chain33Config, tx *types.Transaction)
| 143 | } |
| 144 | |
| 145 | func (q *QueueProtocol) send2MainChain(cfg *types.Chain33Config, tx *types.Transaction) (*types.Reply, error) { |
| 146 | |
| 147 | mainGrpc := grpcclient.GetDefaultMainClient() |
| 148 | if mainGrpc == nil { |
| 149 | var err error |
| 150 | mainGrpc, err = grpcclient.NewMainChainClient(cfg, "") |
| 151 | if err != nil { |
| 152 | return nil, err |
| 153 | } |
| 154 | } |
| 155 | return mainGrpc.SendTransaction(context.TODO(), tx) |
| 156 | } |
| 157 | |
| 158 | // SendTx send transaction to mempool with forward logic in parachain |
| 159 | func (q *QueueProtocol) SendTx(tx *types.Transaction) (*types.Reply, error) { |
no test coverage detected