(req *types.Request)
| 81 | } |
| 82 | |
| 83 | func (p *pool) setFailed(req *types.Request) { |
| 84 | p.failed[req.Header.Hash()] = req |
| 85 | atomic.StoreInt32(&p.failedRequestCount, int32(len(p.failed))) |
| 86 | } |
| 87 | |
| 88 | func (p *pool) failedList() (reqs []*types.Request) { |
| 89 | reqs = make([]*types.Request, 0, len(p.failed)) |
no test coverage detected