sess

type INetServer interface {
	//主要给INetSess调用的方法，也可以重载
	ISessCallBack

	// //开始服务
	// Start() (err error)
	// //结束服务
	// Stop()
	// 遍历所有被动连接，返回false就退出遍历
	RangeSess(f func(sess INetSess) bool)
	// 获取会话
	GetClientSess(id uint64) (result *NetSess)
	//是否加密
	GetEncryEnabled() bool
	//连接类型
	GetProtocal() ProtocalEnum
}

type INetSess interface {

	//发消息
	Send(msg msgdef.IMsg)
	//发消息二进制数据
	SendBuf(data []byte)
	//立即发送
	SendNow(msg msgdef.IMsg)
	//开始
	Start()
	//关闭 只会被运行一次
	Close()
	// 延时关闭连接
	DelayClose()

	//设置消息路由
	//一开始使用的都是service的，验证过后
	//如果是用户就换成用户的
	//剩下的还是使用service的
	SetMsgHandler(msgh msghandler.IMsgHandler)
	//设置表示连接的ID，一般与上层的服务器ID或是用户ID一致
	SetID(uint64)
	//表示连接的ID，一般与上层的服务器ID或是用户ID一致
	GetID() uint64
	//如果连接是服务器过来的话，那就是服务器类型，2表示客户端
	GetType() global.ServerTypeEnum
	//设置如果连接是服务器过来的话，那就是服务器类型，2表示客户端
	SetType(stype global.ServerTypeEnum)
	//远程地址
	RemoteAddr() string
	//是否验证过
	IsVerified() bool
	//设置验证过
	SetVerify()
	// 设置是否输出 发出的消息
	SetInputMsg(v bool)
	// 设置是否输出 收到的消息
	SetRecvMsg(v bool)
}

type ISessCallBack interface {
	//连接被关闭的时候(这个回调会在任意协程上，所以需要注意安全)
	SessClosed(sess INetSess)
	//会话的验证回调 如果是连接客户端的上层需要重载实现验证逻辑，失败就返回错误，底层会关闭连接
	SessVerify(msg msgdef.ISessionVerifyReqMsg, sess INetSess) error
	//连接类型
	GetProtocal() ProtocalEnum
}

type IkcpSession interface {
	// SetStreamMode toggles the stream mode on/off
	SetStreamMode(enable bool)
	// SetWindowSize set maximum window size
	SetWindowSize(sndwnd, rcvwnd int)

	// SetNoDelay calls nodelay() of kcp
	// https://github.com/skywind3000/kcp/blob/master/README.en.md#protocol-configuration
	SetNoDelay(nodelay, interval, resend, nc int)
	// SetDSCP sets the 6bit DSCP field in IPv4 header, or 8bit Traffic Class in IPv6 header.
	//
	// if the underlying connection has implemented `func SetDSCP(int) error`, SetDSCP() will invoke
	// this function instead.
	//
	// It has no effect if it's accepted from Listener.
	SetDSCP(dscp int) error
	// SetMtu sets the maximum transmission unit(not including UDP header)
	SetMtu(mtu int) bool
	// SetACKNoDelay changes ack flush option, set true to flush ack immediately,
	SetACKNoDelay(nodelay bool)
}

type NetSess struct {
	// contains filtered or unexported fields
}

type NetSrv struct {
	*msghandler.MsgHandler

	//监听地址
	ListenAddr string

	// 服务器配置
	Cfg *global.ListenCfg

	//超时时间
	TimeoutV time.Duration
	//心跳时间
	HBTickerV time.Duration
	// contains filtered or unexported fields
}

type ProtocalEnum = string