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