X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fapp_test%2Fsender.c;fp=test%2Fapp_test%2Fsender.c;h=74149bc751b3064f924b5ccbdef11291b1859910;hb=a68562a02028434a87149d5996b291e83d33be51;hp=994c59140f43359f4d788598b717a04920a156c2;hpb=39a4b3f6c7b15bde074d68023cf5fe1901d40996;p=ric-plt%2Flib%2Frmr.git diff --git a/test/app_test/sender.c b/test/app_test/sender.c index 994c591..74149bc 100644 --- a/test/app_test/sender.c +++ b/test/app_test/sender.c @@ -211,6 +211,9 @@ int main( int argc, char** argv ) { sbuf->len = strlen( sbuf->payload ) + 1; // our receiver likely wants a nice acsii-z string sbuf->state = 0; + + fprintf( stderr, " sending msg type %d\n", sbuf->mtype ); + sbuf = rmr_send_msg( mrc, sbuf ); // send it (send returns an empty payload on success, or the original payload on fail/retry) switch( sbuf->state ) { @@ -285,7 +288,7 @@ int main( int argc, char** argv ) { } fprintf( stderr, " draining begins\n" ); - timeout = time( NULL ) + 20; // allow 20 seconds for the pipe to drain from the receiver + timeout = time( NULL ) + 10; // allow 10 seconds for the pipe to drain from the receiver while( time( NULL ) < timeout ) { if( rcv_fd >= 0 ) { while( (nready = epoll_wait( ep_fd, events, 1, 100 )) > 0 ) { // if something ready to receive (non-blocking check) @@ -314,7 +317,7 @@ int main( int argc, char** argv ) { pass = 0; } - fprintf( stderr, " [%s] sent=%d rcvd=%d rts-ok=%d failures=%d retries=%d\n", + fprintf( stderr, " [%s] sent=%d rcvd=%d rts-ok=%d failures=%d retries=%d\n", pass ? "PASS" : "FAIL", count, rcvd_count, rts_ok, fail_count, rt_count ); rmr_close( mrc );