()
| 1363 | } |
| 1364 | |
| 1365 | func (q *querier) resyncPeerMappings() { |
| 1366 | q.mu.Lock() |
| 1367 | defer q.mu.Unlock() |
| 1368 | keys := make([]mKey, 0, len(q.mappers)) |
| 1369 | for mk := range q.mappers { |
| 1370 | keys = append(keys, mk) |
| 1371 | } |
| 1372 | q.mappingQ.enqueue(keys...) |
| 1373 | } |
| 1374 | |
| 1375 | func (q *querier) handleUpdates() { |
| 1376 | defer q.wg.Done() |
no test coverage detected