Method sendLoop

peer/tcp/session.go:180–217

发送循环

()

// 发送循环
func (self *tcpSession) sendLoop() {

	var writeList []interface{}

	var capturePanic bool

	if i, ok := self.Peer().(cellnet.PeerCaptureIOPanic); ok {
		capturePanic = i.CaptureIOPanic()
	}

	for {
		writeList = writeList[0:0]
		exit := self.sendQueue.Pick(&writeList)

		// 遍历要发送的数据
		for _, msg := range writeList {

			if capturePanic {
				self.protectedSendMessage(&cellnet.SendMsgEvent{Ses: self, Msg: msg})
			} else {
				self.SendMessage(&cellnet.SendMsgEvent{Ses: self, Msg: msg})
			}
		}

		if exit {
			break
		}
	}

	// 完整关闭
	conn := self.Conn()
	if conn != nil {
		conn.Close()
	}

	// 通知完成
	self.exitSync.Done()
}

// 启动会话的各种资源
func (self *tcpSession) Start() {