(sp uint64, q *QueryTracker)
| 68 | } |
| 69 | |
| 70 | func (p *pool) enqueue(sp uint64, q *QueryTracker) { |
| 71 | var pos = len(p.queries) |
| 72 | p.queries = append(p.queries, q) |
| 73 | p.index[sp] = pos |
| 74 | atomic.StoreInt32(&p.trackerCount, int32(len(p.queries))) |
| 75 | return |
| 76 | } |
| 77 | |
| 78 | func (p *pool) enqueueRead(q *QueryTracker) { |
| 79 | // NOTE(leventeliu): this overwrites any request with a same hash |
no outgoing calls
no test coverage detected