(conn ziface.IConnection)
| 222 | } |
| 223 | |
| 224 | func (s *Server) StartConn(conn ziface.IConnection) { |
| 225 | // HeartBeat check |
| 226 | if s.hc != nil { |
| 227 | // Clone a heart-beat checker from the server side |
| 228 | heartBeatChecker := s.hc.Clone() |
| 229 | |
| 230 | // Bind current connection |
| 231 | heartBeatChecker.BindConn(conn) |
| 232 | } |
| 233 | |
| 234 | // Start processing business for the current connection |
| 235 | conn.Start() |
| 236 | } |
| 237 | |
| 238 | func (s *Server) ListenTcpConn() { |
| 239 | zlog.Ins().InfoF("[START] TCP Server name: %s,listener at IP: %s, Port %d is starting", s.Name, s.IP, s.Port) |
no test coverage detected