X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fbindings%2Frmr-python%2Frmr%2Frmr.py;h=00f6e715d07660ac203070cb46875a78561609dd;hb=fa09c30e9450c45853311c6f07a621e1b9218ff0;hp=7e5d493d7c78a0d236bc7b44e2250ee2148930ec;hpb=0b6077fcd74759b097964d49ccb57e36bd86f9bb;p=ric-plt%2Flib%2Frmr.git

diff --git a/src/bindings/rmr-python/rmr/rmr.py b/src/bindings/rmr-python/rmr/rmr.py
index 7e5d493..00f6e71 100644
--- a/src/bindings/rmr-python/rmr/rmr.py
+++ b/src/bindings/rmr-python/rmr/rmr.py
@@ -93,6 +93,9 @@ def _state_to_status(stateno):
     return sdict.get(stateno, "UNKNOWN STATE")
 
 
+_RCONST = _get_constants()
+
+
 ##############
 # PUBLIC API
 ##############
@@ -100,7 +103,15 @@ def _state_to_status(stateno):
 
 # These constants are directly usable by importers of this library
 # TODO: Are there others that will be useful?
-RMR_MAX_RCV_BYTES = _get_constants()["RMR_MAX_RCV_BYTES"]
+
+RMR_MAX_RCV_BYTES = _RCONST["RMR_MAX_RCV_BYTES"]
+
+RMRFL_NONE = _RCONST.get("RMRFL_MTCALL", 0x02)	  # initialisation flags
+RMRFL_NONE = _RCONST.get("RMRFL_NONE", 0x0)
+
+RMR_OK = _RCONST["RMR_OK"]                        # useful state constants
+RMR_ERR_TIMEOUT = _RCONST["RMR_ERR_TIMEOUT"]
+RMR_ERR_RETRY = _RCONST["RMR_ERR_RETRY"]
 
 
 class rmr_mbuf_t(Structure):
@@ -213,6 +224,20 @@ def rmr_alloc_msg(vctx, size):
     return _rmr_alloc_msg(vctx, size)
 
 
+_rmr_free_msg = rmr_c_lib.rmr_free_msg
+_rmr_free_msg.argtypes = [c_void_p]
+_rmr_free_msg.restype = None
+
+
+def rmr_free_msg(mbuf):
+    """
+    Refer to the rmr C documentation for rmr_free_msg
+    extern void rmr_free_msg( rmr_mbuf_t* mbuf )
+    """
+    if mbuf is not None:
+        _rmr_free_msg(mbuf)
+
+
 _rmr_payload_size = rmr_c_lib.rmr_payload_size
 _rmr_payload_size.argtypes = [POINTER(rmr_mbuf_t)]
 _rmr_payload_size.restype = c_int
@@ -312,23 +337,36 @@ def rmr_bytes2meid(ptr_mbuf, src, length):
 # this is an alias to rmr_bytes2meid using familiar set/get terminoloigy
 rmr_set_meid = rmr_bytes2meid
 
-
 # CAUTION:  Some of the C functions expect a mutable buffer to copy the bytes into;
 #           if there is a get_* function below, use it to set up and return the
 #           buffer properly.
 
-
+# extern unsigned char*  rmr_get_meid(rmr_mbuf_t* mbuf, unsigned char* dest);
+# we don't provide direct access to this function (unless it is asked for) because it is not really useful to provide your own buffer.
+# Rather, rmr_get_meid does this for you, and just returns the string.
 _rmr_get_meid = rmr_c_lib.rmr_get_meid
 _rmr_get_meid.argtypes = [POINTER(rmr_mbuf_t), c_char_p]
 _rmr_get_meid.restype = c_char_p
 
 
-def rmr_get_meid(ptr_mbuf, dest):
+def rmr_get_meid(ptr_mbuf):
     """
-    Refer to the rmr C documentation for rmr_get_meid
-    extern unsigned char*  rmr_get_meid(rmr_mbuf_t* mbuf, unsigned char* dest);
+    Get the managed equipment ID (meid) from the message header.
+
+    Parameters
+    ----------
+    ptr_mbuf: ctypes c_void_p
+        Pointer to an rmr message buffer
+
+    Returns
+    -------
+    string:
+        meid
     """
-    return _rmr_get_meid(ptr_mbuf, dest)
+    sz = _get_constants().get("RMR_MAX_MEID", 64)  # size for buffer to fill
+    buf = create_string_buffer(sz)
+    _rmr_get_meid(ptr_mbuf, buf)
+    return buf.value.decode()  # decode turns into a string
 
 
 _rmr_get_src = rmr_c_lib.rmr_get_src
@@ -404,10 +442,6 @@ def message_summary(ptr_mbuf):
     if ptr_mbuf.contents.len > RMR_MAX_RCV_BYTES:
         return "Malformed message: message length is greater than the maximum possible"
 
-    meid = get_meid(ptr_mbuf)
-    if meid == "\000" * _get_constants().get("RMR_MAX_MEID", 32):  # special case all nils
-        meid = None
-
     return {
         "payload": get_payload(ptr_mbuf),
         "payload length": ptr_mbuf.contents.len,
@@ -417,7 +451,7 @@ def message_summary(ptr_mbuf):
         "message state": ptr_mbuf.contents.state,
         "message status": _state_to_status(ptr_mbuf.contents.state),
         "payload max size": rmr_payload_size(ptr_mbuf),
-        "meid": meid,
+        "meid": rmr_get_meid(ptr_mbuf),
         "message source": get_src(ptr_mbuf),
         "errno": ptr_mbuf.contents.tp_state,
     }
@@ -454,27 +488,6 @@ def generate_and_set_transaction_id(ptr_mbuf):
     memmove(ptr_mbuf.contents.xaction, uu_id, sz)
 
 
-def get_meid(ptr_mbuf):
-    """
-    | Get the managed equipment ID (meid) from the message header.
-    | This is a 32 byte field and RMr returns all 32 bytes which if the sender did not set will be garbage.
-
-    Parameters
-    ----------
-    ptr_mbuf: ctypes c_void_p
-        Pointer to an rmr message buffer
-
-    Returns
-    -------
-    string:
-        meid
-    """
-    sz = _get_constants().get("RMR_MAX_MEID", 64)  # size for buffer to fill
-    buf = create_string_buffer(sz)
-    rmr_get_meid(ptr_mbuf, buf)
-    return buf.raw.decode()
-
-
 def get_src(ptr_mbuf):
     """
     Get the message source (likely host:port)
@@ -487,7 +500,7 @@ def get_src(ptr_mbuf):
     Returns
     -------
     string:
-        meid
+        message source
     """
     sz = _get_constants().get("RMR_MAX_SRC", 64)  # size to fill
     buf = create_string_buffer(sz)