aboutsummaryrefslogtreecommitdiff
path: root/src/experimentation/gnunet-daemon-experimentation_scheduler.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2013-08-11 21:21:56 +0000
committerChristian Grothoff <christian@grothoff.org>2013-08-11 21:21:56 +0000
commit3d7fefedc9ba60bd8e8448efe8b628446d958536 (patch)
tree61ce41a52cd6e7232cead77818ef265993b2427e /src/experimentation/gnunet-daemon-experimentation_scheduler.c
parent4a0398474db197abed243a123fb971fbeeffab4b (diff)
downloadgnunet-3d7fefedc9ba60bd8e8448efe8b628446d958536.tar.gz
gnunet-3d7fefedc9ba60bd8e8448efe8b628446d958536.zip
changing time measurement from milliseconds to microseconds
Diffstat (limited to 'src/experimentation/gnunet-daemon-experimentation_scheduler.c')
-rw-r--r--src/experimentation/gnunet-daemon-experimentation_scheduler.c12
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);