From 4b0cfc7539ec6fdbc462f60269656fee761bafaf Mon Sep 17 00:00:00 2001 From: Rastislav Szabo Date: Wed, 17 May 2017 16:19:30 +0200 Subject: multiple small fixes Change-Id: I9e822ce7e9b9f44f7d074b0294d6eda37c2a0f12 Signed-off-by: Rastislav Szabo --- core/core.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) (limited to 'core/core.go') diff --git a/core/core.go b/core/core.go index 7dc45de..550b6a7 100644 --- a/core/core.go +++ b/core/core.go @@ -207,13 +207,16 @@ func (c *Connection) processRequest(ch *api.Channel, chMeta *channelMetadata, re "msg_size": len(data), }).Debug("Sending a message to VPP.") - c.vpp.SendMsg(chMeta.id, data) - if req.Multipart { - // multipart request + // expect multipart response atomic.StoreUint32(&chMeta.multipart, 1) + } - // send a control ping + // send the request to VPP + c.vpp.SendMsg(chMeta.id, data) + + if req.Multipart { + // send a control ping to determine end of the multipart response ping := &vpe.ControlPing{} pingData, _ := c.codec.EncodeMsg(ping, c.pingReqID) -- cgit 1.2.3-korg