diff --git a/orte/mca/oob/tcp/oob_tcp_msg.c b/orte/mca/oob/tcp/oob_tcp_msg.c index 21d31a5da7..d36a3017f3 100644 --- a/orte/mca/oob/tcp/oob_tcp_msg.c +++ b/orte/mca/oob/tcp/oob_tcp_msg.c @@ -119,9 +119,8 @@ int mca_oob_tcp_msg_timedwait(mca_oob_tcp_msg_t* msg, int* rc, struct timespec* if(opal_event_progress_thread()) { int rc; OPAL_THREAD_UNLOCK(&msg->msg_lock); - opal_progress(); - /*rc = opal_event_loop(OPAL_EVLOOP_ONCE); - assert(rc >= 0);*/ + rc = opal_event_loop(OPAL_EVLOOP_ONCE); + assert(rc >= 0); OPAL_THREAD_LOCK(&msg->msg_lock); } else { opal_condition_timedwait(&msg->msg_condition, &msg->msg_lock, abstime); @@ -134,7 +133,6 @@ int mca_oob_tcp_msg_timedwait(mca_oob_tcp_msg_t* msg, int* rc, struct timespec* while(msg->msg_complete == false && ((uint32_t)tv.tv_sec <= secs || ((uint32_t)tv.tv_sec == secs && (uint32_t)tv.tv_usec < usecs))) { - /*(void)opal_event_loop(OPAL_EVLOOP_ONCE);*/ opal_progress(); gettimeofday(&tv,NULL); }