#include "xbt/mallocator.h"
#include <stdbool.h>
-#define SD_INITIALISED() (sd_global != NULL)
-#define SD_CHECK_INIT_DONE() xbt_assert(SD_INITIALISED(), "Call SD_init() first");
-
/* Global variables */
typedef struct SD_global {
s_SD_task_t task;
- xbt_assert(!SD_INITIALISED(), "SD_init() already called");
+ xbt_assert(sd_global == NULL, "SD_init() already called");
/* Connect our log channels: that must be done manually under windows */
XBT_LOG_CONNECT(sd_kernel, sd);
s_SD_task_t task;
- if (SD_INITIALISED()) {
- XBT_DEBUG("Recreating the swags...");
- xbt_swag_free(sd_global->not_scheduled_task_set);
- xbt_swag_free(sd_global->schedulable_task_set);
- xbt_swag_free(sd_global->scheduled_task_set);
- xbt_swag_free(sd_global->runnable_task_set);
- xbt_swag_free(sd_global->in_fifo_task_set);
- xbt_swag_free(sd_global->running_task_set);
- xbt_swag_free(sd_global->done_task_set);
- xbt_swag_free(sd_global->failed_task_set);
-
- sd_global->not_scheduled_task_set =
- xbt_swag_new(xbt_swag_offset(task, state_hookup));
- sd_global->schedulable_task_set =
- xbt_swag_new(xbt_swag_offset(task, state_hookup));
- sd_global->scheduled_task_set =
- xbt_swag_new(xbt_swag_offset(task, state_hookup));
- sd_global->runnable_task_set =
- xbt_swag_new(xbt_swag_offset(task, state_hookup));
- sd_global->in_fifo_task_set =
- xbt_swag_new(xbt_swag_offset(task, state_hookup));
- sd_global->running_task_set =
- xbt_swag_new(xbt_swag_offset(task, state_hookup));
- sd_global->done_task_set =
- xbt_swag_new(xbt_swag_offset(task, state_hookup));
- sd_global->failed_task_set =
- xbt_swag_new(xbt_swag_offset(task, state_hookup));
- sd_global->task_number = 0;
+ XBT_DEBUG("Recreating the swags...");
+ xbt_swag_free(sd_global->not_scheduled_task_set);
+ xbt_swag_free(sd_global->schedulable_task_set);
+ xbt_swag_free(sd_global->scheduled_task_set);
+ xbt_swag_free(sd_global->runnable_task_set);
+ xbt_swag_free(sd_global->in_fifo_task_set);
+ xbt_swag_free(sd_global->running_task_set);
+ xbt_swag_free(sd_global->done_task_set);
+ xbt_swag_free(sd_global->failed_task_set);
+
+ sd_global->not_scheduled_task_set =
+ xbt_swag_new(xbt_swag_offset(task, state_hookup));
+ sd_global->schedulable_task_set =
+ xbt_swag_new(xbt_swag_offset(task, state_hookup));
+ sd_global->scheduled_task_set =
+ xbt_swag_new(xbt_swag_offset(task, state_hookup));
+ sd_global->runnable_task_set =
+ xbt_swag_new(xbt_swag_offset(task, state_hookup));
+ sd_global->in_fifo_task_set =
+ xbt_swag_new(xbt_swag_offset(task, state_hookup));
+ sd_global->running_task_set =
+ xbt_swag_new(xbt_swag_offset(task, state_hookup));
+ sd_global->done_task_set =
+ xbt_swag_new(xbt_swag_offset(task, state_hookup));
+ sd_global->failed_task_set =
+ xbt_swag_new(xbt_swag_offset(task, state_hookup));
+ sd_global->task_number = 0;
#ifdef HAVE_JEDULE
- jedule_sd_cleanup();
- jedule_sd_init();
+ jedule_sd_cleanup();
+ jedule_sd_init();
#endif
-
- } else {
- XBT_WARN("SD_application_reinit called before initialization of SimDag");
- /* we cannot use exceptions here because xbt is not running! */
- }
-
}
/**
surf_parse_reset_callbacks();
// Add config callbacks
surf_parse_add_callback_config();
- SD_CHECK_INIT_DONE();
+
parse_platform_file(platform_file);
surf_config_models_create_elms();
unsigned int iter, depcnt;
static int first_time = 1;
- SD_CHECK_INIT_DONE();
-
if (first_time) {
XBT_VERB("Starting simulation...");
if (!sd_global->watch_point_reached && how_long<0){
if (xbt_swag_size(sd_global->done_task_set) < sd_global->task_number){
- XBT_WARN("Simulation is finished but some tasks are still not done");
+ XBT_WARN("Simulation is finished but %d tasks are still not done",
+ (sd_global->task_number - xbt_swag_size(sd_global->done_task_set)));
xbt_swag_foreach_safe (task, task_safe,sd_global->not_scheduled_task_set){
XBT_WARN("%s is in SD_NOT_SCHEDULED state", SD_task_get_name(task));
}
*
* \return the current clock, in second
*/
-double SD_get_clock(void)
-{
- SD_CHECK_INIT_DONE();
-
+double SD_get_clock(void) {
return surf_get_clock();
}
TRACE_surf_release();
#endif
- if (SD_INITIALISED()) {
- xbt_mallocator_free(sd_global->task_mallocator);
+ xbt_mallocator_free(sd_global->task_mallocator);
- XBT_DEBUG("Destroying workstation and link arrays if necessary...");
- if (sd_global->workstation_list != NULL)
- xbt_free(sd_global->workstation_list);
+ XBT_DEBUG("Destroying workstation and link arrays if necessary...");
+ if (sd_global->workstation_list != NULL)
+ xbt_free(sd_global->workstation_list);
- if (sd_global->link_list != NULL)
- xbt_free(sd_global->link_list);
+ if (sd_global->link_list != NULL)
+ xbt_free(sd_global->link_list);
- if (sd_global->recyclable_route != NULL)
- xbt_free(sd_global->recyclable_route);
+ if (sd_global->recyclable_route != NULL)
+ xbt_free(sd_global->recyclable_route);
- XBT_DEBUG("Destroying the swags...");
- xbt_swag_free(sd_global->not_scheduled_task_set);
- xbt_swag_free(sd_global->schedulable_task_set);
- xbt_swag_free(sd_global->scheduled_task_set);
- xbt_swag_free(sd_global->runnable_task_set);
- xbt_swag_free(sd_global->in_fifo_task_set);
- xbt_swag_free(sd_global->running_task_set);
- xbt_swag_free(sd_global->done_task_set);
- xbt_swag_free(sd_global->failed_task_set);
- xbt_swag_free(sd_global->return_set);
+ XBT_DEBUG("Destroying the swags...");
+ xbt_swag_free(sd_global->not_scheduled_task_set);
+ xbt_swag_free(sd_global->schedulable_task_set);
+ xbt_swag_free(sd_global->scheduled_task_set);
+ xbt_swag_free(sd_global->runnable_task_set);
+ xbt_swag_free(sd_global->in_fifo_task_set);
+ xbt_swag_free(sd_global->running_task_set);
+ xbt_swag_free(sd_global->done_task_set);
+ xbt_swag_free(sd_global->failed_task_set);
+ xbt_swag_free(sd_global->return_set);
- XBT_DEBUG("Exiting Surf...");
- surf_exit();
+ XBT_DEBUG("Exiting Surf...");
+ surf_exit();
- xbt_free(sd_global);
- sd_global = NULL;
+ xbt_free(sd_global);
+ sd_global = NULL;
#ifdef HAVE_TRACING
TRACE_end();
jedule_sd_dump();
jedule_sd_cleanup();
#endif
-
- } else {
- XBT_WARN("SD_exit() called, but SimDag is not running");
- /* we cannot use exceptions here because xbt is not running! */
- }
}
/**
SD_link_t link;
const char *name;
- SD_CHECK_INIT_DONE();
- xbt_assert(surf_link != NULL, "surf_link is NULL !");
-
link = xbt_new(s_SD_link_t, 1);
link->surf_link = surf_link;
link->data = data; /* user data */
void **data;
int i;
- SD_CHECK_INIT_DONE();
- xbt_assert(SD_link_get_number() > 0, "There is no link!");
-
if (sd_global->link_list == NULL) { /* this is the first time the function is called */
sd_global->link_list = xbt_new(SD_link_t, link_lib->count);
*/
int SD_link_get_number(void)
{
- SD_CHECK_INIT_DONE();
return link_lib->count;
}
*/
void *SD_link_get_data(SD_link_t link)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(link != NULL, "Invalid parameter");
return link->data;
}
*/
void SD_link_set_data(SD_link_t link, void *data)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(link != NULL, "Invalid parameter");
link->data = data;
}
*/
const char *SD_link_get_name(SD_link_t link)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(link != NULL, "Invalid parameter");
return surf_resource_name(link->surf_link);
}
*/
double SD_link_get_current_bandwidth(SD_link_t link)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(link != NULL, "Invalid parameter");
return surf_workstation_model->extension.workstation.
get_link_bandwidth(link->surf_link);
}
*/
double SD_link_get_current_latency(SD_link_t link)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(link != NULL, "Invalid parameter");
return surf_workstation_model->extension.workstation.
get_link_latency(link->surf_link);
}
*/
e_SD_link_sharing_policy_t SD_link_get_sharing_policy(SD_link_t link)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(link != NULL, "Invalid parameter");
return link->sharing_policy;
}
*/
void __SD_link_destroy(void *link)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(link != NULL, "Invalid parameter");
/* link->surf_link is freed by surf_exit and link->data is freed by the user */
xbt_free(link);
}
*/
void *SD_task_get_data(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
return task->data;
}
*/
void SD_task_set_data(SD_task_t task, void *data)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
task->data = data;
}
*/
e_SD_task_state_t SD_task_get_state(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
return task->state;
}
*/
const char *SD_task_get_name(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
return task->name;
}
unsigned int i;
xbt_dynar_t parents;
SD_dependency_t dep;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
parents = xbt_dynar_new(sizeof(SD_task_t), NULL);
xbt_dynar_foreach(task->tasks_before, i, dep) {
unsigned int i;
xbt_dynar_t children;
SD_dependency_t dep;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
children = xbt_dynar_new(sizeof(SD_task_t), NULL);
xbt_dynar_foreach(task->tasks_after, i, dep) {
*/
int SD_task_get_workstation_count(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
- //xbt_assert(task->state_set != sd_global->scheduled_task_set,
- // "Unscheduled task %s", task->name);
return task->workstation_nb;
}
*/
SD_workstation_t *SD_task_get_workstation_list(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
- //xbt_assert(task->state_set != sd_global->scheduled_task_set,
- // "Unscheduled task %s", task->name);
return task->workstation_list;
}
*/
double SD_task_get_amount(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
return task->amount;
}
*/
double SD_task_get_remaining_amount(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
-
if (task->surf_action)
return surf_workstation_model->get_remains(task->surf_action);
else
int i;
SD_dependency_t dependency;
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
-
dynar = src->tasks_after;
length = xbt_dynar_length(dynar);
unsigned int counter;
SD_dependency_t dependency;
- SD_CHECK_INIT_DONE();
xbt_assert(src != NULL
|| dst != NULL,
"Invalid parameter: both src and dst are NULL");
int i;
SD_dependency_t dependency;
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
-
/* remove the dependency from src->tasks_after */
dynar = src->tasks_after;
length = xbt_dynar_length(dynar);
int i;
SD_dependency_t dependency;
-
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
-
dynar = src->tasks_after;
length = xbt_dynar_length(dynar);
*/
void SD_task_watch(SD_task_t task, e_SD_task_state_t state)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
-
if (state & SD_NOT_SCHEDULED)
THROWF(arg_error, 0,
"Cannot add a watch point for state SD_NOT_SCHEDULED");
*/
void SD_task_unwatch(SD_task_t task, e_SD_task_state_t state)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
xbt_assert(state != SD_NOT_SCHEDULED,
"SimDag error: Cannot have a watch point for state SD_NOT_SCHEDULED");
{
double time, max_time = 0.0;
int i, j;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL && workstation_nb > 0
- && workstation_list != NULL, "Invalid parameter");
+ xbt_assert(workstation_nb > 0, "Invalid parameter");
/* the task execution time is the maximum execution time of the parallel tasks */
static XBT_INLINE void SD_task_do_schedule(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
-
if (!__SD_task_is_not_scheduled(task) && !__SD_task_is_schedulable(task))
THROWF(arg_error, 0, "Task '%s' has already been scheduled",
SD_task_get_name(task));
*/
void SD_task_unschedule(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
-
if (task->state_set != sd_global->scheduled_task_set &&
task->state_set != sd_global->runnable_task_set &&
task->state_set != sd_global->running_task_set &&
*/
static void __SD_task_destroy_scheduling_data(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
if (!__SD_task_is_scheduled_or_runnable(task)
&& !__SD_task_is_in_fifo(task))
THROWF(arg_error, 0,
int i;
void **surf_workstations;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
xbt_assert(__SD_task_is_runnable_or_in_fifo(task),
"Task '%s' is not runnable or in a fifo! Task state: %d",
SD_task_get_name(task), SD_task_get_state(task));
int i;
SD_workstation_t workstation;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
xbt_assert(__SD_task_is_runnable(task),
"Task '%s' is not runnable! Task state: %d",
SD_task_get_name(task), SD_task_get_state(task));
SD_task_t *candidates;
int can_start = 1;
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
xbt_assert(__SD_task_is_running(task),
"The task must be running! Task state: %d",
SD_task_get_state(task));
*/
double SD_task_get_start_time(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
if (task->surf_action)
return surf_workstation_model->
action_get_start_time(task->surf_action);
*/
double SD_task_get_finish_time(SD_task_t task)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(task != NULL, "Invalid parameter");
-
if (task->surf_action) /* should never happen as actions are destroyed right after their completion */
return surf_workstation_model->
action_get_finish_time(task->surf_action);
SD_workstation_t workstation;
const char *name;
- SD_CHECK_INIT_DONE();
- xbt_assert(surf_workstation != NULL, "surf_workstation is NULL !");
workstation = xbt_new(s_SD_workstation_t, 1);
workstation->surf_workstation = surf_workstation;
*/
SD_workstation_t SD_workstation_get_by_name(const char *name)
{
- SD_CHECK_INIT_DONE();
-
- xbt_assert(name != NULL, "Invalid parameter");
-
return xbt_lib_get_or_null(host_lib, name, SD_HOST_LEVEL);
}
void **data;
int i;
- SD_CHECK_INIT_DONE();
xbt_assert(SD_workstation_get_number() > 0, "There is no workstation!");
if (sd_global->workstation_list == NULL) { /* this is the first time the function is called */
*/
int SD_workstation_get_number(void)
{
- SD_CHECK_INIT_DONE();
return host_lib->count;
}
*/
void *SD_workstation_get_data(SD_workstation_t workstation)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
return workstation->data;
}
*/
void SD_workstation_set_data(SD_workstation_t workstation, void *data)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
workstation->data = data;
}
*/
const char *SD_workstation_get_name(SD_workstation_t workstation)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
return surf_resource_name(workstation->surf_workstation);
}
*/
xbt_dict_t SD_workstation_get_properties(SD_workstation_t workstation)
{
- SD_CHECK_INIT_DONE();
- xbt_assert((workstation != NULL), "Invalid parameters");
-
return surf_workstation_model->extension.
workstation.get_properties(workstation->surf_workstation);
void *surf_link;
unsigned int cpt;
- SD_CHECK_INIT_DONE();
-
if (sd_global->recyclable_route == NULL) {
/* first run */
sd_global->recyclable_route = xbt_new(SD_link_t, SD_link_get_number());
*/
int SD_route_get_size(SD_workstation_t src, SD_workstation_t dst)
{
- SD_CHECK_INIT_DONE();
return xbt_dynar_length(surf_workstation_model->extension.
workstation.get_route(src->surf_workstation,
dst->surf_workstation));
*/
double SD_workstation_get_power(SD_workstation_t workstation)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
return surf_workstation_model->extension.workstation.
get_speed(workstation->surf_workstation, 1.0);
}
*/
double SD_workstation_get_available_power(SD_workstation_t workstation)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
return surf_workstation_model->extension.
workstation.get_available_speed(workstation->surf_workstation);
}
double SD_workstation_get_computation_time(SD_workstation_t workstation,
double computation_amount)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
xbt_assert(computation_amount >= 0,
"computation_amount must be greater than or equal to zero");
return computation_amount / SD_workstation_get_power(workstation);
double latency;
int i;
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
links = SD_route_get_list(src, dst);
nb_links = SD_route_get_size(src, dst);
latency = 0.0;
double min_bandwidth;
int i;
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
-
links = SD_route_get_list(src, dst);
nb_links = SD_route_get_size(src, dst);
bandwidth = min_bandwidth = -1.0;
double latency;
int i;
- SD_CHECK_INIT_DONE();
- xbt_assert(src != NULL && dst != NULL, "Invalid parameter");
xbt_assert(communication_amount >= 0,
"communication_amount must be greater than or equal to zero");
e_SD_workstation_access_mode_t
SD_workstation_get_access_mode(SD_workstation_t workstation)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
return workstation->access_mode;
}
e_SD_workstation_access_mode_t
access_mode)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
-
if (access_mode == workstation->access_mode) {
return; // nothing is changed
}
*/
int __SD_workstation_is_busy(SD_workstation_t workstation)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
-
XBT_DEBUG
("Workstation '%s' access mode: '%s', current task: %s, fifo size: %d",
SD_workstation_get_name(workstation),
SD_workstation_t w;
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
/* workstation->surf_workstation is freed by surf_exit and workstation->data is freed by the user */
w = (SD_workstation_t) workstation;
* \param workstation a workstation */
SD_task_t SD_workstation_get_current_task(SD_workstation_t workstation)
{
- SD_CHECK_INIT_DONE();
- xbt_assert(workstation != NULL, "Invalid parameter");
xbt_assert(workstation->access_mode == SD_WORKSTATION_SEQUENTIAL_ACCESS,
"Access mode must be set to SD_WORKSTATION_SEQUENTIAL_ACCESS"
" to use this function");
comm_cost, -1.0);
ret = SD_simulate(-1.0);
+ xbt_assert(xbt_dynar_length(ret) == 2,
+ "I was expecting the terminaison of 2 tasks, but I got %lu instead", xbt_dynar_length(ret));
xbt_dynar_free(&ret);
SD_task_destroy(taskA);
SD_task_destroy(taskB);