Method PacketToMsg

nhp/core/device.go:431–467

Synchronous linear processing.

(pd *PacketData)

// Synchronous linear processing.
func (d *Device) PacketToMsg(pd *PacketData) (ppd *PacketParserData, err error) {
	defer func() {
		if x := recover(); x != nil {
			ppd = nil
			err = fmt.Errorf("!!!recovered from panic: %v\n%s", x, string(debug.Stack()))
			ErrRuntimePanic.SetExtraError(err)
			err = ErrRuntimePanic
		}
	}()

	var packetType int
	packetType, _, err = d.RecvPrecheck(pd.BasePacket)
	if err != nil {
		return nil, err
	}
	// skip processing keepalive packet
	if packetType == NHP_KPL {
		return &PacketParserData{HeaderType: NHP_KPL}, nil
	}

	pd.InitTime = time.Now().UnixNano()
	ppd, err = d.createPacketParserData(pd)
	defer ppd.Destroy()
	if err != nil {
		return nil, err
	}
	err = ppd.validatePeer()
	if err != nil {
		return nil, err
	}
	err = ppd.decryptBody()
	if err != nil {
		return nil, err
	}

	return ppd, nil
}

func (d *Device) SendMsgToPacket(md *MsgData) {
	select {