(ev cellnet.Event)
| 165 | } |
| 166 | |
| 167 | func (self *tcpSession) protectedSendMessage(ev cellnet.Event) { |
| 168 | |
| 169 | defer func() { |
| 170 | if err := recover(); err != nil { |
| 171 | log.Errorf("IO send panic: %s %s", err, cellnet.MessageToName(ev.Message())) |
| 172 | } |
| 173 | |
| 174 | }() |
| 175 | |
| 176 | self.SendMessage(ev) |
| 177 | } |
| 178 | |
| 179 | // 发送循环 |
| 180 | func (self *tcpSession) sendLoop() { |
no test coverage detected