feat: add log for resolver and dynconfig (#2945)

Signed-off-by: Gaius <[email protected]>

internal/dynconfig/dynconfig.go

@@ -110,7 +110,7 @@ func (d *dynconfig[T]) Get() (*T, error) {
 func (d *dynconfig[T]) load() error {
 	// If another load is in progress, return directly.
 	if !d.mu.TryLock() {
-		return errors.New("another load is in progress")
+		return errors.New("load is running")
 	}
 	defer d.mu.Unlock()
 

pkg/resolver/scheduler_resolver.go

@@ -74,6 +74,7 @@ func (r *SchedulerResolver) Build(target resolver.Target, cc resolver.ClientConn
 func (r *SchedulerResolver) ResolveNow(resolver.ResolveNowOptions) {
 	// Avoid concurrent GetResolveSchedulerAddrs calls.
 	if !r.mu.TryLock() {
+		plogger.Warning("resolve addresses is running")
 		return
 	}
 	defer r.mu.Unlock()
@@ -94,6 +95,8 @@ func (r *SchedulerResolver) ResolveNow(resolver.ResolveNowOptions) {
 	}); err != nil {
 		plogger.Errorf("resolver update ClientConn error %v", err)
 	}
+
+	plogger.Infof("resolve addresses %v", addrs)
 }
 
 // Close closes the resolver.

pkg/resolver/seed_peer_resolver.go

@@ -75,6 +75,7 @@ func (r *SeedPeerResolver) Build(target resolver.Target, cc resolver.ClientConn,
 func (r *SeedPeerResolver) ResolveNow(resolver.ResolveNowOptions) {
 	// Avoid concurrent GetResolveSeedPeerAddrs calls.
 	if !r.mu.TryLock() {
+		slogger.Warning("resolve addresses is running")
 		return
 	}
 	defer r.mu.Unlock()
@@ -95,6 +96,8 @@ func (r *SeedPeerResolver) ResolveNow(resolver.ResolveNowOptions) {
 	}); err != nil {
 		slogger.Errorf("resolver update ClientConn error %v", err)
 	}
+
+	slogger.Infof("resolve addresses %v", addrs)
 }
 
 // Close closes the resolver.

pkg/rpc/interceptor.go

@@ -27,6 +27,7 @@ import (
 	"google.golang.org/grpc/status"
 
 	"d7y.io/dragonfly/v2/internal/dferrors"
+	logger "d7y.io/dragonfly/v2/internal/dflog"
 )
 
 var (
@@ -73,6 +74,8 @@ func RefresherUnaryClientInterceptor(r Refresher) grpc.UnaryClientInterceptor {
 		err := invoker(ctx, method, req, reply, cc, opts...)
 		if s, ok := status.FromError(err); ok {
 			if s.Code() == codes.ResourceExhausted || s.Code() == codes.Unavailable {
+				logger.Errorf("refresh dynconfig addresses when unary client calling error: %s %#v %v", method, req, err)
+
 				// nolint
 				r.Refresh()
 			}
@@ -88,6 +91,8 @@ func RefresherStreamClientInterceptor(r Refresher) grpc.StreamClientInterceptor
 		clientStream, err := streamer(ctx, desc, cc, method, opts...)
 		if s, ok := status.FromError(err); ok {
 			if s.Code() == codes.ResourceExhausted || s.Code() == codes.Unavailable {
+				logger.Errorf("refresh dynconfig addresses when stream clinet calling error: %s %v", method, err)
+
 				// nolint
 				r.Refresh()
 			}

scheduler/config/dynconfig.go

@@ -319,6 +319,7 @@ func (d *dynconfig) GetSchedulerClusterClientConfig() (types.SchedulerClusterCli
 func (d *dynconfig) Refresh() error {
 	// If another load is in progress, return directly.
 	if !d.mu.TryLock() {
+		logger.Warn("refresh is running")
 		return nil
 	}
 	defer d.mu.Unlock()