diff --git a/libs/rpc/client.go b/libs/rpc/client.go index 74f84f18..8bd6328d 100644 --- 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() }