diff options
Diffstat (limited to 'core')
| -rw-r--r-- | core/bin_api/vpe/vpe.go | 3 | ||||
| -rw-r--r-- | core/msg_codec.go | 13 |
2 files changed, 15 insertions, 1 deletions
diff --git a/core/bin_api/vpe/vpe.go b/core/bin_api/vpe/vpe.go index 51a245b..c11f466 100644 --- a/core/bin_api/vpe/vpe.go +++ b/core/bin_api/vpe/vpe.go @@ -1,5 +1,6 @@ +// Code generated by govpp binapi-generator DO NOT EDIT. // Package vpe represents the VPP binary API of the 'vpe' VPP module. -// DO NOT EDIT. Generated from 'bin_api/vpe.api.json' +// Generated from 'bin_api/vpe.api.json' package vpe import "git.fd.io/govpp.git/api" diff --git a/core/msg_codec.go b/core/msg_codec.go index 5614a7e..c72b7f3 100644 --- a/core/msg_codec.go +++ b/core/msg_codec.go @@ -43,6 +43,12 @@ type vppReplyHeader struct { Context uint32 } +// vppEventHeader struct contains header fields implemented by all VPP events. +type vppEventHeader struct { + VlMsgID uint16 + Context uint32 +} + // vppOtherHeader struct contains header fields implemented by other VPP messages (not requests nor replies). type vppOtherHeader struct { VlMsgID uint16 @@ -51,6 +57,7 @@ type vppOtherHeader struct { const ( vppRequestHeaderSize = 10 // size of a VPP request header vppReplyHeaderSize = 6 // size of a VPP reply header + vppEventHeaderSize = 6 // size of a VPP event header vppOtherHeaderSize = 2 // size of the header of other VPP messages ) @@ -68,6 +75,8 @@ func (*MsgCodec) EncodeMsg(msg api.Message, msgID uint16) ([]byte, error) { header = &vppRequestHeader{VlMsgID: msgID} } else if msg.GetMessageType() == api.ReplyMessage { header = &vppReplyHeader{VlMsgID: msgID} + } else if msg.GetMessageType() == api.EventMessage { + header = &vppEventHeader{VlMsgID: msgID} } else { header = &vppOtherHeader{VlMsgID: msgID} } @@ -109,6 +118,8 @@ func (*MsgCodec) DecodeMsg(data []byte, msg api.Message) error { header = &vppRequestHeader{} } else if msg.GetMessageType() == api.ReplyMessage { header = &vppReplyHeader{} + } else if msg.GetMessageType() == api.EventMessage { + header = &vppEventHeader{} } else { header = &vppOtherHeader{} } @@ -128,6 +139,8 @@ func (*MsgCodec) DecodeMsg(data []byte, msg api.Message) error { buf = bytes.NewReader(data[vppRequestHeaderSize:]) } else if msg.GetMessageType() == api.ReplyMessage { buf = bytes.NewReader(data[vppReplyHeaderSize:]) + } else if msg.GetMessageType() == api.EventMessage { + buf = bytes.NewReader(data[vppEventHeaderSize:]) } else { buf = bytes.NewReader(data[vppOtherHeaderSize:]) } |