+const double virt_overhead = 1; // 0.95
+
+static void hostStateChange(s4u::Host& host)
+{
+ if (not host.is_on()) { // just turned off.
+ std::vector<s4u::VirtualMachine*> trash;
+ /* Find all VMs living on that host */
+ for (s4u::VirtualMachine* const& vm : VirtualMachineImpl::allVms_)
+ if (vm->get_pm() == &host)
+ trash.push_back(vm);
+ for (s4u::VirtualMachine* vm : trash)
+ vm->shutdown();
+ }
+}
+
+static void addActiveTask(kernel::activity::ActivityImplPtr exec)
+{
+ s4u::VirtualMachine* vm =
+ dynamic_cast<s4u::VirtualMachine*>(boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(exec)->host_);
+ if (vm != nullptr) {
+ VirtualMachineImpl *vm_impl = vm->get_impl();
+ vm_impl->active_tasks_ = vm_impl->active_tasks_ + 1;
+ vm_impl->update_action_weight();
+ }
+}
+
+static void removeActiveTask(kernel::activity::ActivityImplPtr exec)
+{
+ s4u::VirtualMachine* vm =
+ dynamic_cast<s4u::VirtualMachine*>(boost::static_pointer_cast<simgrid::kernel::activity::ExecImpl>(exec)->host_);
+ if (vm != nullptr) {
+ VirtualMachineImpl *vm_impl = vm->get_impl();
+ vm_impl->active_tasks_ = vm_impl->active_tasks_ - 1;
+ vm_impl->update_action_weight();
+ }
+}
+
+VMModel::VMModel()
+{
+ all_existing_models.push_back(this);
+ s4u::Host::on_state_change.connect(hostStateChange);
+ kernel::activity::ExecImpl::on_creation.connect(addActiveTask);
+ kernel::activity::ExecImpl::on_completion.connect(removeActiveTask);
+ kernel::activity::ActivityImpl::on_resumed.connect(addActiveTask);
+ kernel::activity::ActivityImpl::on_suspended.connect(removeActiveTask);
+}