Method handleMsg

protocols/cpc/handler.go:375–416

(p *peer, id string, handleTxs bool, handleDporMsgs bool, dporProtocol consensus.Protocol)

}

func (pm *ProtocolManager) handleMsg(p *peer, id string, handleTxs bool, handleDporMsgs bool, dporProtocol consensus.Protocol) (string, error) {

	msg, err := p.rw.ReadMsg()
	if err != nil {
		return id, err
	}

	if msg.Size > ProtocolMaxMsgSize {
		log.Warn("err when checking msg size", "size", msg.Size)
		return id, errResp(ErrMsgTooLarge, "%v > %v", msg.Size, ProtocolMaxMsgSize)
	}

	defer msg.Discard()

	// if I am a validator, do not waste time to handle tx msg
	if msg.Code == TxMsg && !handleTxs {
		return id, nil
	}

	switch {
	case backend.IsSyncMsg(msg):
		switch err = pm.handleSyncMsg(msg, p); err {
		case nil:

		default:
			log.Warn("err when handling sync msg", "err", err)
		}

	case backend.IsDporMsg(msg) && handleDporMsgs:
		switch id, err = dporProtocol.HandleMsg(id, p.version, p.Peer, p.rw, msg); err {
		case nil:

		default:
			log.Warn("err when handling dpor msg", "err", err)
		}

	default:
		log.Warn("unknown msg code", "msg", msg.Code)
	}

	return id, err
}

func (pm *ProtocolManager) handleSyncMsg(msg p2p.Msg, p *peer) error {
	// Handle the message depending on its contents