Method Query

net/dns/manager.go:481–505

Query executes a DNS query received from the given address. The query is provided in bs as a wire-encoded DNS query without any transport header. This method is called for requests arriving over UDP and TCP. The "family" parameter should indicate what type of DNS query this is: either "tcp" or "udp

(ctx context.Context, bs []byte, family string, from netip.AddrPort)

// The "family" parameter should indicate what type of DNS query this is:
// either "tcp" or "udp".
func (m *Manager) Query(ctx context.Context, bs []byte, family string, from netip.AddrPort) ([]byte, error) {
	select {
	case <-m.ctx.Done():
		return nil, net.ErrClosed
	default:
		// continue
	}

	if n := atomic.AddInt32(&m.activeQueriesAtomic, 1); n > maxActiveQueries {
		atomic.AddInt32(&m.activeQueriesAtomic, -1)
		metricDNSQueryErrorQueue.Add(1)
		return nil, errFullQueue
	}
	defer atomic.AddInt32(&m.activeQueriesAtomic, -1)
	outbs, err := m.resolver.Query(ctx, bs, family, from)
	if err != nil {
		return outbs, err
	}
	m.mu.Lock()
	defer m.mu.Unlock()
	if m.queryResponseMapper != nil {
		outbs = m.queryResponseMapper(outbs)
	}
	return outbs, err
}

const (
	// RFC 7766 6.2 recommends connection reuse & request pipelining