} else
switch (actor->simcall_.call_) {
case Simcall::COMM_WAITANY:
- state->transition_.times_considered_ = -1;
while (procstate->get_times_considered() < simcall_comm_waitany__get__count(&actor->simcall_)) {
if (simgrid::mc::request_is_enabled_by_idx(process, &actor->simcall_, procstate->get_times_considered())) {
state->transition_.times_considered_ = procstate->get_times_considered_and_inc();
break;
case Simcall::COMM_TESTANY:
- state->transition_.times_considered_ = -1;
while (procstate->get_times_considered() < simcall_comm_testany__get__count(&actor->simcall_)) {
if (simgrid::mc::request_is_enabled_by_idx(process, &actor->simcall_, procstate->get_times_considered())) {
state->transition_.times_considered_ = procstate->get_times_considered_and_inc();
else if (act->src_actor_.get() == nullptr && act->state_ == simgrid::kernel::activity::State::READY &&
act->detached())
state->transition_.times_considered_ = 0; // OK
- else
- state->transition_.times_considered_ = -1; // timeout
procstate->set_done();
req = &actor->simcall_;
break;
const simgrid::mc::AddressSpace* address_space)
{
ExpressionContext state;
- state.frame_base = nullptr;
- state.cursor = nullptr;
state.address_space = address_space;
ExpressionStack stack;
simgrid::mc::ActorInformation info;
info.address = simgrid::mc::RemotePtr<simgrid::kernel::actor::ActorImpl>(data[i]);
- info.hostname = nullptr;
process->read_bytes(&info.copy, sizeof(info.copy), remote(data[i]));
target.push_back(std::move(info));
}