else
cond.wait(mutex);
}
- TRY_CLEANUP {
- mutex.release();
- }
CATCH (e) {
if (e.category != timeout_error)
RETHROW;
}
bool pop_was_successful = queue.try_pop(task);
xbt_assert(pop_was_successful);
- } else {
- mutex.release();
}
+ mutex.release();
}
msg = static_cast<message*>(MSG_task_get_data(task));
from = MSG_task_get_source(task);