X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fcommon%2Finclude%2Frmr.h;h=478e08e72d02b228ce50515592976e08342cab50;hb=d07cc97b4b5493a5fc67231ee09d1c931c993161;hp=5d4583a85f80a1603f5210d0a0770d9d9aa40fda;hpb=6d112571b27574ae857da7cb8dc8758ffee4ff60;p=ric-plt%2Flib%2Frmr.git diff --git a/src/rmr/common/include/rmr.h b/src/rmr/common/include/rmr.h index 5d4583a..478e08e 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 4096 // 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 @@ -72,6 +75,11 @@ extern "C" { #define RMR_ERR_INITFAILED 15 // initialisation of something (probably message) failed #define RMR_ERR_NOTSUPP 16 // the request is not supported, or RMr was not initialised for the request +#define RMR_NO_CLONE 0 // parm constants for better readability +#define RMR_CLONE 1 +#define RMR_NO_COPY 0 +#define RMR_COPY 1 + #define RMR_WH_CONNECTED(a) (a>=0) // for now whid is integer; it could be pointer at some future date /* @@ -135,7 +143,9 @@ extern void rmr_set_low_latency( void* vctx ); extern rmr_mbuf_t* rmr_torcv_msg( void* vctx, rmr_mbuf_t* old_msg, int ms_to ); extern rmr_mbuf_t* rmr_tralloc_msg( void* context, int msize, int trsize, unsigned const char* data ); extern rmr_whid_t rmr_wh_open( void* vctx, char const* target ); +extern rmr_mbuf_t* rmr_wh_call( void* vctx, rmr_whid_t whid, rmr_mbuf_t* msg, int call_id, int max_wait ); extern rmr_mbuf_t* rmr_wh_send_msg( void* vctx, rmr_whid_t whid, rmr_mbuf_t* msg ); +extern int rmr_wh_state( void* vctx, rmr_whid_t whid ); extern void rmr_wh_close( void* vctx, int whid ); // ----- mt call support --------------------------------------------------------------------------------