53 references to SendQueryError
Microsoft.Extensions.ServiceDiscovery.Dns (53)
Resolver\DnsResolver.cs (51)
74
static (
SendQueryError
, ServiceResult[]) ProcessResponse(EncodedDomainName dnsSafeName, QueryType queryType, DnsResponse response)
84
return (
SendQueryError
.MalformedResponse, []);
112
return (
SendQueryError
.NoError, results.ToArray());
155
static (
SendQueryError
error, AddressResult[] result) ProcessResponse(EncodedDomainName dnsSafeName, QueryType queryType, DnsResponse response)
181
return (
SendQueryError
.MalformedResponse, []);
195
return (
SendQueryError
.MalformedResponse, []);
215
return (
SendQueryError
.NoError, results.ToArray());
229
return (
SendQueryError
.MalformedResponse, []);
235
return (
SendQueryError
.MalformedResponse, []);
243
return (
SendQueryError
.MalformedResponse, []);
264
return (
SendQueryError
.MalformedResponse, []);
272
return (
SendQueryError
.MalformedResponse, []);
280
return (
SendQueryError
.NoError, finalAddressList?.ToArray() ?? []);
359
private async ValueTask<TResult[]> SendQueryWithTelemetry<TResult>(string name, EncodedDomainName dnsSafeName, QueryType queryType, Func<EncodedDomainName, QueryType, DnsResponse, (
SendQueryError
error, TResult[] result)> processResponseFunc, CancellationToken cancellationToken)
362
(
SendQueryError
error, TResult[] result) = await SendQueryWithRetriesAsync(name, dnsSafeName, queryType, processResponseFunc, cancellationToken).ConfigureAwait(false);
372
public
SendQueryError
Error;
375
async ValueTask<(
SendQueryError
error, TResult[] result)> SendQueryWithRetriesAsync<TResult>(string name, EncodedDomainName dnsSafeName, QueryType queryType, Func<EncodedDomainName, QueryType, DnsResponse, (
SendQueryError
error, TResult[] result)> processResponseFunc, CancellationToken cancellationToken)
377
SendQueryError
lastError =
SendQueryError
.InternalError; // will be overwritten by the first attempt
395
if (lastError ==
SendQueryError
.NoError)
405
lastError =
SendQueryError
.NetworkError;
419
case
SendQueryError
.NoError:
422
case
SendQueryError
.NameError:
427
case
SendQueryError
.NoData:
435
case
SendQueryError
.Timeout:
439
case
SendQueryError
.NetworkError:
443
case
SendQueryError
.ServerError when response.Header.ResponseCode == QueryResponseCode.ServerFailure:
451
case
SendQueryError
.ServerError:
457
case
SendQueryError
.MalformedResponse:
461
case
SendQueryError
.InternalError:
494
return new SendQueryResult { Error =
SendQueryError
.Timeout };
516
SendQueryError
sendError =
SendQueryError
.NoError;
541
if (sendError !=
SendQueryError
.NoError)
553
Error =
SendQueryError
.MalformedResponse
566
Error =
SendQueryError
.MalformedResponse
580
Error =
SendQueryError
.MalformedResponse
587
SendQueryError
validationError = ValidateResponse(header.ResponseCode, queryStartedTime, answers, authorities, ref expirationTime);
649
internal static
SendQueryError
ValidateResponse(QueryResponseCode responseCode, DateTime createdAt, List<DnsResourceRecord> answers, List<DnsResourceRecord> authorities, ref DateTime expiration)
655
return
SendQueryError
.NoError;
677
return
SendQueryError
.NoData;
696
return
SendQueryError
.NameError;
699
return
SendQueryError
.ServerError;
702
internal static (DnsDataReader reader, DnsMessageHeader header,
SendQueryError
sendError) SendDnsQueryCustomTransport(Func<Memory<byte>, int, int> callback, EncodedDomainName dnsSafeName, QueryType queryType)
716
return (default, default,
SendQueryError
.MalformedResponse);
721
return (responseReader, header,
SendQueryError
.NoError);
781
internal static async ValueTask<(DnsDataReader reader, DnsMessageHeader header,
SendQueryError
error)> SendDnsQueryCoreTcpAsync(IPEndPoint serverEndPoint, EncodedDomainName dnsSafeName, QueryType queryType, CancellationToken cancellationToken)
804
return (default, default,
SendQueryError
.MalformedResponse);
829
return (default, default,
SendQueryError
.MalformedResponse);
834
return (responseReader, header,
SendQueryError
.NoError);
Resolver\DnsResolver.Telemetry.cs (2)
28
public static void StopNameResolution(string hostName, QueryType queryType, in NameResolutionActivity activity, object? answers,
SendQueryError
error, long endingTimestamp)
76
public void Stop(object? answers,
SendQueryError
error, long endingTimestamp, out TimeSpan duration)