X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Frmr%2Fsi%2Finclude%2Frmr_si_private.h;h=f125efb701cd16884b9991630b8a48909f4a57b1;hb=ce1c741c01e8387cb095dac5e36a4d8ad91d006d;hp=6c6f74a98737678c94f4f573c9d494cc601470cf;hpb=c113b0836f3ebd58911c30de1636a707174efe55;p=ric-plt%2Flib%2Frmr.git diff --git a/src/rmr/si/include/rmr_si_private.h b/src/rmr/si/include/rmr_si_private.h index 6c6f74a..f125efb 100644 --- a/src/rmr/si/include/rmr_si_private.h +++ b/src/rmr/si/include/rmr_si_private.h @@ -128,6 +128,7 @@ struct uta_ctx { int d1_len; // extra header data 1 length int d2_len; // extra header data 2 length (future) int nn_sock; // our general listen socket + int rtable_ready; // set to true when rt is received or loaded 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 @@ -155,7 +156,10 @@ struct uta_ctx { int max_ibm; // max size of an inbound message (river accum alloc size) void* zcb_mring; // zero copy buffer mbuf ring void* fd2ep; // the symtab mapping file des to endpoints for cleanup on disconnect + void* ephash; // hash host:port or ip:port to endpoint struct + pthread_mutex_t *fd2ep_gate; // we must gate add/deletes to the fd2 symtab + pthread_mutex_t *rtgate; // master gate for accessing/moving route tables }; typedef uta_ctx_t uta_ctx;