X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b4ace96f8a501a6659817d9741aeb103cbcfd2c4..078b9d03609d4f0072a2d968f792bbdd9a1fe08d:/src/plugins/vm/VirtualMachineImpl.cpp diff --git a/src/plugins/vm/VirtualMachineImpl.cpp b/src/plugins/vm/VirtualMachineImpl.cpp index 2776c8dfef..e499ff03d7 100644 --- a/src/plugins/vm/VirtualMachineImpl.cpp +++ b/src/plugins/vm/VirtualMachineImpl.cpp @@ -108,7 +108,7 @@ VMModel::VMModel() kernel::activity::ActivityImpl::on_suspended.connect(remove_active_activity); } -double VMModel::next_occuring_event(double now) +double VMModel::next_occurring_event(double now) { /* TODO: update action's cost with the total cost of processes on the VM. */ @@ -149,7 +149,7 @@ double VMModel::next_occuring_event(double now) } /* 2. Ready. Get the next occurring event */ - return surf_cpu_model_vm->next_occuring_event(now); + return surf_cpu_model_vm->next_occurring_event(now); } /************ @@ -200,16 +200,16 @@ void VirtualMachineImpl::suspend(smx_actor_t issuer) throw VmFailureException(XBT_THROW_POINT, xbt::string_printf("Actor %s cannot suspend the VM %s in which it runs", issuer->get_cname(), piface_->get_cname())); - XBT_DEBUG("suspend VM(%s), where %zu processes exist", piface_->get_cname(), process_list_.size()); + XBT_DEBUG("suspend VM(%s), where %zu actors exist", piface_->get_cname(), get_actor_count()); action_->suspend(); - for (auto& smx_process : process_list_) { - XBT_DEBUG("suspend %s", smx_process.get_cname()); - smx_process.suspend(); + for (auto& actor : get_all_actors()) { + XBT_DEBUG("suspend %s", actor->get_cname()); + actor->suspend(); } - XBT_DEBUG("suspend all processes on the VM done done"); + XBT_DEBUG("suspend all actors on the VM done done"); vm_state_ = s4u::VirtualMachine::state::SUSPENDED; } @@ -220,13 +220,13 @@ void VirtualMachineImpl::resume() throw VmFailureException(XBT_THROW_POINT, xbt::string_printf("Cannot resume VM %s: it was not suspended", piface_->get_cname())); - XBT_DEBUG("Resume VM %s, containing %zu processes.", piface_->get_cname(), process_list_.size()); + XBT_DEBUG("Resume VM %s, containing %zu actors.", piface_->get_cname(), get_actor_count()); action_->resume(); - for (auto& smx_process : process_list_) { - XBT_DEBUG("resume %s", smx_process.get_cname()); - smx_process.resume(); + for (auto& actor : get_all_actors()) { + XBT_DEBUG("resume %s", actor->get_cname()); + actor->resume(); } vm_state_ = s4u::VirtualMachine::state::RUNNING; @@ -259,12 +259,12 @@ void VirtualMachineImpl::shutdown(smx_actor_t issuer) XBT_VERB("Shutting down the VM %s even if it's not running but %s", piface_->get_cname(), stateName); } - XBT_DEBUG("shutdown VM %s, that contains %zu processes", piface_->get_cname(), process_list_.size()); + XBT_DEBUG("shutdown VM %s, that contains %zu actors", piface_->get_cname(), get_actor_count()); - for (auto& smx_process : process_list_) { - XBT_DEBUG("kill %s@%s on behalf of %s which shutdown that VM.", smx_process.get_cname(), - smx_process.get_host()->get_cname(), issuer->get_cname()); - issuer->kill(&smx_process); + for (auto& actor : get_all_actors()) { + XBT_DEBUG("kill %s@%s on behalf of %s which shutdown that VM.", actor->get_cname(), actor->get_host()->get_cname(), + issuer->get_cname()); + issuer->kill(actor->get_impl()); } set_state(s4u::VirtualMachine::state::DESTROYED); @@ -283,7 +283,7 @@ void VirtualMachineImpl::set_physical_host(s4u::Host* destination) std::string pm_name_dst = destination->get_name(); /* update net_elm with that of the destination physical host */ - piface_->pimpl_netpoint = destination->pimpl_netpoint; + piface_->set_netpoint(destination->get_netpoint()); physical_host_ = destination;