X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Ftest_nng_em.c;h=8c6a9ca9507b95cfc8bf9951f120250716676fea;hb=refs%2Fchanges%2F37%2F1037%2F2;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..8c6a9ca 100644
--- a/test/test_nng_em.c
+++ b/test/test_nng_em.c
@@ -320,10 +320,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 +365,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 +540,7 @@ static int em_nn_recvmsg (int s, struct nn_msghdr *msghdr, int flags ) {
 }
 
 static void em_nn_freemsg( void* ptr ) {
+	free( ptr );
 	return;
 }