()
| 945 | } |
| 946 | |
| 947 | func (q *querier) handleIncoming() { |
| 948 | defer q.wg.Done() |
| 949 | for { |
| 950 | select { |
| 951 | case <-q.ctx.Done(): |
| 952 | return |
| 953 | |
| 954 | case c := <-q.newConnections: |
| 955 | q.logger.Debug(q.ctx, "new connection received", slog.F("peer_id", c.UniqueID())) |
| 956 | q.newConn(c) |
| 957 | |
| 958 | case c := <-q.closeConnections: |
| 959 | q.logger.Debug(q.ctx, "connection close request", slog.F("peer_id", c.UniqueID())) |
| 960 | q.cleanupConn(c) |
| 961 | } |
| 962 | } |
| 963 | } |
| 964 | |
| 965 | func (q *querier) newConn(c *connIO) { |
| 966 | q.mu.Lock() |
no test coverage detected