X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Ftest_nng_em.c;h=fc6030146a352c2ff2c8c4d0cce9fcbe8cd80a87;hb=ab6d04ce30514b16ba5821fcc788157b4779a4a3;hp=88f5966fc0ce633d393e0e5d65e01161930bc678;hpb=68d09fa5028e47e763c44c30647da31e77eda64a;p=ric-plt%2Flib%2Frmr.git

diff --git a/test/test_nng_em.c b/test/test_nng_em.c
index 88f5966..fc60301 100644
--- a/test/test_nng_em.c
+++ b/test/test_nng_em.c
@@ -190,6 +190,11 @@ static void em_set_rcvcount( int v ) {
 }
 
 static void em_set_rcvdelay( int v ) {
+	if( v < 0 ) {
+		fprintf( stderr, "<EM>   ##ERR## attempt to set receive delay with invalid value was ignored: %d seconds\n", v );
+		return;
+	}
+	fprintf( stderr, "<EM>   receive delay is now %d seconds\n", v );
 	rcv_delay = v;
 }
 
@@ -320,10 +325,10 @@ static int em_nng_sub0_open(nng_socket * s ) {
 	return return_value;
 }
 static int em_nng_recv(nng_socket s, void * v, size_t * t, int i ) {
-
 	return return_value;
 }
 static int em_nng_send( nng_socket s, void* m, int l, int f ) {
+	free( m );					// we must ditch the message as nng does (or reuses)
 	return return_value;
 }
 
@@ -365,13 +370,11 @@ static int em_nng_msg_alloc( nng_msg** mp, size_t l ) {
 */
 static void em_nng_free( void* p, size_t l ) {
 	if( p ) {
-		//fprintf( stderr, ">>>>> not freed: %p\n", p );
 		free( p );
 	}
 }
 static void em_nng_msg_free( void* p ) {
 	if( p ) {
-		//fprintf( stderr, ">>>>> not freed: %p\n", p );
 		free( p );
 	}
 }
@@ -542,6 +545,7 @@ static int em_nn_recvmsg (int s, struct nn_msghdr *msghdr, int flags ) {
 }
 
 static void em_nn_freemsg( void* ptr ) {
+	free( ptr );
 	return;
 }