fix(API): Sync the timeout specifications

[ric-plt/lib/rmr.git] / src / nanomsg / include / rmr_private.h

diff --git a/src/nanomsg/include/rmr_private.h b/src/nanomsg/include/rmr_private.h
index 9c00675..3522e08 100644 (file)
--- a/src/nanomsg/include/rmr_private.h
+++ b/src/nanomsg/include/rmr_private.h
@@ -62,6 +62,7 @@ struct uta_ctx {
        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
@@ -99,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 );