53 references to SendQueryError
Microsoft.Extensions.ServiceDiscovery.Dns (53)
Resolver\DnsResolver.cs (51)
68static (SendQueryError, ServiceResult[]) ProcessResponse(EncodedDomainName dnsSafeName, QueryType queryType, DnsResponse response) 78return (SendQueryError.MalformedResponse, []); 106return (SendQueryError.NoError, results.ToArray()); 174static (SendQueryError error, AddressResult[] result) ProcessResponse(EncodedDomainName dnsSafeName, QueryType queryType, DnsResponse response) 200return (SendQueryError.MalformedResponse, []); 214return (SendQueryError.MalformedResponse, []); 234return (SendQueryError.NoError, results.ToArray()); 248return (SendQueryError.MalformedResponse, []); 254return (SendQueryError.MalformedResponse, []); 262return (SendQueryError.MalformedResponse, []); 283return (SendQueryError.MalformedResponse, []); 291return (SendQueryError.MalformedResponse, []); 299return (SendQueryError.NoError, finalAddressList?.ToArray() ?? []); 343private async ValueTask<TResult[]> SendQueryWithTelemetry<TResult>(string name, EncodedDomainName dnsSafeName, QueryType queryType, Func<EncodedDomainName, QueryType, DnsResponse, (SendQueryError error, TResult[] result)> processResponseFunc, CancellationToken cancellationToken) 346(SendQueryError error, TResult[] result) = await SendQueryWithRetriesAsync(name, dnsSafeName, queryType, processResponseFunc, cancellationToken).ConfigureAwait(false); 356public SendQueryError Error; 359async ValueTask<(SendQueryError error, TResult[] result)> SendQueryWithRetriesAsync<TResult>(string name, EncodedDomainName dnsSafeName, QueryType queryType, Func<EncodedDomainName, QueryType, DnsResponse, (SendQueryError error, TResult[] result)> processResponseFunc, CancellationToken cancellationToken) 361SendQueryError lastError = SendQueryError.InternalError; // will be overwritten by the first attempt 379if (lastError == SendQueryError.NoError) 389lastError = SendQueryError.NetworkError; 403case SendQueryError.NoError: 406case SendQueryError.NameError: 411case SendQueryError.NoData: 419case SendQueryError.Timeout: 423case SendQueryError.NetworkError: 427case SendQueryError.ServerError when response.Header.ResponseCode == QueryResponseCode.ServerFailure: 435case SendQueryError.ServerError: 441case SendQueryError.MalformedResponse: 445case SendQueryError.InternalError: 478return new SendQueryResult { Error = SendQueryError.Timeout }; 500SendQueryError sendError = SendQueryError.NoError; 525if (sendError != SendQueryError.NoError) 537Error = SendQueryError.MalformedResponse 550Error = SendQueryError.MalformedResponse 564Error = SendQueryError.MalformedResponse 571SendQueryError validationError = ValidateResponse(header.ResponseCode, queryStartedTime, answers, authorities, ref expirationTime); 633internal static SendQueryError ValidateResponse(QueryResponseCode responseCode, DateTime createdAt, List<DnsResourceRecord> answers, List<DnsResourceRecord> authorities, ref DateTime expiration) 639return SendQueryError.NoError; 661return SendQueryError.NoData; 680return SendQueryError.NameError; 683return SendQueryError.ServerError; 686internal static (DnsDataReader reader, DnsMessageHeader header, SendQueryError sendError) SendDnsQueryCustomTransport(Func<Memory<byte>, int, int> callback, EncodedDomainName dnsSafeName, QueryType queryType) 700return (default, default, SendQueryError.MalformedResponse); 705return (responseReader, header, SendQueryError.NoError); 765internal static async ValueTask<(DnsDataReader reader, DnsMessageHeader header, SendQueryError error)> SendDnsQueryCoreTcpAsync(IPEndPoint serverEndPoint, EncodedDomainName dnsSafeName, QueryType queryType, CancellationToken cancellationToken) 788return (default, default, SendQueryError.MalformedResponse); 813return (default, default, SendQueryError.MalformedResponse); 818return (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)