53 references to SendQueryError
Microsoft.Extensions.ServiceDiscovery.Dns (53)
Resolver\DnsResolver.cs (51)
70static (SendQueryError, ServiceResult[]) ProcessResponse(EncodedDomainName dnsSafeName, QueryType queryType, DnsResponse response) 80return (SendQueryError.MalformedResponse, []); 108return (SendQueryError.NoError, results.ToArray()); 176static (SendQueryError error, AddressResult[] result) ProcessResponse(EncodedDomainName dnsSafeName, QueryType queryType, DnsResponse response) 202return (SendQueryError.MalformedResponse, []); 216return (SendQueryError.MalformedResponse, []); 236return (SendQueryError.NoError, results.ToArray()); 250return (SendQueryError.MalformedResponse, []); 256return (SendQueryError.MalformedResponse, []); 264return (SendQueryError.MalformedResponse, []); 285return (SendQueryError.MalformedResponse, []); 293return (SendQueryError.MalformedResponse, []); 301return (SendQueryError.NoError, finalAddressList?.ToArray() ?? []); 345private async ValueTask<TResult[]> SendQueryWithTelemetry<TResult>(string name, EncodedDomainName dnsSafeName, QueryType queryType, Func<EncodedDomainName, QueryType, DnsResponse, (SendQueryError error, TResult[] result)> processResponseFunc, CancellationToken cancellationToken) 348(SendQueryError error, TResult[] result) = await SendQueryWithRetriesAsync(name, dnsSafeName, queryType, processResponseFunc, cancellationToken).ConfigureAwait(false); 358public SendQueryError Error; 361async ValueTask<(SendQueryError error, TResult[] result)> SendQueryWithRetriesAsync<TResult>(string name, EncodedDomainName dnsSafeName, QueryType queryType, Func<EncodedDomainName, QueryType, DnsResponse, (SendQueryError error, TResult[] result)> processResponseFunc, CancellationToken cancellationToken) 363SendQueryError lastError = SendQueryError.InternalError; // will be overwritten by the first attempt 381if (lastError == SendQueryError.NoError) 391lastError = SendQueryError.NetworkError; 405case SendQueryError.NoError: 408case SendQueryError.NameError: 413case SendQueryError.NoData: 421case SendQueryError.Timeout: 425case SendQueryError.NetworkError: 429case SendQueryError.ServerError when response.Header.ResponseCode == QueryResponseCode.ServerFailure: 437case SendQueryError.ServerError: 443case SendQueryError.MalformedResponse: 447case SendQueryError.InternalError: 480return new SendQueryResult { Error = SendQueryError.Timeout }; 502SendQueryError sendError = SendQueryError.NoError; 527if (sendError != SendQueryError.NoError) 539Error = SendQueryError.MalformedResponse 552Error = SendQueryError.MalformedResponse 566Error = SendQueryError.MalformedResponse 573SendQueryError validationError = ValidateResponse(header.ResponseCode, queryStartedTime, answers, authorities, ref expirationTime); 635internal static SendQueryError ValidateResponse(QueryResponseCode responseCode, DateTime createdAt, List<DnsResourceRecord> answers, List<DnsResourceRecord> authorities, ref DateTime expiration) 641return SendQueryError.NoError; 663return SendQueryError.NoData; 682return SendQueryError.NameError; 685return SendQueryError.ServerError; 688internal static (DnsDataReader reader, DnsMessageHeader header, SendQueryError sendError) SendDnsQueryCustomTransport(Func<Memory<byte>, int, int> callback, EncodedDomainName dnsSafeName, QueryType queryType) 702return (default, default, SendQueryError.MalformedResponse); 707return (responseReader, header, SendQueryError.NoError); 767internal static async ValueTask<(DnsDataReader reader, DnsMessageHeader header, SendQueryError error)> SendDnsQueryCoreTcpAsync(IPEndPoint serverEndPoint, EncodedDomainName dnsSafeName, QueryType queryType, CancellationToken cancellationToken) 790return (default, default, SendQueryError.MalformedResponse); 815return (default, default, SendQueryError.MalformedResponse); 820return (responseReader, header, SendQueryError.NoError);
Resolver\DnsResolver.Telemetry.cs (2)
28public static void StopNameResolution(string hostName, QueryType queryType, in NameResolutionActivity activity, object? answers, SendQueryError error, long endingTimestamp) 76public void Stop(object? answers, SendQueryError error, long endingTimestamp, out TimeSpan duration)