Function AddTcpServerMgr

einx_default.go:49–63

(m module.Module, addr string, mgr interface{}, opts ...Option)

}

func AddTcpServerMgr(m module.Module, addr string, mgr interface{}, opts ...Option) {
	m_eventer := m.(event.EventReceiver)

	opts = append(opts, NetworkOption.ListenAddr(addr))
	opts = append(opts, network.Module(m_eventer))
	opts = append(opts, NetworkOption.ServeHandler(mgr.(SessionHandler)))

	tcp_server := network.NewTcpServerMgr(opts...)

	e := &event.ComponentEventMsg{}
	e.MsgType = event.EVENT_COMPONENT_CREATE
	e.Sender = tcp_server
	e.Attach = mgr
	m_eventer.PushEventMsg(e)
}

func StartTcpClientMgr(m module.Module, name string, mgr interface{}, opts ...Option) {
	m_eventer := m.(event.EventReceiver)