X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Frmr.go;h=0aeced219009dd3d54e3aa8d2477bd94c0ef6f12;hb=5953f7e372df54c71f526e9519e8eb0ee7ee6f72;hp=44f0178ae807b30ed2bb874eb9ec65e951b6d3d3;hpb=1c24a3c3823e2ae6301cf0951cdbb7171d9afbde;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/rmr.go b/pkg/xapp/rmr.go index 44f0178..0aeced2 100755 --- a/pkg/xapp/rmr.go +++ b/pkg/xapp/rmr.go @@ -82,6 +82,8 @@ type RMRParams struct { Src string Mbuf *C.rmr_mbuf_t Whid int + Callid int + Timeout int status int } @@ -233,12 +235,12 @@ func (m *RMRClient) SendRts(params *RMRParams) bool { return m.Send(params, true) } -func (m *RMRClient) Send(params *RMRParams, isRts bool) bool { +func (m *RMRClient) CopyBuffer(params *RMRParams) *C.rmr_mbuf_t { txBuffer := params.Mbuf if txBuffer == nil { txBuffer = m.Allocate() if txBuffer == nil { - return false + return nil } } @@ -265,7 +267,15 @@ func (m *RMRClient) Send(params *RMRParams, isRts bool) bool { } } C.write_bytes_array(txBuffer.payload, datap, txBuffer.len) + return txBuffer +} + +func (m *RMRClient) Send(params *RMRParams, isRts bool) bool { + txBuffer := m.CopyBuffer(params) + if txBuffer == nil { + return false + } params.status = m.SendBuf(txBuffer, isRts, params.Whid) if params.status == int(C.RMR_OK) { return true @@ -324,6 +334,39 @@ func (m *RMRClient) SendBuf(txBuffer *C.rmr_mbuf_t, isRts bool, whid int) int { return int(currBuffer.state) } +func (m *RMRClient) SendCallMsg(params *RMRParams) (int, string) { + var ( + currBuffer *C.rmr_mbuf_t + counterName string = "Transmitted" + ) + txBuffer := m.CopyBuffer(params) + if txBuffer == nil { + return C.RMR_ERR_INITFAILED, "" + } + + txBuffer.state = 0 + + currBuffer = C.rmr_wh_call(m.context, C.int(params.Whid), txBuffer, C.int(params.Callid), C.int(params.Timeout)) + + if currBuffer == nil { + m.UpdateStatCounter("TransmitError") + return m.LogMBufError("SendBuf failed", txBuffer), "" + } + + if currBuffer.state != C.RMR_OK { + counterName = "TransmitError" + m.LogMBufError("SendBuf failed", currBuffer) + } + + m.UpdateStatCounter(counterName) + defer m.Free(currBuffer) + + cptr := unsafe.Pointer(currBuffer.payload) + payload := C.GoBytes(cptr, C.int(currBuffer.len)) + + return int(currBuffer.state), string(payload) +} + func (m *RMRClient) Openwh(target string) C.rmr_whid_t { return m.Wh_open(target) }