-func (m *RMRClient) SendBuffer(params *RMRParams, isRts bool) bool {
- 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
- }
- if errCode != C.RMR_ERR_RETRY {
- Logger.Error("rmrClient: rmr_send returned hard error - %d", errCode)
- break
- }
-
- }
-
- m.Free(params.Mbuf)
- m.UpdateStatCounter("TransmitError")
- return false
-}
-
-func (m *RMRClient) Send(params *RMRParams, isRts bool) C.int {