(q *QueryTracker)
| 76 | } |
| 77 | |
| 78 | func (p *pool) enqueueRead(q *QueryTracker) { |
| 79 | // NOTE(leventeliu): this overwrites any request with a same hash |
| 80 | p.reads[q.Req.Header.Hash()] = q |
| 81 | } |
| 82 | |
| 83 | func (p *pool) setFailed(req *types.Request) { |
| 84 | p.failed[req.Header.Hash()] = req |
no test coverage detected