diff --git a/registry/etcdv3/listener_test.go b/registry/etcdv3/listener_test.go index 4a805c31c3b229934b041a2588ea7e88c7126b94..56564736465c733ec13d9d18e02bd01bb12e8698 100644 --- a/registry/etcdv3/listener_test.go +++ b/registry/etcdv3/listener_test.go @@ -11,39 +11,36 @@ import ( "github.com/apache/dubbo-go/remoting" ) +func startETCDServer(t *testing.T) { -func startETCDServer(t *testing.T){ - - cmd := exec.Command("./load.sh", "start") + cmd := exec.Command("./load.sh", "start") //cmd := exec.Command("pwd") - cmd.Stdout= os.Stdout + cmd.Stdout = os.Stdout cmd.Stderr = os.Stdout cmd.Dir = "../../remoting/etcdv3/single" - if err := cmd.Run(); err != nil{ + if err := cmd.Run(); err != nil { t.Fatal(err) } } -func stopETCDServer(t *testing.T){ +func stopETCDServer(t *testing.T) { - cmd := exec.Command("./load.sh", "stop") + cmd := exec.Command("./load.sh", "stop") //cmd := exec.Command("pwd") - cmd.Stdout= os.Stdout + cmd.Stdout = os.Stdout cmd.Stderr = os.Stdout cmd.Dir = "../../remoting/etcdv3/single" - if err := cmd.Run(); err != nil{ + if err := cmd.Run(); err != nil { t.Fatal(err) } } - func Test_DataChange(t *testing.T) { - startETCDServer(t) defer stopETCDServer(t) diff --git a/registry/etcdv3/registry.go b/registry/etcdv3/registry.go index 89dbe313510f427dd8f7e0bb91f47d5236c77d21..f6424a6a0e65daad7fb7f9d04c046aeac9d1f374 100644 --- a/registry/etcdv3/registry.go +++ b/registry/etcdv3/registry.go @@ -157,7 +157,6 @@ func (r *etcdV3Registry) stop() { // close current client r.client.Close() - r.cltLock.Lock() r.client = nil r.services = nil diff --git a/registry/etcdv3/registry_test.go b/registry/etcdv3/registry_test.go index 7c69f4d31e8ba68f11b2f7f16aa32590ec3c4aa8..81a8e0ddb6c4e86a7b769c3234be2c27991230a2 100644 --- a/registry/etcdv3/registry_test.go +++ b/registry/etcdv3/registry_test.go @@ -105,7 +105,6 @@ func Test_ConsumerDestory(t *testing.T) { func Test_ProviderDestory(t *testing.T) { - startETCDServer(t) defer stopETCDServer(t) @@ -118,5 +117,3 @@ func Test_ProviderDestory(t *testing.T) { reg.Destroy() assert.Equal(t, false, reg.IsAvailable()) } - - diff --git a/remoting/etcdv3/client_test.go b/remoting/etcdv3/client_test.go index f3b44797ed81d495e713f9900b87c021f9f60c4c..3d586a8bb2955d61f7dde9a5bdd73db066b93a51 100644 --- a/remoting/etcdv3/client_test.go +++ b/remoting/etcdv3/client_test.go @@ -61,25 +61,25 @@ func initClient(t *testing.T) *Client { return c } -func startETCDServer(t *testing.T){ +func startETCDServer(t *testing.T) { - cmd := exec.Command("./load.sh", "start") - cmd.Stdout= os.Stdout + cmd := exec.Command("./load.sh", "start") + cmd.Stdout = os.Stdout cmd.Stderr = os.Stdout cmd.Dir = "./single" - if err := cmd.Run(); err != nil{ + if err := cmd.Run(); err != nil { t.Fatal(err) } } -func stopETCDServer(t *testing.T){ - cmd := exec.Command("./load.sh", "stop") - cmd.Stdout= os.Stdout +func stopETCDServer(t *testing.T) { + cmd := exec.Command("./load.sh", "stop") + cmd.Stdout = os.Stdout cmd.Stderr = os.Stdout cmd.Dir = "./single" - if err := cmd.Run(); err != nil{ + if err := cmd.Run(); err != nil { t.Fatal(err) } @@ -343,7 +343,6 @@ func TestClient_Valid(t *testing.T) { func TestClient_Done(t *testing.T) { - startETCDServer(t) defer stopETCDServer(t) diff --git a/remoting/etcdv3/listener_test.go b/remoting/etcdv3/listener_test.go index 93f3d225a7cfa77b4d46c19b575d2ea2a7bb15e5..4dd6e7f318a978dc610784bc15c4be6d82ef60ed 100644 --- a/remoting/etcdv3/listener_test.go +++ b/remoting/etcdv3/listener_test.go @@ -85,4 +85,3 @@ func (m *mockDataListener) DataChange(eventType remoting.Event) bool { } return true } -