X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Frmr%2Fcommon%2Finclude%2Frmr.h;h=aeefa57668eb447dffb25a279cad43568fc604df;hb=15fb8a6128ee4f8b4d7096f13422aebe4afd2fec;hp=3fc7677c98894028ea6675c4f477ad58269a4687;hpb=338fe5e46223df8145b53cdf52dab358f18c7f26;p=ric-plt%2Flib%2Frmr.git

diff --git a/src/rmr/common/include/rmr.h b/src/rmr/common/include/rmr.h
index 3fc7677..aeefa57 100644
--- a/src/rmr/common/include/rmr.h
+++ b/src/rmr/common/include/rmr.h
@@ -39,7 +39,10 @@ extern "C" {
 #define RMR_MAX_MEID		32		// spece in header reserved for managed element id
 #define RMR_MAX_SRC			64		// max length of hostname (which could be IPv6 addr with [...]:port so more than the 39 bytes of a plain addr
 #define RMR_MAX_SID			32		// misc sender info/data (reserved)
-#define RMR_MAX_RCV_BYTES	(1024 * 64)		// max bytes we support in a receive message
+
+
+#define RMR_MAX_RCV_BYTES	1024 * 2	// DEPRECATED CONSTANT NAME as underlying transport no longer have a max receive size
+#define RMR_DEF_MSG_SIZE	1024	// default message size that applications might want to use
 
 									// various flags for function calls
 #define RMRFL_NONE			0x00	// no flags
@@ -176,6 +179,16 @@ extern int rmr_send_to( void* vctx, int time );		// DEPRECATED -- replaced with
 // ---- misc user interface stuff ----------------------------------------------------------------------
 extern void rmr_set_vlevel( int new_level );
 
+// ---- rmr status debug structures --------------------------------------------------------------------
+typedef struct {
+  uint64_t drop;    // accumulated number of dropped msg
+  uint64_t enqueue; // accumulated number of enqueued msg
+} rmr_rx_debug_t;
+
+// ---- rmr status debug api ---------------------------------------------------------------------------
+extern int rmr_reset_rx_debug_count(void *vctx);
+extern int rmr_get_rx_debug_info(void *vctx, rmr_rx_debug_t *rx_rst);
+
 // --- uta compatability defs if needed user should define UTA_COMPAT  ----------------------------------
 #ifdef UTA_COMPAT
 #pragma message( "use of UTA_COMPAT is deprecated and soon to be removed" )