diff --git a/test/apps/iodemo/ucx_wrapper.cc b/test/apps/iodemo/ucx_wrapper.cc index 7d1d940d6d1..1027f424209 100644 --- a/test/apps/iodemo/ucx_wrapper.cc +++ b/test/apps/iodemo/ucx_wrapper.cc @@ -223,9 +223,10 @@ void UcxContext::progress(unsigned count) { int i = 0; - while ((i++ < count) && progress_worker_event()) { + progress_worker_event(); + do { progress_io_message(); - } + } while ((++i < count) && progress_worker_event()); progress_timed_out_conns(); progress_conn_requests();