Improve resolver failing reporting
This commit is contained in:
@@ -145,10 +145,16 @@ func (tr *TCPResolver) getOrCreateResolverConn(ctx context.Context) (*tcpResolve
|
|||||||
// Connect to server.
|
// Connect to server.
|
||||||
conn, err := tr.dnsClient.Dial(tr.resolver.ServerAddress)
|
conn, err := tr.dnsClient.Dial(tr.resolver.ServerAddress)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Debugf("resolver: failed to connect to %s", tr.resolver.Info.DescriptiveName())
|
// Hint network environment at failed connection.
|
||||||
|
netenv.ReportFailedConnection()
|
||||||
|
|
||||||
|
log.Debugf("resolver: failed to connect to %s: %s", tr.resolver.Info.DescriptiveName(), err)
|
||||||
return nil, fmt.Errorf("%w: failed to connect to %s: %s", ErrFailure, tr.resolver.Info.DescriptiveName(), err)
|
return nil, fmt.Errorf("%w: failed to connect to %s: %s", ErrFailure, tr.resolver.Info.DescriptiveName(), err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Hint network environment at successful connection.
|
||||||
|
netenv.ReportSuccessfulConnection()
|
||||||
|
|
||||||
// Log that a connection to the resolver was established.
|
// Log that a connection to the resolver was established.
|
||||||
log.Debugf(
|
log.Debugf(
|
||||||
"resolver: connected to %s",
|
"resolver: connected to %s",
|
||||||
@@ -174,9 +180,6 @@ func (tr *TCPResolver) getOrCreateResolverConn(ctx context.Context) (*tcpResolve
|
|||||||
// Set resolver conn for reuse.
|
// Set resolver conn for reuse.
|
||||||
tr.resolverConn = resolverConn
|
tr.resolverConn = resolverConn
|
||||||
|
|
||||||
// Hint network environment at successful connection.
|
|
||||||
netenv.ReportSuccessfulConnection()
|
|
||||||
|
|
||||||
return resolverConn, nil
|
return resolverConn, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user