if (comm->src_proc == process) {
XBT_DEBUG("Found an unfinished send comm %p (detached = %d), state %d, src = %p, dst = %p", comm.get(),
- comm->detached, (int)comm->state, comm->src_proc, comm->dst_proc);
+ comm->detached, (int)comm->state_, comm->src_proc, comm->dst_proc);
comm->src_proc = nullptr;
} else if (comm->dst_proc == process) {
- XBT_DEBUG("Found an unfinished recv comm %p, state %d, src = %p, dst = %p", comm.get(), (int)comm->state,
+ XBT_DEBUG("Found an unfinished recv comm %p, state %d, src = %p, dst = %p", comm.get(), (int)comm->state_,
comm->src_proc, comm->dst_proc);
comm->dst_proc = nullptr;
process->comms.remove(process->waiting_synchro);
comm->cancel();
// Remove first occurrence of &process->simcall:
- auto i = boost::range::find(process->waiting_synchro->simcalls, &process->simcall);
- if (i != process->waiting_synchro->simcalls.end())
- process->waiting_synchro->simcalls.remove(&process->simcall);
+ auto i = boost::range::find(process->waiting_synchro->simcalls_, &process->simcall);
+ if (i != process->waiting_synchro->simcalls_.end())
+ process->waiting_synchro->simcalls_.remove(&process->simcall);
} else if (sleep != nullptr) {
SIMIX_process_sleep_destroy(process->waiting_synchro);
if (process != simcall->issuer) {
SIMIX_simcall_answer(simcall);
} else {
- sync_suspend->simcalls.push_back(simcall);
+ sync_suspend->simcalls_.push_back(simcall);
process->waiting_synchro = sync_suspend;
process->waiting_synchro->suspend();
}
return;
}
smx_activity_t sync = SIMIX_process_join(simcall->issuer, process, timeout);
- sync->simcalls.push_back(simcall);
+ sync->simcalls_.push_back(simcall);
simcall->issuer->waiting_synchro = sync;
}
return;
}
smx_activity_t sync = simcall->issuer->sleep(duration);
- sync->simcalls.push_back(simcall);
+ sync->simcalls_.push_back(simcall);
simcall->issuer->waiting_synchro = sync;
}