diff options
| author |   Rastislav Szabo <raszabo@cisco.com> | 2017-05-17 16:19:30 +0200 |
|---|---|---|
| committer | Rastislav Szabo <raszabo@cisco.com> | 2017-05-17 16:19:30 +0200 |
| commit | 4b0cfc7539ec6fdbc462f60269656fee761bafaf (patch) | |
| tree | 27a9f634d5201dea49207a50fa8e1ba9639bdc58 /core | |
| parent | 51f628282c65f754152a346074f2ae286121138e (diff) | |
multiple small fixes
Change-Id: I9e822ce7e9b9f44f7d074b0294d6eda37c2a0f12
Signed-off-by: Rastislav Szabo <raszabo@cisco.com>
Diffstat (limited to 'core')
| -rw-r--r-- | core/core.go | 11 |
1 files changed, 7 insertions, 4 deletions
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) |