(ses cellnet.Session, msg interface{})
| 22 | } |
| 23 | |
| 24 | func (UDPMessageTransmitter) OnSendMessage(ses cellnet.Session, msg interface{}) error { |
| 25 | |
| 26 | writer := ses.(udp.DataWriter) |
| 27 | |
| 28 | msglog.WriteSendLogger(log, "udp", ses, msg) |
| 29 | |
| 30 | // ses不再被复用, 所以使用session自己的contextset做内存池, 避免串台 |
| 31 | return sendPacket(writer, ses.(cellnet.ContextSet), msg) |
| 32 | } |
| 33 | |
| 34 | func init() { |
| 35 |
nothing calls this directly
no test coverage detected