Code Review
/
ric-plt
/
xapp-frame.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
baseimage with go 1.18 and go.mod updates
[ric-plt/xapp-frame.git]
/
pkg
/
xapp
/
rmr.go
diff --git
a/pkg/xapp/rmr.go
b/pkg/xapp/rmr.go
index
028cc3c
..
a10a113
100755
(executable)
--- a/
pkg/xapp/rmr.go
+++ b/
pkg/xapp/rmr.go
@@
-29,6
+29,7
@@
package xapp
#include <rmr/rmr.h>
#include <rmr/RIC_message_types.h>
#include <rmr/rmr.h>
#include <rmr/RIC_message_types.h>
+
void write_bytes_array(unsigned char *dst, void *data, int len) {
memcpy((void *)dst, (void *)data, len);
}
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",
}
C.RMR_ERR_NOTSUPP: "the request is not supported, or RMr was not initialized for the request",
}
-//-----------------------------------------------------------------------------
+//
-----------------------------------------------------------------------------
//
//
-//-----------------------------------------------------------------------------
+//
-----------------------------------------------------------------------------
type RMRParams struct {
Mtype int
Payload []byte
type RMRParams struct {
Mtype int
Payload []byte
@@
-132,9
+133,9
@@
func (params *RMRParams) String() string {
return b.String()
}
return b.String()
}
-//-----------------------------------------------------------------------------
+//
-----------------------------------------------------------------------------
//
//
-//-----------------------------------------------------------------------------
+//
-----------------------------------------------------------------------------
type RMRClientParams struct {
StatDesc string
RmrData PortData
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)
}
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)
func NewRMRClientWithParams(params *RMRClientParams) *RMRClient {
p := C.CString(fmt.Sprintf("%d", params.RmrData.Port))
m := C.int(params.RmrData.MaxSize)