diff options
author | Ondrej Fabry <ofabry@cisco.com> | 2018-04-05 13:46:54 +0200 |
---|---|---|
committer | Ondrej Fabry <ofabry@cisco.com> | 2018-04-05 13:46:54 +0200 |
commit | 392a56b700fa6715d091e56c49f79bfe32613fc6 (patch) | |
tree | 1fe9cede81628bd6ee4a878296ff5faa22f3c823 /api/api.go | |
parent | 37c71c06371e9bf791fd1573051fa774fcb66602 (diff) |
Lookup message name by ID when receiving unexpected message
Change-Id: I693e8084b7e3f036dec5e557dc772857bb7d5f3d
Signed-off-by: Ondrej Fabry <ofabry@cisco.com>
Diffstat (limited to 'api/api.go')
-rw-r--r-- | api/api.go | 22 |
1 files changed, 18 insertions, 4 deletions
@@ -78,6 +78,8 @@ type MessageDecoder interface { type MessageIdentifier interface { // GetMessageID returns message identifier of given API message. GetMessageID(msg Message) (uint16, error) + // LookupByID looks up message name and crc by ID + LookupByID(ID uint16) (string, error) } // Channel is the main communication interface with govpp core. It contains two Go channels, one for sending the requests @@ -231,6 +233,7 @@ func (ch *Channel) receiveReplyInternal(msg Message) (LastReplyReceived bool, er LastReplyReceived = true return } + // message checks expMsgID, err := ch.MsgIdentifier.GetMessageID(msg) if err != nil { @@ -238,20 +241,31 @@ func (ch *Channel) receiveReplyInternal(msg Message) (LastReplyReceived bool, er msg.GetMessageName(), msg.GetCrcString()) return false, err } + if vppReply.MessageID != expMsgID { + var msgNameCrc string + if nameCrc, err := ch.MsgIdentifier.LookupByID(vppReply.MessageID); err != nil { + msgNameCrc = err.Error() + } else { + msgNameCrc = nameCrc + } + if ch.lastTimedOut { - logrus.Warnf("received invalid message ID, expected %d (%s), but got %d (probably timed out reply from previous request)", - expMsgID, msg.GetMessageName(), vppReply.MessageID) + logrus.Warnf("received invalid message ID, expected %d (%s), but got %d (%s) (probably timed out reply from previous request)", + expMsgID, msg.GetMessageName(), vppReply.MessageID, msgNameCrc) continue } - err = fmt.Errorf("received invalid message ID, expected %d (%s), but got %d (check if multiple goroutines are not sharing single GoVPP channel)", - expMsgID, msg.GetMessageName(), vppReply.MessageID) + + err = fmt.Errorf("received invalid message ID, expected %d (%s), but got %d (%s) (check if multiple goroutines are not sharing single GoVPP channel)", + expMsgID, msg.GetMessageName(), vppReply.MessageID, msgNameCrc) return false, err } + ch.lastTimedOut = false // decode the message err = ch.MsgDecoder.DecodeMsg(vppReply.Data, msg) return false, err + case <-timer.C: ch.lastTimedOut = true err = fmt.Errorf("no reply received within the timeout period %s", ch.replyTimeout) |