Change-Id: I2fe30c58125f178a99883bfb3a8069c5a2106977
Signed-off-by: Mohamed Abukar <abukar.mohamed@nokia.com>
func (m *RMRClient) Free(mbuf *C.rmr_mbuf_t) {
if mbuf == nil {
- Logger.Error("rmrClient: Can't free mbuffer, given nil pointer")
return
}
C.rmr_free_msg(mbuf)
}
func (m *RMRClient) SendBuffer(params *RMRParams, isRts bool) bool {
- defer m.Free(params.Mbuf)
for i := 0; i < 10; i++ {
errCode := m.Send(params, isRts)
if errCode == C.RMR_OK {
+ m.Free(params.Mbuf)
m.UpdateStatCounter("Transmitted")
return true
}
}
}
+
+ m.Free(params.Mbuf)
m.UpdateStatCounter("TransmitError")
return false
}