diff options
| author |   Ondrej Fabry <ofabry@cisco.com> | 2019-07-10 07:14:20 +0200 |
|---|---|---|
| committer | Ondrej Fabry <ofabry@cisco.com> | 2019-07-10 07:14:20 +0200 |
| commit | 4dca07c803308611275f78b490ac0352c1052fe2 (patch) | |
| tree | efb52ff663ef3b16f4bd6957379a572c5fd49de0 /core/request_handler.go | |
| parent | b1006dced4cc0c23d9dc754e97d89500aeb55170 (diff) | |
Fix socketclient for VPP 19.08
- in VPP 19.08 the socket type has changed to STREAM and data has to
be writtento VPP with single flush, otherwise msg might get mixed
with next header and cause VPP to stop responding
- this also fixes WaitReady for socketclient and vppapiclient
Change-Id: I022724c0c09c9b92d4c695d1cf2be15994fff717
Signed-off-by: Ondrej Fabry <ofabry@cisco.com>
Diffstat (limited to 'core/request_handler.go')
| -rw-r--r-- | core/request_handler.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/request_handler.go b/core/request_handler.go index fd8aa59..d3f7bdc 100644 --- a/core/request_handler.go +++ b/core/request_handler.go @@ -93,7 +93,7 @@ func (c *Connection) processRequest(ch *Channel, req *vppRequest) error { "msg_size": len(data), "seq_num": req.seqNum, "msg_crc": req.msg.GetCrcString(), - }).Debugf("--> govpp send: %s: %+v", req.msg.GetMessageName(), req.msg) + }).Debugf("==> govpp send: %s: %+v", req.msg.GetMessageName(), req.msg) } // send the request to VPP @@ -118,7 +118,7 @@ func (c *Connection) processRequest(ch *Channel, req *vppRequest) error { "msg_id": c.pingReqID, "msg_size": len(pingData), "seq_num": req.seqNum, - }).Debug(" -> sending control ping") + }).Debug("--> sending control ping") if err := c.vppClient.SendMsg(context, pingData); err != nil { log.WithFields(logger.Fields{ @@ -165,7 +165,7 @@ func (c *Connection) msgCallback(msgID uint16, data []byte) { "is_multi": isMulti, "seq_num": seqNum, "msg_crc": msg.GetCrcString(), - }).Debugf("<-- govpp recv: %s", msg.GetMessageName()) + }).Debugf("<== govpp recv: %s", msg.GetMessageName()) } if context == 0 || c.isNotificationMessage(msgID) { |