X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fnanomsg%2Finclude%2Frmr_private.h;h=3522e0846d6434b2b7e01218c193fe964700e519;hb=966c7d60bb790ccebdfbc2d62fdba72680b523b6;hp=3b5d3d317da3532fa3f6e8e09200a69524e2eae7;hpb=fd9cc7a5b3355146388ebdf4d558cb284c66c5f1;p=ric-plt%2Flib%2Frmr.git diff --git a/src/nanomsg/include/rmr_private.h b/src/nanomsg/include/rmr_private.h index 3b5d3d3..3522e08 100644 --- a/src/nanomsg/include/rmr_private.h +++ b/src/nanomsg/include/rmr_private.h @@ -59,6 +59,10 @@ struct uta_ctx { int flags; // CTXFL_ constants int nrtele; // number of elements in the routing table int nn_sock; // our general listen socket + int trace_data_len; // len of tracing data that sits just past header (0 means none) + int d1_len; // lengths for additional post header, pre payload data areas + int d2_len; + int last_rto; // last receive timeout set so that we don't bash in on every call route_table_t* rtable; // the active route table route_table_t* old_rtable; // the previously used rt, sits here to allow for draining route_table_t* new_rtable; // route table under construction @@ -96,7 +100,7 @@ static int uta_epsock_byname( route_table_t* rt, char* ep_name ); static int uta_epsock_rr( route_table_t *rt, int mtype, int group, int* more ); // ------ msg ------------------------------------------------ -static rmr_mbuf_t* alloc_zcmsg( uta_ctx_t* ctx, rmr_mbuf_t* msg, int size, int state ); +static rmr_mbuf_t* alloc_zcmsg( uta_ctx_t* ctx, rmr_mbuf_t* msg, int size, int state, int tr_size ); static inline rmr_mbuf_t* clone_msg( rmr_mbuf_t* old_msg ); static rmr_mbuf_t* rcv_msg( uta_ctx_t* ctx, rmr_mbuf_t* old_msg ); static void* rcv_payload( uta_ctx_t* ctx, rmr_mbuf_t* old_msg );