X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7093fb34d72a218454bc09aff6f970d68442e0ce..3f17e7a2d9e727cf8ba2da354280f3afd329c8a6:/src/simdag/private.h diff --git a/src/simdag/private.h b/src/simdag/private.h index d8bf9f7cdb..06fe3394dd 100644 --- a/src/simdag/private.h +++ b/src/simdag/private.h @@ -15,12 +15,12 @@ typedef struct SD_global { xbt_dict_t workstations; /* workstation list */ int workstation_count; /* number of workstations */ xbt_dict_t links; /* link list */ - xbt_dynar_t tasks; /* task list */ int watch_point_reached; /* has a task just reached a watch point? */ /* task state sets */ xbt_swag_t not_scheduled_task_set; xbt_swag_t scheduled_task_set; + xbt_swag_t ready_task_set; xbt_swag_t running_task_set; xbt_swag_t done_task_set; xbt_swag_t failed_task_set; @@ -50,6 +50,8 @@ typedef struct SD_task { double amount; surf_action_t surf_action; unsigned short watch_points; + int state_changed; /* used only by SD_simulate, to make sure we put + the task only once in the returning array */ /* dependencies */ xbt_dynar_t tasks_before; @@ -80,6 +82,37 @@ void __SD_link_destroy(void *link); SD_workstation_t __SD_workstation_create(void *surf_workstation, void *data); void __SD_workstation_destroy(void *workstation); +void __SD_task_set_state(SD_task_t task, e_SD_task_state_t new_state); surf_action_t __SD_task_run(SD_task_t task); +void __SD_task_remove_dependencies(SD_task_t task); + +/* Functions to test if the task is in a given state. + These functions are faster than using SD_task_get_state() */ + +/* Returns whether the given task is scheduled or ready. */ +static _XBT_INLINE int __SD_task_is_scheduled_or_ready(SD_task_t task) { + return task->state_set == sd_global->scheduled_task_set || + task->state_set == sd_global->ready_task_set; +} + +/* Returns whether the state of the given task is SD_NOT_SCHEDULED. */ +static _XBT_INLINE int __SD_task_is_not_scheduled(SD_task_t task) { + return task->state_set == sd_global->not_scheduled_task_set; +} + +/* Returns whether the state of the given task is SD_SCHEDULED. */ +static _XBT_INLINE int __SD_task_is_scheduled(SD_task_t task) { + return task->state_set == sd_global->scheduled_task_set; +} + +/* Returns whether the state of the given task is SD_READY. */ +static _XBT_INLINE int __SD_task_is_ready(SD_task_t task) { + return task->state_set == sd_global->ready_task_set; +} + +/* Returns whether the state of the given task is SD_RUNNING. */ +static _XBT_INLINE int __SD_task_is_running(SD_task_t task) { + return task->state_set == sd_global->running_task_set; +} #endif