X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d4fb7b9d845c48b3274774833a3b848750a73766..831de10adaaf8910940aa280e2ac2dd075b5ffe5:/src/simdag/simdag_private.h diff --git a/src/simdag/simdag_private.h b/src/simdag/simdag_private.h index d2345567e0..906205e86b 100644 --- a/src/simdag/simdag_private.h +++ b/src/simdag/simdag_private.h @@ -23,7 +23,7 @@ typedef struct SD_global { bool watch_point_reached; /* has a task just reached a watch point? */ std::set *initial_tasks; - std::set *executable_tasks; + std::set *runnable_tasks; std::set *completed_tasks; xbt_dynar_t return_set; @@ -49,10 +49,10 @@ typedef struct SD_task { int marked; /* used to check if the task DAG has some cycle*/ /* dependencies */ - xbt_dynar_t tasks_before; - xbt_dynar_t tasks_after; - int unsatisfied_dependencies; - unsigned int is_not_ready; + std::set *inputs; + std::set *outputs; + std::set *predecessors; + std::set *successors; /* scheduling parameters (only exist in state SD_SCHEDULED) */ int host_count; @@ -60,20 +60,8 @@ typedef struct SD_task { double *flops_amount; double *bytes_amount; double rate; - - long long int counter; /* task unique identifier for instrumentation */ - char *category; /* sd task category for instrumentation */ } s_SD_task_t; -/* Task dependencies */ -typedef struct SD_dependency { - char *name; - void *data; - SD_task_t src; - SD_task_t dst; - /* src must be finished before dst can start */ -} s_SD_dependency_t, *SD_dependency_t; - /* SimDag private functions */ XBT_PRIVATE void SD_task_set_state(SD_task_t task, e_SD_task_state_t new_state); XBT_PRIVATE void SD_task_run(SD_task_t task); @@ -81,7 +69,7 @@ XBT_PRIVATE bool acyclic_graph_detail(xbt_dynar_t dag); XBT_PRIVATE void uniq_transfer_task_name(SD_task_t task); /* Task mallocator functions */ -XBT_PRIVATE void* SD_task_new_f(void); +XBT_PRIVATE void* SD_task_new_f(); XBT_PRIVATE void SD_task_recycle_f(void *t); XBT_PRIVATE void SD_task_free_f(void *t);