X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Frmr_nng_api_static_test.c;fp=test%2Frmr_nng_api_static_test.c;h=f08c2f1639574907a7fb033ea4c6652be4e319f5;hb=dfe7b622b128e7bfb4a5e1f7e0afdb84e6001d14;hp=ca2e6f2543b455fafe2e89d7d6cb55f78dacc159;hpb=2596b2305f214efbd7aba832fa009217ab854770;p=ric-plt%2Flib%2Frmr.git

diff --git a/test/rmr_nng_api_static_test.c b/test/rmr_nng_api_static_test.c
index ca2e6f2..f08c2f1 100644
--- a/test/rmr_nng_api_static_test.c
+++ b/test/rmr_nng_api_static_test.c
@@ -122,16 +122,25 @@ static int rmr_api_test( ) {
 		return 1;
 	}
 
+	setenv( "RMR_SRC_ID", "somehost", 1 );								// context should have this as source
 	if( (rmc2 = rmr_init( ":6789", 1024, FL_NOTHREAD )) == NULL ) {		// init without starting a thread
 		errors += fail_if_nil( rmc, "rmr_init returned a nil pointer for non-threaded init "  );
 	}
 
+	fprintf( stderr, "<INFO> with RMR_SRC_ID env set, source name in context: (%s)\n", ((uta_ctx_t *) rmc2)->my_name );
+	v = strcmp( ((uta_ctx_t *) rmc2)->my_name, "somehost:6789" );
+	errors += fail_not_equal( v, 0, "source name not set from environment variable (see previous info)" );
 	free_ctx( rmc2 );			// coverage
-
+	
+	unsetenv( "RMR_SRC_ID" );												// context should NOT have our artificial name 
 	if( (rmc2 = rmr_init( NULL, 1024, FL_NOTHREAD )) == NULL ) {			// drive default port selector code
 		errors += fail_if_nil( rmc, "rmr_init returned a nil pointer when driving for default port "  );
 	}
 
+	fprintf( stderr, "<INFO> after unset of RMR_SRC_ID, source name in context: (%s)\n", ((uta_ctx_t *) rmc2)->my_name );
+	v = strcmp( ((uta_ctx_t *) rmc2)->my_name, "somehost:6789" );
+	errors += fail_if_equal( v, 0, "source name smells when removed from environment (see previous info)" );
+	free_ctx( rmc2 );			// attempt to reduce leak check errors
 
 	v = rmr_ready( rmc );		// unknown return; not checking at the moment
 
@@ -440,6 +449,10 @@ static int rmr_api_test( ) {
 	em_set_mtc_msgs( 0 );							// turn off 
 	em_set_rcvdelay( 0 );							// full speed receive rate
 	((uta_ctx_t *)rmc)->shutdown = 1;				// force the mt-reciver attached to the context to stop
+
+	em_set_rcvdelay( 0 );							// let the receive loop spin w/o receives so we drive warning code about queue full
+	sleep( 5 );
+	em_set_rcvdelay( 1 );							// restore slow receive pace for any later tests
 #endif