X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2FrmrCgo%2FrmrCgoTypes.go;fp=E2Manager%2FrmrCgo%2FrmrCgoTypes.go;h=cc92dca0fcc59aaffeef312b6d397e8b9af251d1;hb=07ef76dd471a0892a893c90e0ab06713aee34be1;hp=0000000000000000000000000000000000000000;hpb=59f84608ec15c016958a6e0e0ddd813f376c0925;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/rmrCgo/rmrCgoTypes.go b/E2Manager/rmrCgo/rmrCgoTypes.go
new file mode 100644
index 0000000..cc92dca
--- /dev/null
+++ b/E2Manager/rmrCgo/rmrCgoTypes.go
@@ -0,0 +1,137 @@
+//
+// Copyright 2019 AT&T Intellectual Property
+// Copyright 2019 Nokia
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+package rmrCgo
+
+// #cgo LDFLAGS: -L/usr/local/lib -lrmr_nng -lnng
+// #include <rmr/rmr.h>
+// #include <rmr/RIC_message_types.h>
+// #include <stdlib.h>
+import "C"
+import (
+	"e2mgr/logger"
+	"fmt"
+	"unsafe"
+)
+
+func NewMBuf(mType int, len int, meid string, payload *[]byte, xAction *[]byte) *MBuf {
+	return &MBuf{
+		MType:   mType,
+		Len:     len,
+		Meid:    meid,
+		Payload: payload,
+		XAction: xAction,
+	}
+}
+
+func NewContext(maxMsgSize int, flags int, ctx unsafe.Pointer, logger *logger.Logger) *Context {
+	return &Context{
+		MaxMsgSize: maxMsgSize,
+		Flags:      flags,
+		RmrCtx:     ctx,
+		Logger:     logger,
+	}
+}
+//TODO: consider declaring using its own type
+const (
+	// messages
+	RIC_X2_SETUP_REQ            = C.RIC_X2_SETUP_REQ
+	RIC_X2_SETUP_RESP           = C.RIC_X2_SETUP_RESP
+	RIC_X2_SETUP_FAILURE        = C.RIC_X2_SETUP_FAILURE
+	RIC_ENDC_X2_SETUP_REQ       = C.RIC_ENDC_X2_SETUP_REQ
+	RIC_ENDC_X2_SETUP_RESP      =C.RIC_ENDC_X2_SETUP_RESP
+	RIC_ENDC_X2_SETUP_FAILURE   = C.RIC_ENDC_X2_SETUP_FAILURE
+	RIC_SCTP_CONNECTION_FAILURE = C.RIC_SCTP_CONNECTION_FAILURE
+	RIC_ENB_LOAD_INFORMATION    = C.RIC_ENB_LOAD_INFORMATION
+	RIC_ENB_CONF_UPDATE 		= C.RIC_ENB_CONF_UPDATE
+	RIC_ENB_CONFIGURATION_UPDATE_ACK = C.RIC_ENB_CONF_UPDATE_ACK
+	RIC_ENB_CONFIGURATION_UPDATE_FAILURE = C.RIC_ENB_CONF_UPDATE_FAILURE
+	RIC_ENDC_CONF_UPDATE 		= C.RIC_ENDC_CONF_UPDATE
+	RIC_ENDC_CONF_UPDATE_ACK = C.RIC_ENDC_CONF_UPDATE_ACK
+	RIC_ENDC_CONF_UPDATE_FAILURE = C.RIC_ENDC_CONF_UPDATE_FAILURE
+	RIC_SCTP_CLEAR_ALL 			= C.RIC_SCTP_CLEAR_ALL
+)
+
+const (
+	RMR_MAX_XACTION_LEN = int(C.RMR_MAX_XID)
+	RMR_MAX_MEID_LEN    = int(C.RMR_MAX_MEID)
+
+	//states
+    RMR_OK				= C.RMR_OK
+    RMR_ERR_BADARG		= C.RMR_ERR_BADARG
+    RMR_ERR_NOENDPT		= C.RMR_ERR_NOENDPT
+    RMR_ERR_EMPTY		= C.RMR_ERR_EMPTY
+    RMR_ERR_NOHDR		= C.RMR_ERR_NOHDR
+    RMR_ERR_SENDFAILED	= C.RMR_ERR_SENDFAILED
+    RMR_ERR_CALLFAILED	= C.RMR_ERR_CALLFAILED
+    RMR_ERR_NOWHOPEN	= C.RMR_ERR_NOWHOPEN
+    RMR_ERR_WHID		= C.RMR_ERR_WHID
+    RMR_ERR_OVERFLOW	= C.RMR_ERR_OVERFLOW
+    RMR_ERR_RETRY		= C.RMR_ERR_RETRY
+    RMR_ERR_RCVFAILED	= C.RMR_ERR_RCVFAILED
+    RMR_ERR_TIMEOUT		= C.RMR_ERR_TIMEOUT
+    RMR_ERR_UNSET       = C.RMR_ERR_UNSET
+    RMR_ERR_TRUNC       = C.RMR_ERR_TRUNC
+    RMR_ERR_INITFAILED  = C.RMR_ERR_INITFAILED
+)
+
+var states = map[int]string {
+	RMR_OK				:	"state is good",
+	RMR_ERR_BADARG		:	"argument passd to function was unusable",
+	RMR_ERR_NOENDPT		:	"send/call could not find an endpoint based on msg type",
+	RMR_ERR_EMPTY		:	"msg received had no payload; attempt to send an empty message",
+	RMR_ERR_NOHDR		:	"message didn't contain a valid header",
+	RMR_ERR_SENDFAILED	:	"send failed; errno has nano reason",
+	RMR_ERR_CALLFAILED	:	"unable to send call() message",
+	RMR_ERR_NOWHOPEN	:	"no wormholes are open",
+	RMR_ERR_WHID		:	"wormhole id was invalid",
+	RMR_ERR_OVERFLOW	:	"operation would have busted through a buffer/field size",
+	RMR_ERR_RETRY		:	"request (send/call/rts) failed, but caller should retry (EAGAIN for wrappers)",
+	RMR_ERR_RCVFAILED	:	"receive failed (hard error)",
+	RMR_ERR_TIMEOUT		:	"message processing call timed out",
+	RMR_ERR_UNSET       :   "the message hasn't been populated with a transport buffer",
+	RMR_ERR_TRUNC       :   "received message likely truncated",
+	RMR_ERR_INITFAILED  :   "initialisation of something (probably message) failed",
+}
+
+type MBuf struct {
+	MType   int
+	Len     int
+	Meid    string //Managed entity id (RAN name)
+	Payload *[]byte
+	XAction *[]byte
+}
+
+func (m MBuf) String () string {
+	return fmt.Sprintf("{ MType: %d, Len: %d, Meid: %q, Xaction: %q, Payload: [%x] }", m.MType, m.Len, m.Meid, m.XAction, m.Payload)
+}
+
+type Context struct {
+	MaxMsgSize     int
+	Flags          int
+	RmrCtx         unsafe.Pointer
+	Logger         *logger.Logger
+}
+
+type RmrMessenger interface {
+	Init(port string, maxMsgSize int, flags int, logger *logger.Logger) *RmrMessenger
+	SendMsg(msg *MBuf, maxMsgSize int) (*MBuf, error)
+	RecvMsg() (*MBuf, error)
+	RtsMsg(msg *MBuf)
+	IsReady() bool
+	Close()
+}