(method string, request interface{}, response interface{})
| 211 | } |
| 212 | |
| 213 | func (bs *BusService) requestBP(method string, request interface{}, response interface{}) (err error) { |
| 214 | var bpNodeID proto.NodeID |
| 215 | if bpNodeID, err = rpc.GetCurrentBP(); err != nil { |
| 216 | return |
| 217 | } |
| 218 | return bs.caller.CallNode(bpNodeID, method, request, response) |
| 219 | } |
| 220 | |
| 221 | func (bs *BusService) extractTxs(blocks *types.BPBlock, count uint32) { |
| 222 | for _, tx := range blocks.Transactions { |
no test coverage detected