diff --git a/common/proxy/proxy.go b/common/proxy/proxy.go index 43ca720d0e71577a446829f702c1d2fe23a32905..9d3f3f882156e1df61eac1adca67dec450964396 100644 --- a/common/proxy/proxy.go +++ b/common/proxy/proxy.go @@ -142,7 +142,7 @@ func (p *Proxy) Implement(v common.RPCService) { result := p.invoke.Invoke(invCtx, inv) err = result.Error() - logger.Infof("[makeDubboCallProxy] result: %v, err: %v", result.Result(), err) + logger.Debugf("[makeDubboCallProxy] result: %v, err: %v", result.Result(), err) if len(outs) == 1 { return []reflect.Value{reflect.ValueOf(&err).Elem()} } diff --git a/registry/directory/directory.go b/registry/directory/directory.go index 42d03e40bef4f078d9fd8e746119523d3d0725b2..2de34bcbe61114660aa4eb3482cdd67570f92d1b 100644 --- a/registry/directory/directory.go +++ b/registry/directory/directory.go @@ -128,10 +128,9 @@ func (dir *registryDirectory) refreshInvokers(res *registry.ServiceEvent) { } switch res.Action { case remoting.EventTypeAdd, remoting.EventTypeUpdate: - //dir.cacheService.EventTypeAdd(res.Path, dir.serviceTTL) + logger.Infof("selector add service url{%s}", res.Service) oldInvoker = dir.cacheInvoker(url) case remoting.EventTypeDel: - //dir.cacheService.EventTypeDel(res.Path, dir.serviceTTL) oldInvoker = dir.uncacheInvoker(url) logger.Infof("selector delete service url{%s}", res.Service) default: diff --git a/registry/zookeeper/listener.go b/registry/zookeeper/listener.go index 588e0c519288ed32a2453fac87d226b41d4a5194..fe8e42db9f39190e34142149a6b67c9638a84ed2 100644 --- a/registry/zookeeper/listener.go +++ b/registry/zookeeper/listener.go @@ -56,7 +56,7 @@ func (l *RegistryDataListener) DataChange(eventType remoting.Event) bool { // Intercept the last bit index := strings.Index(eventType.Path, "/providers/") if index == -1 { - logger.Warn("Listen with no url, event.path={%v}", eventType.Path) + logger.Warnf("Listen with no url, event.path={%v}", eventType.Path) return false } url := eventType.Path[index+len("/providers/"):]