summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
f0ee2c6)
Change-Id: I2fe30c58125f178a99883bfb3a8069c5a2106977
Signed-off-by: Mohamed Abukar <abukar.mohamed@nokia.com>
func (m *RMRClient) Free(mbuf *C.rmr_mbuf_t) {
if mbuf == nil {
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)
return
}
C.rmr_free_msg(mbuf)
}
func (m *RMRClient) SendBuffer(params *RMRParams, isRts bool) bool {
}
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 {
for i := 0; i < 10; i++ {
errCode := m.Send(params, isRts)
if errCode == C.RMR_OK {
m.UpdateStatCounter("Transmitted")
return true
}
m.UpdateStatCounter("Transmitted")
return true
}
m.UpdateStatCounter("TransmitError")
return false
}
m.UpdateStatCounter("TransmitError")
return false
}