Method serveClient

proxy/server.go:127–183

(clientconn *ClientConn)

}

func (s *Server) serveClient(clientconn *ClientConn) error {

	loggo.Info("serveClient accept new client %s", clientconn.conn.Info())

	sendch := common.NewChannel(s.config.MainBuffer)
	recvch := common.NewChannel(s.config.MainBuffer)

	clientconn.sendch = sendch
	clientconn.recvch = recvch

	wg := thread.NewGroup("Server serveClient"+" "+clientconn.conn.Info(), s.wg, func() {
		loggo.Info("group start exit %s", clientconn.conn.Info())
		clientconn.conn.Close()
		sendch.Close()
		recvch.Close()
		if clientconn.input != nil {
			clientconn.input.Close()
		}
		if clientconn.output != nil {
			clientconn.output.Close()
		}
		loggo.Info("group end exit %s", clientconn.conn.Info())
	})

	var pingflag int32
	var pongflag int32
	var pongtime int64

	wg.Go("Server recvFrom"+" "+clientconn.conn.Info(), func() error {
		return recvFrom(wg, recvch, clientconn.conn, s.config.MaxMsgSize, s.config.Encrypt)
	})

	wg.Go("Server sendTo"+" "+clientconn.conn.Info(), func() error {
		return sendTo(wg, sendch, clientconn.conn, s.config.Compress, s.config.MaxMsgSize, s.config.Encrypt, &pingflag, &pongflag, &pongtime)
	})

	wg.Go("Server checkPingActive"+" "+clientconn.conn.Info(), func() error {
		return checkPingActive(wg, sendch, recvch, &clientconn.ProxyConn, s.config.EstablishedTimeout, s.config.PingInter, s.config.PingTimeoutInter, s.config.ShowPing, &pingflag)
	})

	wg.Go("Server checkNeedClose"+" "+clientconn.conn.Info(), func() error {
		return checkNeedClose(wg, &clientconn.ProxyConn)
	})

	wg.Go("Server process"+" "+clientconn.conn.Info(), func() error {
		return s.process(wg, sendch, recvch, clientconn, &pongflag, &pongtime)
	})

	wg.Wait()
	if clientconn.established {
		s.clients.Delete(clientconn.name)
	}

	loggo.Info("serveClient close client %s", clientconn.conn.Info())

	return nil
}