Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Implement SD_task_schedule, SD_task_unschedule and other SimDag stuff.
[simgrid.git] / src / simdag / private.h
1 #ifndef SIMDAG_PRIVATE_H
2 #define SIMDAG_PRIVATE_H
3
4 #include "xbt/dict.h"
5 #include "xbt/dynar.h"
6 #include "simdag/simdag.h"
7 #include "simdag/datatypes.h"
8 #include "surf/surf.h"
9
10 #define SD_CHECK_INIT_DONE() xbt_assert0(sd_global != NULL, "Call SD_init() first")
11
12 /* Global variables */
13
14 typedef struct SD_global {
15   xbt_dict_t workstations; /* workstation list */
16   int workstation_count; /* number of workstations */
17   xbt_dict_t links; /* link list */
18 } s_SD_global_t, *SD_global_t;
19
20 extern SD_global_t sd_global;
21
22 /* Link private data */
23 typedef struct SD_link_data {
24   void *surf_link; /* surf object */
25 } s_SD_link_data_t;
26
27 /* Workstation private data */
28 typedef struct SD_workstation_data {
29   void *surf_workstation; /* surf object */
30 } s_SD_workstation_data_t;
31
32 /* Task private data */
33 typedef struct SD_task_data {
34   char *name;
35   SD_task_state_t state;
36   double amount;
37   surf_action_t surf_action;
38   unsigned short watch_points;
39
40   /* dependencies */
41   xbt_dynar_t tasks_before;
42   xbt_dynar_t tasks_after;
43
44   /* scheduling parameters (only exist in state SD_SCHEDULED) */
45   int workstation_nb;
46   void **workstation_list; /* surf workstations */
47   double *computation_amount;
48   double *communication_amount;
49   double rate;
50 } s_SD_task_data_t;
51
52 /* Private functions */
53
54 SD_link_t __SD_link_create(void *surf_link, void *data);
55 void __SD_link_destroy(void *link);
56
57 SD_workstation_t __SD_workstation_create(void *surf_workstation, void *data);
58 void __SD_workstation_destroy(void *workstation);
59
60 void __SD_task_run(SD_task_t task);
61 void __SD_task_destroy(SD_task_t task);
62 void __SD_task_destroy_scheduling_data(SD_task_t task);
63
64 #endif