X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fnng%2Fsrc%2Fmt_call_nng_static.c;h=d3a914a3a82a6221617620e6f96975b401604977;hb=cf4413c47ce274d7fc08c3bcfc8c4de3d465ad4d;hp=78205611704bb8432f20189641b4629d85a2f42e;hpb=7d1b7b0de82414ad25ebd323b2913de72ab448c1;p=ric-plt%2Flib%2Frmr.git diff --git a/src/rmr/nng/src/mt_call_nng_static.c b/src/rmr/nng/src/mt_call_nng_static.c index 7820561..d3a914a 100644 --- a/src/rmr/nng/src/mt_call_nng_static.c +++ b/src/rmr/nng/src/mt_call_nng_static.c @@ -38,7 +38,7 @@ static inline void queue_normal( uta_ctx_t* ctx, rmr_mbuf_t* mbuf ) { if( ! uta_ring_insert( ctx->mring, mbuf ) ) { rmr_free_msg( mbuf ); // drop if ring is full if( !warned ) { - fprintf( stderr, "[WARN] rmr_mt_receive: application is not receiving fast enough; messages dropping\n" ); + rmr_vlog( RMR_VL_WARN, "rmr_mt_receive: application is not receiving fast enough; messages dropping\n" ); warned++; } @@ -80,7 +80,7 @@ static void* mt_receive( void* vctx ) { return NULL; } - fprintf( stderr, "[INFO] rmr mt_receiver is spinning\n" ); + rmr_vlog( RMR_VL_INFO, "rmr mt_receiver is spinning\n" ); while( ! ctx->shutdown ) { mbuf = rcv_msg( ctx, NULL );