diff options
Diffstat (limited to 'src/experimentation/gnunet-daemon-experimentation_scheduler.c')
-rw-r--r-- | src/experimentation/gnunet-daemon-experimentation_scheduler.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/experimentation/gnunet-daemon-experimentation_scheduler.c b/src/experimentation/gnunet-daemon-experimentation_scheduler.c index 784baa4d4..34142fabb 100644 --- a/src/experimentation/gnunet-daemon-experimentation_scheduler.c +++ b/src/experimentation/gnunet-daemon-experimentation_scheduler.c | |||
@@ -133,7 +133,7 @@ static void run_experiment_inbound (void *cls,const struct GNUNET_SCHEDULER_Task | |||
133 | se->state = REQUESTED; | 133 | se->state = REQUESTED; |
134 | /* Schedule to run */ | 134 | /* Schedule to run */ |
135 | start = GNUNET_TIME_absolute_get_remaining(se->e->start); | 135 | start = GNUNET_TIME_absolute_get_remaining(se->e->start); |
136 | if (0 == start.rel_value) | 136 | if (0 == start.rel_value_us) |
137 | se->task = GNUNET_SCHEDULER_add_now (&run_experiment_inbound, se); | 137 | se->task = GNUNET_SCHEDULER_add_now (&run_experiment_inbound, se); |
138 | else | 138 | else |
139 | se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_inbound, se); | 139 | se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_inbound, se); |
@@ -155,7 +155,7 @@ static void run_experiment_inbound (void *cls,const struct GNUNET_SCHEDULER_Task | |||
155 | 155 | ||
156 | /* Reschedule */ | 156 | /* Reschedule */ |
157 | end = GNUNET_TIME_absolute_get_remaining(GNUNET_TIME_absolute_add (se->e->stop, se->e->frequency)); | 157 | end = GNUNET_TIME_absolute_get_remaining(GNUNET_TIME_absolute_add (se->e->stop, se->e->frequency)); |
158 | if (0 == end.rel_value) | 158 | if (0 == end.rel_value_us) |
159 | { | 159 | { |
160 | se->state = STOPPED; | 160 | se->state = STOPPED; |
161 | return; /* End of experiment is reached */ | 161 | return; /* End of experiment is reached */ |
@@ -201,7 +201,7 @@ static void run_experiment_outbound (void *cls,const struct GNUNET_SCHEDULER_Tas | |||
201 | 201 | ||
202 | /* Reschedule */ | 202 | /* Reschedule */ |
203 | end = GNUNET_TIME_absolute_get_remaining(GNUNET_TIME_absolute_add (se->e->stop, se->e->frequency)); | 203 | end = GNUNET_TIME_absolute_get_remaining(GNUNET_TIME_absolute_add (se->e->stop, se->e->frequency)); |
204 | if (0 == end.rel_value) | 204 | if (0 == end.rel_value_us) |
205 | { | 205 | { |
206 | se->state = STOPPED; | 206 | se->state = STOPPED; |
207 | return; /* End of experiment is reached */ | 207 | return; /* End of experiment is reached */ |
@@ -328,7 +328,7 @@ GED_scheduler_add (struct Node *n, struct Experiment *e, int outbound) | |||
328 | 328 | ||
329 | start = GNUNET_TIME_absolute_get_remaining(e->start); | 329 | start = GNUNET_TIME_absolute_get_remaining(e->start); |
330 | end = GNUNET_TIME_absolute_get_remaining(e->stop); | 330 | end = GNUNET_TIME_absolute_get_remaining(e->stop); |
331 | if (0 == end.rel_value) | 331 | if (0 == end.rel_value_us) |
332 | return; /* End of experiment is reached */ | 332 | return; /* End of experiment is reached */ |
333 | 333 | ||
334 | /* Add additional checks here if required */ | 334 | /* Add additional checks here if required */ |
@@ -340,7 +340,7 @@ GED_scheduler_add (struct Node *n, struct Experiment *e, int outbound) | |||
340 | 340 | ||
341 | if (GNUNET_YES == outbound) | 341 | if (GNUNET_YES == outbound) |
342 | { | 342 | { |
343 | if (0 == start.rel_value) | 343 | if (0 == start.rel_value_us) |
344 | se->task = GNUNET_SCHEDULER_add_now (&run_experiment_outbound, se); | 344 | se->task = GNUNET_SCHEDULER_add_now (&run_experiment_outbound, se); |
345 | else | 345 | else |
346 | se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_outbound, se); | 346 | se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_outbound, se); |
@@ -348,7 +348,7 @@ GED_scheduler_add (struct Node *n, struct Experiment *e, int outbound) | |||
348 | } | 348 | } |
349 | else | 349 | else |
350 | { | 350 | { |
351 | if (0 == start.rel_value) | 351 | if (0 == start.rel_value_us) |
352 | se->task = GNUNET_SCHEDULER_add_now (&run_experiment_inbound, se); | 352 | se->task = GNUNET_SCHEDULER_add_now (&run_experiment_inbound, se); |
353 | else | 353 | else |
354 | se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_inbound, se); | 354 | se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_inbound, se); |