X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/962510fd94a2c10c6873d41acdf2798a8af7f706..9960ea202c197830987b497fd1d2619c887ea9eb:/src/msg/msg_vm.cpp diff --git a/src/msg/msg_vm.cpp b/src/msg/msg_vm.cpp index a18f43c7d5..1a5a9ad539 100644 --- a/src/msg/msg_vm.cpp +++ b/src/msg/msg_vm.cpp @@ -114,12 +114,14 @@ msg_vm_t MSG_vm_create(msg_host_t pm, const char* name, int coreAmount, int rams msg_vm_t vm = new simgrid::s4u::VirtualMachine(name, pm, coreAmount); s_vm_params_t params; - memset(¶ms, 0, sizeof(params)); - params.ramsize = static_cast(ramsize) * 1024 * 1024; - params.devsize = 0; - params.skip_stage2 = 0; + params.ncpus = 0; + params.ramsize = static_cast(ramsize) * 1024 * 1024; + params.overcommit = 0; + params.devsize = 0; + params.skip_stage1 = 0; + params.skip_stage2 = 0; params.max_downtime = 0.03; - params.mig_speed = static_cast(mig_netspeed) * 1024 * 1024; // mig_speed + params.mig_speed = static_cast(mig_netspeed) * 1024 * 1024; // mig_speed params.dp_intensity = static_cast(dp_intensity) / 100; params.dp_cap = params.ramsize * 0.9; // assume working set memory is 90% of ramsize @@ -185,10 +187,9 @@ void MSG_vm_start(msg_vm_t vm) { vm->start(); if (TRACE_msg_vm_is_enabled()) { - container_t vm_container = simgrid::instr::Container::byName(vm->getName()); - simgrid::instr::Type* state = vm_container->type_->byName("MSG_VM_STATE"); + simgrid::instr::StateType* state = simgrid::instr::Container::byName(vm->getName())->getState("MSG_VM_STATE"); state->addEntityValue("start", "0 0 1"); // start is blue - new simgrid::instr::PushStateEvent(MSG_get_clock(), vm_container, state, state->getEntityValue("start")); + state->pushEvent("start"); } } @@ -293,10 +294,8 @@ static int migration_rx_fun(int argc, char *argv[]) counter++; // start link - container_t msg = simgrid::instr::Container::byName(vm->getName()); - simgrid::instr::Type* type = simgrid::instr::Type::getRootType()->byName("MSG_VM_LINK"); - new simgrid::instr::StartLinkEvent(MSG_get_clock(), simgrid::instr::Container::getRootContainer(), type, msg, "M", - key); + container_t msg = simgrid::instr::Container::byName(vm->getName()); + simgrid::instr::Container::getRoot()->getLink("MSG_VM_LINK")->startEvent(msg, "M", key); // destroy existing container of this vm container_t existing_container = simgrid::instr::Container::byName(vm->getName()); @@ -308,9 +307,7 @@ static int migration_rx_fun(int argc, char *argv[]) // end link msg = simgrid::instr::Container::byName(vm->getName()); - type = simgrid::instr::Type::getRootType()->byName("MSG_VM_LINK"); - new simgrid::instr::EndLinkEvent(MSG_get_clock(), simgrid::instr::Container::getRootContainer(), type, msg, "M", - key); + simgrid::instr::Container::getRoot()->getLink("MSG_VM_LINK")->endEvent(msg, "M", key); } // Inform the SRC that the migration has been correctly performed @@ -768,10 +765,9 @@ void MSG_vm_suspend(msg_vm_t vm) XBT_DEBUG("vm_suspend done"); if (TRACE_msg_vm_is_enabled()) { - container_t vm_container = simgrid::instr::Container::byName(vm->getName()); - simgrid::instr::Type* state = vm_container->type_->byName("MSG_VM_STATE"); + simgrid::instr::StateType* state = simgrid::instr::Container::byName(vm->getName())->getState("MSG_VM_STATE"); state->addEntityValue("suspend", "1 0 0"); // suspend is red - new simgrid::instr::PushStateEvent(MSG_get_clock(), vm_container, state, state->getEntityValue("suspend")); + state->pushEvent("suspend"); } } @@ -784,11 +780,8 @@ void MSG_vm_resume(msg_vm_t vm) { vm->pimpl_vm_->resume(); - if (TRACE_msg_vm_is_enabled()) { - container_t vm_container = simgrid::instr::Container::byName(vm->getName()); - simgrid::instr::Type* type = vm_container->type_->byName("MSG_VM_STATE"); - new simgrid::instr::PopStateEvent(MSG_get_clock(), vm_container, type); - } + if (TRACE_msg_vm_is_enabled()) + simgrid::instr::Container::byName(vm->getName())->getState("MSG_VM_STATE")->popEvent(); } /** @brief Get the physical host of a given VM.