From 93374a2eb1f418736bf9a83676543afc53c06cd3 Mon Sep 17 00:00:00 2001 From: wangwx <wangwx@tuya.com> Date: Thu, 25 Feb 2021 21:32:11 +0800 Subject: [PATCH] fix glint --- cluster/router/local/factory.go | 2 +- config_center/zookeeper/impl_test.go | 7 ------- 2 files changed, 1 insertion(+), 8 deletions(-) diff --git a/cluster/router/local/factory.go b/cluster/router/local/factory.go index 73864c8da..3724da733 100644 --- a/cluster/router/local/factory.go +++ b/cluster/router/local/factory.go @@ -38,6 +38,6 @@ func newLocalPriorityRouteFactory() router.PriorityRouterFactory { } // NewPriorityRouter construct a new NewLocalDiscRouter via url -func (f *LocalPriorityRouteFactory) NewPriorityRouter(url *common.URL) (router.PriorityRouter, error) { +func (f *LocalPriorityRouteFactory) NewPriorityRouter(url *common.URL, ch chan struct{}) (router.PriorityRouter, error) { return NewLocalPriorityRouter(url) } diff --git a/config_center/zookeeper/impl_test.go b/config_center/zookeeper/impl_test.go index 01adb7bb5..7f17153e2 100644 --- a/config_center/zookeeper/impl_test.go +++ b/config_center/zookeeper/impl_test.go @@ -120,11 +120,6 @@ func TestGetConfig(t *testing.T) { assert.Equal(t, "", configs) } -func printMap(key, value interface{}) bool { - fmt.Println(key, value) - return true -} - func TestAddListener(t *testing.T) { ts, reg := initZkData("", t) defer func() { @@ -132,11 +127,9 @@ func TestAddListener(t *testing.T) { err := ts.Stop() assert.NoError(t, err) }() - reg.cacheListener.keyListeners.Range(printMap) listener := &mockDataListener{} reg.AddListener(dubboPropertyFileName, listener) - reg.cacheListener.keyListeners.Range(printMap) listener.wg.Add(1) data := ` dubbo.consumer.request_timeout=3s -- GitLab