Function WriteRecvLogger

msglog/proc.go:13–34

(log *golog.Logger, protocol string, ses cellnet.Session, msg interface{})

}

func WriteRecvLogger(log *golog.Logger, protocol string, ses cellnet.Session, msg interface{}) {

	if log.IsDebugEnabled() {

		if peeker, ok := msg.(PacketMessagePeeker); ok {
			msg = peeker.Message()
		}

		if IsMsgLogValid(cellnet.MessageToID(msg)) {
			peerInfo := ses.Peer().(cellnet.PeerProperty)

			log.Debugf("#%s.recv(%s)@%d len: %d %s | %s",
				protocol,
				peerInfo.Name(),
				ses.ID(),
				cellnet.MessageSize(msg),
				cellnet.MessageToName(msg),
				cellnet.MessageToString(msg))
		}

	}
}

func WriteSendLogger(log *golog.Logger, protocol string, ses cellnet.Session, msg interface{}) {