Skip to content

Commit 494507d

Browse files
committed
debug: add log for debug discovery
1 parent f59eb7f commit 494507d

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

pkg/loadbalance/lbcache/cache.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -163,9 +163,9 @@ func (b *BalancerFactory) Get(ctx context.Context, target rpcinfo.EndpointInfo)
163163
return val.(*Balancer), nil
164164
}
165165
val, err, _ := b.sfg.Do(desc, func() (interface{}, error) {
166-
klog.CtxErrorf(ctx, "KITEX-DEBUG: start Resolve")
166+
klog.CtxErrorf(ctx, "KITEX-DEBUG: start Resolve, desc=%s", desc)
167167
res, err := b.resolver.Resolve(ctx, desc)
168-
klog.CtxErrorf(ctx, "KITEX-DEBUG: end Resolve")
168+
klog.CtxErrorf(ctx, "KITEX-DEBUG: end Resolve, desc=%s", desc)
169169
if err != nil {
170170
return nil, err
171171
}
@@ -179,6 +179,7 @@ func (b *BalancerFactory) Get(ctx context.Context, target rpcinfo.EndpointInfo)
179179
bl.sharedTicker = getSharedTicker(bl, b.opts.RefreshInterval)
180180
klog.CtxErrorf(ctx, "KITEX-DEBUG: end getSharedTicker")
181181
b.cache.Store(desc, bl)
182+
klog.CtxErrorf(ctx, "KITEX-DEBUG: put balancer[desc=%s] into cache", desc)
182183
return bl, nil
183184
})
184185
if err != nil {

0 commit comments

Comments
 (0)