X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f5ee12fe642b7ceaa87d2b85aca3591d612c8d40..130940bb5ba3a570745c51f305016e00f3370e95:/src/simdag/private.h diff --git a/src/simdag/private.h b/src/simdag/private.h index 4cc0513503..aab3cd6044 100644 --- a/src/simdag/private.h +++ b/src/simdag/private.h @@ -1,4 +1,5 @@ -/* Copyright (c) 2007-2009 Da SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006, 2007, 2008, 2009, 2010. The SimGrid Team. + * All rights reserved. */ /* 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. */ @@ -35,8 +36,9 @@ typedef struct SD_global { /* task state sets */ xbt_swag_t not_scheduled_task_set; + xbt_swag_t schedulable_task_set; xbt_swag_t scheduled_task_set; - xbt_swag_t ready_task_set; + xbt_swag_t runnable_task_set; xbt_swag_t in_fifo_task_set; xbt_swag_t running_task_set; xbt_swag_t done_task_set; @@ -72,12 +74,13 @@ typedef struct SD_task { e_SD_task_state_t state; void *data; /* user data */ char *name; + int kind; double amount; double remains; double start_time; double finish_time; surf_action_t surf_action; - unsigned short watch_points; /* bit field xor()ed with masks */ + unsigned short watch_points; /* bit field xor()ed with masks */ int fifo_checked; /* used by SD_task_just_done to make sure we evaluate the task only once */ @@ -85,6 +88,8 @@ typedef struct SD_task { /* dependencies */ xbt_dynar_t tasks_before; xbt_dynar_t tasks_after; + unsigned int unsatisfied_dependencies; + unsigned int is_not_ready; /* scheduling parameters (only exist in state SD_SCHEDULED) */ int workstation_nb; @@ -92,6 +97,10 @@ typedef struct SD_task { double *computation_amount; double *communication_amount; double rate; + +#ifdef HAVE_TRACING + char *category; /* sd task category for instrumentation */ +#endif } s_SD_task_t; /* Task dependencies */ @@ -108,7 +117,8 @@ typedef struct SD_dependency { SD_link_t __SD_link_create(void *surf_link, void *data); void __SD_link_destroy(void *link); -SD_workstation_t __SD_workstation_create(void *surf_workstation, void *data); +SD_workstation_t __SD_workstation_create(void *surf_workstation, + void *data); void __SD_workstation_destroy(void *workstation); int __SD_workstation_is_busy(SD_workstation_t workstation); @@ -119,11 +129,18 @@ void __SD_task_just_done(SD_task_t task); /* Functions to test if the task is in a given state. */ -/* Returns whether the given task is scheduled or ready. */ -static XBT_INLINE int __SD_task_is_scheduled_or_ready(SD_task_t task) +/* Returns whether the given task is scheduled or runnable. */ +static XBT_INLINE int __SD_task_is_scheduled_or_runnable(SD_task_t task) { return task->state_set == sd_global->scheduled_task_set || - task->state_set == sd_global->ready_task_set; + task->state_set == sd_global->runnable_task_set; +} + +/* Returns whether the given task is scheduled or runnable. */ +static XBT_INLINE int __SD_task_is_schedulable_or_done(SD_task_t task) +{ + return task->state_set == sd_global->schedulable_task_set || + task->state_set == sd_global->done_task_set; } /* Returns whether the state of the given task is SD_NOT_SCHEDULED. */ @@ -132,16 +149,22 @@ 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_schedulable(SD_task_t task) +{ + return task->state_set == sd_global->schedulable_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) +/* Returns whether the state of the given task is SD_RUNNABLE. */ +static XBT_INLINE int __SD_task_is_runnable(SD_task_t task) { - return task->state_set == sd_global->ready_task_set; + return task->state_set == sd_global->runnable_task_set; } /* Returns whether the state of the given task is SD_IN_FIFO. */ @@ -150,11 +173,11 @@ static XBT_INLINE int __SD_task_is_in_fifo(SD_task_t task) return task->state_set == sd_global->in_fifo_task_set; } -/* Returns whether the state of the given task is SD_READY or SD_IN_FIFO. */ -static XBT_INLINE int __SD_task_is_ready_or_in_fifo(SD_task_t task) +/* Returns whether the state of the given task is SD_RUNNABLE or SD_IN_FIFO. */ +static XBT_INLINE int __SD_task_is_runnable_or_in_fifo(SD_task_t task) { - return task->state_set == sd_global->ready_task_set || - task->state_set == sd_global->in_fifo_task_set; + return task->state_set == sd_global->runnable_task_set || + task->state_set == sd_global->in_fifo_task_set; } /* Returns whether the state of the given task is SD_RUNNING. */