X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fcommon%2Fsrc%2Frtc_static.c;h=f29f65fadf021fde459ad4f9db23f22442df8245;hb=691909ffc0dab5989347ecb00b839e68569db164;hp=10bc2a70914dd11bd287a60be5aa517f69e6c56c;hpb=c8e651e15839411c85e105d16fd2ffc14c1cc1dd;p=ric-plt%2Flib%2Frmr.git diff --git a/src/rmr/common/src/rtc_static.c b/src/rmr/common/src/rtc_static.c index 10bc2a7..f29f65f 100644 --- a/src/rmr/common/src/rtc_static.c +++ b/src/rmr/common/src/rtc_static.c @@ -268,6 +268,7 @@ static void* rtc( void* vctx ) { uta_ctx_t* ctx; // context user has -- where we pin the route table uta_ctx_t* pvt_cx; // private context for session with rtg rmr_mbuf_t* msg = NULL; // message from rtg + route_table_t* rt; // the routing table that will be traversed to print statistics char* my_port; // the port number that we will listen on (4561 has been the default for this) char* rtg_addr; // host:port address of route table generator (route manager) char* daddr; // duplicated rtg address string to parse/trash @@ -385,7 +386,9 @@ static void* rtc( void* vctx ) { count_delay = 300; } if( vlevel >= 0 ) { // allow it to be forced off with -n in verbose file - rt_epcounts( ctx->rtable, ctx->my_name ); + rt = get_rt( ctx ); // get active route table and up ref count + rt_epcounts( rt, ctx->my_name ); + release_rt( ctx, rt ); // dec safely the ref counter } } @@ -464,6 +467,7 @@ static void* raw_rtc( void* vctx ) { uta_ctx_t* ctx; // context user has -- where we pin the route table uta_ctx_t* pvt_cx; // private context for session with rtg rmr_mbuf_t* msg = NULL; // message from rtg + route_table_t* rt; // the routing table that will be traversed to print statistics char* payload; // payload in the message size_t mlen; char* port; // a port number we listen/connect to @@ -582,7 +586,9 @@ static void* raw_rtc( void* vctx ) { if( blabber > bump_freq ) { count_delay = 300; } - rt_epcounts( ctx->rtable, ctx->my_name ); + rt = get_rt( ctx ); // get active route table and up ref count + rt_epcounts( rt, ctx->my_name ); + release_rt( ctx, rt ); // dec safely the ref counter } }