X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/872d65264714799b25eb231609c3f05bae3d03dc..61ab70f5ec5869d57fb0712101280e304d38dcbc:/src/mc/CommunicationDeterminismChecker.cpp diff --git a/src/mc/CommunicationDeterminismChecker.cpp b/src/mc/CommunicationDeterminismChecker.cpp index dc3ac5f7ad..e0f7a77e00 100644 --- a/src/mc/CommunicationDeterminismChecker.cpp +++ b/src/mc/CommunicationDeterminismChecker.cpp @@ -101,7 +101,7 @@ static void update_comm_pattern( simgrid::mc::Remote temp_comm; mc_model_checker->process().read(temp_comm, comm_addr); simgrid::simix::Comm* comm = - static_cast(temp_comm.data()); + static_cast(temp_comm.getBuffer()); smx_process_t src_proc = mc_model_checker->process().resolveProcess( simgrid::mc::remote(comm->src_proc)); @@ -199,7 +199,7 @@ void CommunicationDeterminismChecker::get_comm_pattern(xbt_dynar_t list, smx_sim mc_model_checker->process().read(temp_synchro, remote( static_cast(pattern->comm_addr))); simgrid::simix::Comm* synchro = - static_cast(temp_synchro.data()); + static_cast(temp_synchro.getBuffer()); char* remote_name = mc_model_checker->process().read( (std::uint64_t)(synchro->mbox ? &synchro->mbox->name : &synchro->mbox_cpy->name)); @@ -247,8 +247,7 @@ void CommunicationDeterminismChecker::get_comm_pattern(xbt_dynar_t list, smx_sim simgrid::mc::Remote temp_comm; mc_model_checker->process().read(temp_comm, remote( static_cast(pattern->comm_addr))); - simgrid::simix::Comm* comm = - static_cast(temp_comm.data()); + simgrid::simix::Comm* comm = temp_comm.getBuffer(); char* remote_name; mc_model_checker->process().read(&remote_name, @@ -393,8 +392,8 @@ void CommunicationDeterminismChecker::prepare() /* Get an enabled process and insert it in the interleave set of the initial state */ for (auto& p : mc_model_checker->process().simix_processes()) - if (simgrid::mc::process_is_enabled(&p.copy)) - initial_state->interleave(&p.copy); + if (simgrid::mc::process_is_enabled(p.copy.getBuffer())) + initial_state->interleave(p.copy.getBuffer()); stack_.push_back(std::move(initial_state)); } @@ -520,7 +519,7 @@ int CommunicationDeterminismChecker::main(void) std::unique_ptr(MC_state_new(++expandedStatesCount_)); /* If comm determinism verification, we cannot stop the exploration if - some communications are not finished (at least, data are transfered). + some communications are not finished (at least, data are transferred). These communications are incomplete and they cannot be analyzed and compared with the initial pattern. */ bool compare_snapshots = all_communications_are_finished() @@ -532,8 +531,8 @@ int CommunicationDeterminismChecker::main(void) /* Get enabled processes and insert them in the interleave set of the next state */ for (auto& p : mc_model_checker->process().simix_processes()) - if (simgrid::mc::process_is_enabled(&p.copy)) - next_state->interleave(&p.copy); + if (simgrid::mc::process_is_enabled(p.copy.getBuffer())) + next_state->interleave(p.copy.getBuffer()); if (dot_output != nullptr) fprintf(dot_output, "\"%d\" -> \"%d\" [%s];\n",