CpuModelPtr surf_cpu_model_pm;
CpuModelPtr surf_cpu_model_vm;
+/*************
+ * Callbacks *
+ *************/
+
+CpuPtr getActionCpu(CpuActionPtr action) {
+ return static_cast<CpuPtr>(lmm_constraint_id(lmm_get_cnst_from_var
+ (action->getModel()->getMaxminSystem(),
+ action->getVariable(), 0)));
+}
+
+surf_callback(void, CpuPtr) cpuCreatedCallbacks;
+surf_callback(void, CpuPtr) cpuDestructedCallbacks;
+surf_callback(void, CpuPtr) cpuStateChangedCallbacks;
+surf_callback(void, CpuActionPtr) cpuActionStateChangedCallbacks;
+
/*********
* Model *
*********/
action->finish();
XBT_CDEBUG(surf_kernel, "Action %p finished", action);
- action->updateEnergy();
-
/* set the remains to 0 due to precision problems when updating the remaining amount */
action->setRemains(0);
action->setState(SURF_ACTION_DONE);
action->updateMaxDuration(delta);
- if ((action->getRemains() <= 0) &&
+ if ((action->getRemainsNoUpdate() <= 0) &&
(lmm_get_variable_weight(action->getVariable()) > 0)) {
action->finish();
action->setState(SURF_ACTION_DONE);
action->finish();
action->setState(SURF_ACTION_DONE);
}
- action->updateEnergy();
}
return;
* Resource *
************/
+Cpu::Cpu(){
+ surf_callback_emit(cpuCreatedCallbacks, this);
+}
+
Cpu::Cpu(ModelPtr model, const char *name, xbt_dict_t props,
int core, double powerPeak, double powerScale)
: Resource(model, name, props)
, m_powerScale(powerScale)
, p_constraintCore(NULL)
, p_constraintCoreId(NULL)
-{}
+{
+ surf_callback_emit(cpuCreatedCallbacks, this);
+}
Cpu::Cpu(ModelPtr model, const char *name, xbt_dict_t props,
lmm_constraint_t constraint, int core, double powerPeak, double powerScale)
, m_powerPeak(powerPeak)
, m_powerScale(powerScale)
{
+ surf_callback_emit(cpuCreatedCallbacks, this);
/* At now, we assume that a VM does not have a multicore CPU. */
if (core > 1)
xbt_assert(model == surf_cpu_model_pm);
}
Cpu::~Cpu(){
- if (getModel()->getUpdateMechanism() != UM_UNDEFINED){
+ surf_callback_emit(cpuDestructedCallbacks, this);
+ if (p_constraintCoreId){
for (int i = 0; i < m_core; i++) {
xbt_free(p_constraintCoreId[i]);
}
xbt_free(p_constraintCore);
- xbt_free(p_constraintCoreId);
}
+ if (p_constraintCoreId)
+ xbt_free(p_constraintCoreId);
}
double Cpu::getSpeed(double load)
return m_core;
}
+void Cpu::setState(e_surf_resource_state_t state)
+{
+ Resource::setState(state);
+ surf_callback_emit(cpuStateChangedCallbacks, this);
+}
/**********
* Action *
**********/
if (cpu->getModel()->getUpdateMechanism() == UM_LAZY) {
/* FIXME (hypervisor): Do we need to do something for the LAZY mode? */
}
-
XBT_OUT();
}
+
+void CpuAction::setState(e_surf_action_state_t state){
+ Action::setState(state);
+ surf_callback_emit(cpuActionStateChangedCallbacks, this);
+}