/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
+#include "simgrid/s4u/engine.hpp"
#include "src/instr/instr_private.h"
#include "src/plugins/vm/VirtualMachineImpl.hpp"
/* FIXME: Moved this test to here to avoid stopping simulation if there are actions running on cpus and all cpus are with availability = 0.
* This may cause an infinite loop if one cpu has a trace with periodicity = 0 and the other a trace with periodicity > 0.
* The options are: all traces with same periodicity(0 or >0) or we need to change the way how the events are managed */
- if (time_delta == -1.0) {
+ if (time_delta < 0) {
XBT_DEBUG("No next event at all. Bail out now.");
return -1.0;
}
for (auto model : *all_existing_models) {
model->updateActionsState(NOW, time_delta);
}
+ simgrid::s4u::onTimeAdvance(time_delta);
TRACE_paje_dump_buffer (0);
/*********
* MODEL *
*********/
-
-surf_action_t surf_model_extract_done_action_set(surf_model_t model){
- if (model->getDoneActionSet()->empty())
+static surf_action_t ActionListExtract(simgrid::surf::ActionList* list)
+{
+ if (list->empty())
return nullptr;
- surf_action_t res = &model->getDoneActionSet()->front();
- model->getDoneActionSet()->pop_front();
+ surf_action_t res = &list->front();
+ list->pop_front();
return res;
}
+surf_action_t surf_model_extract_done_action_set(surf_model_t model)
+{
+ return ActionListExtract(model->getDoneActionSet());
+}
+
surf_action_t surf_model_extract_failed_action_set(surf_model_t model){
- if (model->getFailedActionSet()->empty())
- return nullptr;
- surf_action_t res = &model->getFailedActionSet()->front();
- model->getFailedActionSet()->pop_front();
- return res;
+ return ActionListExtract(model->getFailedActionSet());
}
int surf_model_running_action_set_size(surf_model_t model){