From 5b855cdd894c817e94065a16f22df48b6d512df6 Mon Sep 17 00:00:00 2001
From: pantianying <601666418@qq.com>
Date: Mon, 23 Sep 2019 14:04:04 +0800
Subject: [PATCH] fix problem
---
registry/directory/directory.go | 23 +++++++++++------------
1 file changed, 11 insertions(+), 12 deletions(-)
diff --git a/registry/directory/directory.go b/registry/directory/directory.go
index bc8b2f78c..7ffc70224 100644
--- a/registry/directory/directory.go
+++ b/registry/directory/directory.go
@@ -124,20 +124,19 @@ func (dir *registryDirectory) refreshInvokers(res *registry.ServiceEvent) {
url = nil
//TODO: router
}
+ switch res.Action {
+ case remoting.EventTypeAdd, remoting.EventTypeUpdate:
+ //dir.cacheService.EventTypeAdd(res.Path, dir.serviceTTL)
+ dir.cacheInvoker(url)
+ case remoting.EventTypeDel:
+ //dir.cacheService.EventTypeDel(res.Path, dir.serviceTTL)
+ dir.uncacheInvoker(url)
+ logger.Infof("selector delete service url{%s}", res.Service)
+ default:
+ return
+ }
}
- switch res.Action {
- case remoting.EventTypeAdd, remoting.EventTypeUpdate:
- //dir.cacheService.EventTypeAdd(res.Path, dir.serviceTTL)
- dir.cacheInvoker(&res.Service)
- case remoting.EventTypeDel:
- //dir.cacheService.EventTypeDel(res.Path, dir.serviceTTL)
- dir.uncacheInvoker(&res.Service)
- logger.Infof("selector delete service url{%s}", res.Service)
- default:
- return
- }
- dir.cacheInvoker(url)
newInvokers := dir.toGroupInvokers()
dir.listenerLock.Lock()
defer dir.listenerLock.Unlock()
--
GitLab