static_cast<simgrid::kernel::activity::Comm*>(temp_synchro.getBuffer());
char* remote_name = mc_model_checker->process().read<char*>(
- (std::uint64_t)(synchro->mbox ? &synchro->mbox->name : &synchro->mbox_cpy->name));
+ (std::uint64_t)(synchro->mbox ? &synchro->mbox->name_ : &synchro->mbox_cpy->name_));
pattern->rdv = mc_model_checker->process().read_string(remote_name);
pattern->src_proc = mc_model_checker->process().resolveActor(simgrid::mc::remote(synchro->src_proc))->pid;
pattern->src_host = MC_smx_actor_get_host_name(issuer);
- struct s_smpi_mpi_request mpi_request =
- mc_model_checker->process().read<s_smpi_mpi_request>(
+ simgrid::smpi::Request mpi_request =
+ mc_model_checker->process().read<simgrid::smpi::Request>(
(std::uint64_t) simcall_comm_isend__get__data(request));
- pattern->tag = mpi_request.tag;
+ pattern->tag = mpi_request.tag();
if (synchro->src_buff != nullptr){
pattern->data.resize(synchro->src_buff_size);
pattern->data.data(), pattern->data.size(),
remote(synchro->src_buff));
}
- if(mpi_request.detached){
+ if(mpi_request.detached()){
if (!this->initial_communications_pattern_done) {
/* Store comm pattern */
simgrid::mc::PatternCommunicationList* list = xbt_dynar_get_as(
pattern->type = simgrid::mc::PatternCommunicationType::receive;
pattern->comm_addr = simcall_comm_irecv__get__result(request);
- struct s_smpi_mpi_request mpi_request;
+ simgrid::smpi::Request mpi_request;
mc_model_checker->process().read(
- &mpi_request, remote((struct s_smpi_mpi_request*)simcall_comm_irecv__get__data(request)));
- pattern->tag = mpi_request.tag;
+ &mpi_request, remote((simgrid::smpi::Request*)simcall_comm_irecv__get__data(request)));
+ pattern->tag = mpi_request.tag();
simgrid::mc::Remote<simgrid::kernel::activity::Comm> temp_comm;
mc_model_checker->process().read(temp_comm, remote(
simgrid::kernel::activity::Comm* comm = temp_comm.getBuffer();
char* remote_name;
- mc_model_checker->process().read(&remote_name,
- remote(comm->mbox ? &comm->mbox->name : &comm->mbox_cpy->name));
+ mc_model_checker->process().read(&remote_name, remote(comm->mbox ? &comm->mbox->name_ : &comm->mbox_cpy->name_));
pattern->rdv = mc_model_checker->process().read_string(remote_name);
pattern->dst_proc = mc_model_checker->process().resolveActor(simgrid::mc::remote(comm->dst_proc))->pid;
pattern->dst_host = MC_smx_actor_get_host_name(issuer);
bool compare_snapshots = all_communications_are_finished()
&& this->initial_communications_pattern_done;
- if (_sg_mc_visited == 0
- || (visited_state = visitedStates_.addVisitedState(
- expandedStatesCount_, next_state.get(), compare_snapshots)) == nullptr) {
+ if (_sg_mc_max_visited_states == 0 ||
+ (visited_state = visitedStates_.addVisitedState(expandedStatesCount_, next_state.get(), compare_snapshots)) ==
+ nullptr) {
/* Get enabled actors and insert them in the interleave set of the next state */
for (auto& actor : mc_model_checker->process().actors())
state->num, next_state->num, req_str.c_str());
} else if (dot_output != nullptr)
- fprintf(dot_output, "\"%d\" -> \"%d\" [%s];\n",
- state->num, visited_state->other_num == -1 ? visited_state->num : visited_state->other_num, req_str.c_str());
+ fprintf(dot_output, "\"%d\" -> \"%d\" [%s];\n", state->num,
+ visited_state->original_num == -1 ? visited_state->num : visited_state->original_num, req_str.c_str());
stack_.push_back(std::move(next_state));
if (stack_.size() > (std::size_t) _sg_mc_max_depth)
XBT_WARN("/!\\ Max depth reached ! /!\\ ");
else if (visited_state != nullptr)
- XBT_DEBUG("State already visited (equal to state %d), exploration stopped on this path.", visited_state->other_num == -1 ? visited_state->num : visited_state->other_num);
+ XBT_DEBUG("State already visited (equal to state %d), exploration stopped on this path.",
+ visited_state->original_num == -1 ? visited_state->num : visited_state->original_num);
else
XBT_DEBUG("There are no more processes to interleave. (depth %zi)",
stack_.size());