bool comm_ready = false;
if (not pimpl_->comm_queue_.empty()) {
comm_ready = pimpl_->comm_queue_.front()->state_ == SIMIX_DONE;
- }
- if (!comm_ready && pimpl_->permanent_receiver_ && not pimpl_->done_comm_queue_.empty()) {
+
+ } else if (pimpl_->permanent_receiver_ && not pimpl_->done_comm_queue_.empty()) {
comm_ready = pimpl_->done_comm_queue_.front()->state_ == SIMIX_DONE;
}
return comm_ready;
c->set_remaining(simulated_size_in_bytes);
c->set_src_data(payload);
// c->start() is optional.
- c->wait(timeout);
+ c->wait_for(timeout);
}
s4u::CommPtr Mailbox::get_init()
void* res = nullptr;
CommPtr c = get_init();
c->set_dst_data(&res, sizeof(res));
- c->wait(timeout);
+ c->wait_for(timeout);
return res;
}
} // namespace s4u