close

gongshangguo

2022-03-02 9a387796f8d8b3ca0da5c3d68aacce7134393250

 client/client.go

@@ -455,7 +455,7 @@

// 关闭TCP
func (c *Client) Close() {
   c.Logger.Debug("Closing connect", zap.String("addr", c.addr))
   c.Logger.Debug("Closing connect...", zap.String("addr", c.addr))
   c.closeLock.Lock()
   defer c.closeLock.Unlock()
   // 关闭通道
@@ -464,8 +464,9 @@
      if c.IsConnected() {
         c.clientCallback.OnClose(c)
      }

      // 设置连接属性
      c.SetState(StateDisconnected)
   }

   // 设置连接属性
   c.SetState(StateDisconnected)
   c.Logger.Debug("Connect closed...", zap.String("addr", c.addr))
}