X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fnng%2Finclude%2Frmr_nng_private.h;h=bf595749fb2d252561eab25ef5ff50ad938b0e32;hb=d9de79acd9c205dc4f795e90a98331628ed6c85b;hp=efb2daabc3356a66f3194d24e5d98dc8d5fe9bdf;hpb=58ccd68c7e98074aa65cb9fc271db963192de68d;p=ric-plt%2Flib%2Frmr.git diff --git a/src/rmr/nng/include/rmr_nng_private.h b/src/rmr/nng/include/rmr_nng_private.h index efb2daa..bf59574 100644 --- a/src/rmr/nng/include/rmr_nng_private.h +++ b/src/rmr/nng/include/rmr_nng_private.h @@ -51,7 +51,7 @@ struct endpoint { Epoll information needed for the rmr_torcv_msg() funciton */ typedef struct epoll_stuff { - struct epoll_event events[1]; // wait on 10 possible events + struct epoll_event events[1]; // wait on 1 possible events struct epoll_event epe; // event definition for event to listen to int ep_fd; // file des from nng int nng_fd; // fd from nng @@ -124,6 +124,7 @@ static void* rcv_payload( uta_ctx_t* ctx, rmr_mbuf_t* old_msg ); static inline rmr_mbuf_t* realloc_msg( rmr_mbuf_t* old_msg, int tr_len ); static rmr_mbuf_t* send_msg( uta_ctx_t* ctx, rmr_mbuf_t* msg, nng_socket nn_sock, int retries ); static rmr_mbuf_t* send2ep( uta_ctx_t* ctx, endpoint_t* ep, rmr_mbuf_t* msg ); +static rmr_mbuf_t* realloc_payload( rmr_mbuf_t* mbuf, int new_len, int copy, int clone );