X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=test%2Fapp_test%2Freceiver.c;fp=test%2Fapp_test%2Freceiver.c;h=6f739a568270acf318001056232c7e1aee69ce8b;hb=de63b2996a1144b55ccaaf7ad552170d18478d5c;hp=3cf1498035f3d0873b1016e2ca2f3aa4efc9725c;hpb=367cd53d8ab2523f6197740c77ec92eb928fed39;p=ric-plt%2Flib%2Frmr.git

diff --git a/test/app_test/receiver.c b/test/app_test/receiver.c
index 3cf1498..6f739a5 100644
--- a/test/app_test/receiver.c
+++ b/test/app_test/receiver.c
@@ -198,6 +198,9 @@ int main( int argc, char** argv ) {
 					while( rt_count > 0 && msg != NULL && msg->state == RMR_ERR_RETRY ) {		// to work right in nano we need this :(
 						if( ack_count < 1 ) {									// 1st ack, so we need to connect, and we'll wait for that
 							sleep( 1 );
+							if( rt_count > 5 ) {
+								rt_count = 5;									// but only for 5sec; not 1000sec!
+							}
 						}
 						rt_count--;
 						msg = rmr_rts_msg( mrc, msg );							// we don't try to resend if this returns retry
@@ -206,6 +209,8 @@ int main( int argc, char** argv ) {
 						ack_count++;
 					}
 				}
+
+				timeout = time( NULL ) + 10;					// extend timeout to 10s past last received message
 			}
 		}