Release 221

[ric-plt/lib/rmr.git] / test / test_nng_em.c

diff --git a/test/test_nng_em.c b/test/test_nng_em.c
index 88f5966..fc60301 100644 (file)
--- 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;
 }