(log *golog.Logger, protocol string, ses cellnet.Session, msg interface{})
| 34 | } |
| 35 | |
| 36 | func WriteSendLogger(log *golog.Logger, protocol string, ses cellnet.Session, msg interface{}) { |
| 37 | |
| 38 | if log.IsDebugEnabled() { |
| 39 | |
| 40 | if peeker, ok := msg.(PacketMessagePeeker); ok { |
| 41 | msg = peeker.Message() |
| 42 | } |
| 43 | |
| 44 | if IsMsgLogValid(cellnet.MessageToID(msg)) { |
| 45 | peerInfo := ses.Peer().(cellnet.PeerProperty) |
| 46 | |
| 47 | log.Debugf("#%s.send(%s)@%d len: %d %s | %s", |
| 48 | protocol, |
| 49 | peerInfo.Name(), |
| 50 | ses.ID(), |
| 51 | cellnet.MessageSize(msg), |
| 52 | cellnet.MessageToName(msg), |
| 53 | cellnet.MessageToString(msg)) |
| 54 | } |
| 55 | |
| 56 | } |
| 57 | |
| 58 | } |
no test coverage detected