X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Frmr.go;fp=pkg%2Fxapp%2Frmr.go;h=a10a1134a87d57ab4d49da710bc720199c24bc3c;hb=d598befb5dc17414206c06a0c263d7922571ed95;hp=028cc3c9473aa18af2948b27409775063c729ddd;hpb=2fe100b35c1586dba1d7e9856fdec68091c22df0;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/rmr.go b/pkg/xapp/rmr.go index 028cc3c..a10a113 100755 --- a/pkg/xapp/rmr.go +++ b/pkg/xapp/rmr.go @@ -29,6 +29,7 @@ package xapp #include #include + void write_bytes_array(unsigned char *dst, void *data, int len) { memcpy((void *)dst, (void *)data, len); } @@ -108,9 +109,9 @@ var RMRErrors = map[int]string{ C.RMR_ERR_NOTSUPP: "the request is not supported, or RMr was not initialized for the request", } -//----------------------------------------------------------------------------- +// ----------------------------------------------------------------------------- // -//----------------------------------------------------------------------------- +// ----------------------------------------------------------------------------- type RMRParams struct { Mtype int Payload []byte @@ -132,9 +133,9 @@ func (params *RMRParams) String() string { return b.String() } -//----------------------------------------------------------------------------- +// ----------------------------------------------------------------------------- // -//----------------------------------------------------------------------------- +// ----------------------------------------------------------------------------- type RMRClientParams struct { StatDesc string RmrData PortData @@ -146,9 +147,9 @@ func (params *RMRClientParams) String() string { params.RmrData.LowLatency, params.RmrData.FastAck, params.RmrData.Policies) } -//----------------------------------------------------------------------------- +// ----------------------------------------------------------------------------- // -//----------------------------------------------------------------------------- +// ----------------------------------------------------------------------------- func NewRMRClientWithParams(params *RMRClientParams) *RMRClient { p := C.CString(fmt.Sprintf("%d", params.RmrData.Port)) m := C.int(params.RmrData.MaxSize)