()
| 59 | } |
| 60 | |
| 61 | func newPool() *pool { |
| 62 | return &pool{ |
| 63 | failed: make(map[hash.Hash]*types.Request), |
| 64 | reads: make(map[hash.Hash]*QueryTracker), |
| 65 | queries: make([]*QueryTracker, 0), |
| 66 | index: make(map[uint64]int), |
| 67 | } |
| 68 | } |
| 69 | |
| 70 | func (p *pool) enqueue(sp uint64, q *QueryTracker) { |
| 71 | var pos = len(p.queries) |
no outgoing calls
no test coverage detected