sendReq2Validator sends a check request to the validators
(req *types.CheckTx)
| 229 | |
| 230 | // sendReq2Validator sends a check request to the validators |
| 231 | func (worker *txPoolWorker) sendReq2Validator(req *types.CheckTx) bool { |
| 232 | rspPid := worker.server.GetPID(tc.VerifyRspActor) |
| 233 | if rspPid == nil { |
| 234 | log.Info("sendReq2Validator: VerifyRspActor not exist") |
| 235 | return false |
| 236 | } |
| 237 | |
| 238 | pids := worker.server.getNextValidatorPIDs() |
| 239 | if pids == nil { |
| 240 | return false |
| 241 | } |
| 242 | for _, pid := range pids { |
| 243 | pid.Request(req, rspPid) |
| 244 | } |
| 245 | |
| 246 | return true |
| 247 | } |
| 248 | |
| 249 | // sendReq2StatefulV sends a check request to the stateful validator |
| 250 | func (worker *txPoolWorker) sendReq2StatefulV(req *types.CheckTx) { |
no test coverage detected