修复删除client时server卡死

iwannay · Jul 31, 2018 · 5b9f922 · 5b9f922
1 parent b339659
commit 5b9f922
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/libs/rpc/client.go b/libs/rpc/client.go
@@ -36,6 +36,7 @@ func Dial(options ClientOptions) (c *Client) {
 	c = &Client{}
 	c.options = options
 	c.dial()
+	c.quit = make(chan struct{}, 100)
 	return c
 }
 
@@ -97,6 +98,7 @@ func (c *Client) Ping(serviceMethod string) {
 		time.Sleep(pingDuration)
 	}
 closed:
+	log.Println("rpc quited", c.options.Addr)
 	if c.Client != nil {
 		c.Client.Close()
 	}