Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Update workstation handling in SimDag. Change the prefix of SimDag functions with...
[simgrid.git] / src / simdag / sd_task.c
1 #include "simdag/simdag.h"
2 #include "xbt/sysdep.h"
3
4 /* Creates a task.
5  */
6 SD_task_t SD_task_create(const char *name, void *data, double amount) {
7
8   xbt_assert0(amount >= 0, "Invalid parameter"); /* or amount > 0 ? */
9
10   SD_task_t task = xbt_new0(s_SD_task_t, 1);
11   
12   task->data = data;
13   task->name = xbt_strdup(name);
14   /*task->amount = amount;
15     task->remaining_amount = amount;*/
16   task->state = SD_SCHEDULED; /* not sure... should we add a state SD_NOT_SCHEDULED? */
17   /* TODO: dependencies + watch */
18
19   return task;
20 }
21
22 /* Schedules a task.
23  */
24 int SD_task_schedule(SD_task_t task, int workstation_nb,
25                      SD_workstation_t **workstation_list, double *computation_amount,
26                      double *communication_amount, double rate) {
27   xbt_assert0(task, "Invalid parameter");
28   /* TODO */
29
30   return 0;
31 }
32
33 /* Returns the data of a task.
34  */
35 void* SD_task_get_data(SD_task_t task) {
36   xbt_assert0(task, "Invalid parameter");
37   return task->data;
38 }
39
40 /* Sets the data of a task.
41  */
42 void SD_task_set_data(SD_task_t task, void *data) {
43   xbt_assert0(task, "Invalid parameter");
44   task->data = data;
45 }
46
47 /* Returns the name of a task.
48  */
49 const char* SD_task_get_name(SD_task_t task) {
50   xbt_assert0(task, "Invalid parameter");
51   return task->name;
52 }
53
54 /* Returns the computing amount of a task.
55  */
56 double SD_task_get_amount(SD_task_t task) {
57   xbt_assert0(task, "Invalid parameter");
58
59   /* TODO */
60   return 0;
61   /*return task->amount;*/
62 }
63
64 /* Returns the remaining computing amount of a task.
65  */
66 double SD_task_get_remaining_amount(SD_task_t task) {
67   xbt_assert0(task, "Invalid parameter")
68
69   /* TODO (surf encapsulation) */;
70   return 0;
71 }
72
73 /* Adds a dependency between two tasks.
74  */
75 void SD_task_dependency_add(const char *name, void *data, SD_task_t src, SD_task_t dst) {
76   xbt_assert0(src != NULL && dst != NULL, "Invalid parameter");
77   /* TODO */
78 }
79
80 /* Removes a dependency between two tasks.
81  */
82 void SD_task_dependency_remove(SD_task_t src, SD_task_t dst) {
83   xbt_assert0(src != NULL && dst != NULL, "Invalid parameter");
84   /* TODO */
85 }
86
87 /* Returns the state of a task: SD_SCHEDULED, SD_RUNNING, SD_DONE or SD_FAILED.
88  */
89 SD_task_state_t SD_task_get_state(SD_task_t task) {
90   xbt_assert0(task, "Invalid parameter");
91   return task->state;
92 }
93
94 /* Adds a watch point to a task.
95    SD_simulate will stop as soon as the state of this task is the one given in argument.
96    Watch point is then automatically removed.
97  */
98 void  SD_task_watch(SD_task_t task, SD_task_state_t state) {
99   xbt_assert0(task, "Invalid parameter");
100   /* TODO */
101 }
102
103 /* Removes a watch point from a task.
104  */
105 void SD_task_unwatch(SD_task_t task, SD_task_state_t state) {
106   xbt_assert0(task, "Invalid parameter");
107   /* TODO */
108 }
109
110 /* Unschedules a task.
111    Change state and rerun
112  */
113 void SD_task_unschedule(SD_task_t task) {
114   xbt_assert0(task, "Invalid parameter");
115   /* TODO */
116 }
117
118 /* Destroys a task. The user data (if any) should have been destroyed first.
119  */
120 void SD_task_destroy(SD_task_t task) {
121   if (task->name)
122     xbt_free(task->name);
123
124   /* TODO: dependencies + watch */
125   xbt_free(task);
126 }