* Callbacks *
*************/
-simgrid::xbt::signal<void(simgrid::surf::VirtualMachine*)> VMCreatedCallbacks;
-simgrid::xbt::signal<void(simgrid::surf::VirtualMachine*)> VMDestructedCallbacks;
-simgrid::xbt::signal<void(simgrid::surf::VirtualMachine*)> VMStateChangedCallbacks;
+simgrid::xbt::signal<void(simgrid::surf::VirtualMachine*)> onVmCreation;
+simgrid::xbt::signal<void(simgrid::surf::VirtualMachine*)> onVmDestruction;
+simgrid::xbt::signal<void(simgrid::surf::VirtualMachine*)> onVmStateChange;
/*********
* Model *
*********/
-VMModel::vm_list_t VMModel::ws_vms;
+std::deque<VirtualMachine*> VirtualMachine::allVms_;
/************
* Resource *
: HostImpl(model, name, nullptr, nullptr, nullptr)
, hostPM_(hostPM)
{
- VMModel::ws_vms.push_back(*this);
- simgrid::s4u::Host::by_name_or_create(name)->extension_set<simgrid::surf::HostImpl>(this);
+ allVms_.push_back(this);
+ piface_ = simgrid::s4u::Host::by_name_or_create(name);
+ piface_->extension_set<simgrid::surf::HostImpl>(this);
}
/*
*/
VirtualMachine::~VirtualMachine()
{
- VMDestructedCallbacks(this);
- VMModel::ws_vms.erase(VMModel::vm_list_t::s_iterator_to(*this));
+ onVmDestruction(this);
+ allVms_.erase( find(allVms_.begin(), allVms_.end(), this) );
+
/* Free the cpu_action of the VM. */
XBT_ATTRIB_UNUSED int ret = action_->unref();
xbt_assert(ret == 1, "Bug: some resource still remains");
}
e_surf_vm_state_t VirtualMachine::getState() {
- return p_vm_state;
+ return vmState_;
}
void VirtualMachine::setState(e_surf_vm_state_t state) {
- p_vm_state = state;
+ vmState_ = state;
}
void VirtualMachine::turnOn() {
if (isOff()) {
Resource::turnOn();
- VMStateChangedCallbacks(this);
+ onVmStateChange(this);
}
}
void VirtualMachine::turnOff() {
if (isOn()) {
Resource::turnOff();
- VMStateChangedCallbacks(this);
+ onVmStateChange(this);
}
}
+void VirtualMachine::suspend()
+{
+ action_->suspend();
+ vmState_ = SURF_VM_STATE_SUSPENDED;
+}
+
+void VirtualMachine::resume()
+{
+ action_->resume();
+ vmState_ = SURF_VM_STATE_RUNNING;
+}
+
+void VirtualMachine::save()
+{
+ vmState_ = SURF_VM_STATE_SAVING;
+ action_->suspend();
+ vmState_ = SURF_VM_STATE_SAVED;
+}
+
+void VirtualMachine::restore()
+{
+ vmState_ = SURF_VM_STATE_RESTORING;
+ action_->resume();
+ vmState_ = SURF_VM_STATE_RUNNING;
+}
/** @brief returns the physical machine on which the VM is running **/
sg_host_t VirtualMachine::getPm() {