Change-Id: Ie07be64ac104fe9cfbaa96faab8e69d0bf8d7206
Signed-off-by: Irina <ib565x@intl.att.com>
ctx.checkContextInitialized()
ctx.Logger.Debugf("#rmrCgoApi.SendMsg - Going to send message. MBuf: %v", *msg)
allocatedCMBuf := ctx.getAllocatedCRmrMBuf(ctx.Logger, msg, ctx.MaxMsgSize)
ctx.checkContextInitialized()
ctx.Logger.Debugf("#rmrCgoApi.SendMsg - Going to send message. MBuf: %v", *msg)
allocatedCMBuf := ctx.getAllocatedCRmrMBuf(ctx.Logger, msg, ctx.MaxMsgSize)
- defer C.rmr_free_msg(allocatedCMBuf)
state := allocatedCMBuf.state
if state != RMR_OK {
errorMessage := fmt.Sprintf("#rmrCgoApi.SendMsg - Failed to get allocated message. state: %v - %s", state, states[int(state)])
state := allocatedCMBuf.state
if state != RMR_OK {
errorMessage := fmt.Sprintf("#rmrCgoApi.SendMsg - Failed to get allocated message. state: %v - %s", state, states[int(state)])
}
currCMBuf := C.rmr_send_msg(ctx.RmrCtx, allocatedCMBuf)
}
currCMBuf := C.rmr_send_msg(ctx.RmrCtx, allocatedCMBuf)
+ defer C.rmr_free_msg(currCMBuf)
+
state = currCMBuf.state
if state != RMR_OK {
state = currCMBuf.state
if state != RMR_OK {
ctx.checkContextInitialized()
ctx.Logger.Debugf("#rmrCgoApi.RecvMsg - Going to receive message")
allocatedCMBuf := C.rmr_alloc_msg(ctx.RmrCtx, C.int(ctx.MaxMsgSize))
ctx.checkContextInitialized()
ctx.Logger.Debugf("#rmrCgoApi.RecvMsg - Going to receive message")
allocatedCMBuf := C.rmr_alloc_msg(ctx.RmrCtx, C.int(ctx.MaxMsgSize))
- defer C.rmr_free_msg(allocatedCMBuf)
currCMBuf := C.rmr_rcv_msg(ctx.RmrCtx, allocatedCMBuf)
currCMBuf := C.rmr_rcv_msg(ctx.RmrCtx, allocatedCMBuf)
+ defer C.rmr_free_msg(currCMBuf)
+
state := currCMBuf.state
if state != RMR_OK {
state := currCMBuf.state
if state != RMR_OK {
ctx.Logger.Debugf("#rmrCgoApi.Close - Going to close RMR context")
C.rmr_close(ctx.RmrCtx)
time.Sleep(100 * time.Millisecond)
ctx.Logger.Debugf("#rmrCgoApi.Close - Going to close RMR context")
C.rmr_close(ctx.RmrCtx)
time.Sleep(100 * time.Millisecond)
+}
\ No newline at end of file