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