* @author Matthias Wachs
*/
#include "platform.h"
-#include "gnunet_getopt_lib.h"
#include "gnunet_util_lib.h"
#include "gnunet_core_service.h"
#include "gnunet_statistics_service.h"
se->state = REQUESTED;
/* Schedule to run */
start = GNUNET_TIME_absolute_get_remaining(se->e->start);
- if (0 == start.rel_value)
+ if (0 == start.rel_value_us)
se->task = GNUNET_SCHEDULER_add_now (&run_experiment_inbound, se);
else
se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_inbound, se);
/* Reschedule */
end = GNUNET_TIME_absolute_get_remaining(GNUNET_TIME_absolute_add (se->e->stop, se->e->frequency));
- if (0 == end.rel_value)
+ if (0 == end.rel_value_us)
{
se->state = STOPPED;
return; /* End of experiment is reached */
/* Reschedule */
end = GNUNET_TIME_absolute_get_remaining(GNUNET_TIME_absolute_add (se->e->stop, se->e->frequency));
- if (0 == end.rel_value)
+ if (0 == end.rel_value_us)
{
se->state = STOPPED;
return; /* End of experiment is reached */
void
GED_scheduler_handle_start (struct Node *n, struct Experiment *e)
{
- struct ScheduledExperiment *se;
-
- if ((NULL != (se = find_experiment (waiting_in_head, waiting_in_tail, n, e, GNUNET_NO))) ||
- (NULL != (se = find_experiment (running_in_head, running_in_tail, n, e, GNUNET_NO))))
- {
- GNUNET_break_op (0);
- return;
- }
-
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received %s message from peer %s for experiment `%s'\n",
- "START", GNUNET_i2s (&n->id), e->name);
-
- GED_scheduler_add (n, e, GNUNET_NO);
+ if ((NULL != find_experiment (waiting_in_head, waiting_in_tail, n, e, GNUNET_NO)) ||
+ (NULL != find_experiment (running_in_head, running_in_tail, n, e, GNUNET_NO)))
+ {
+ GNUNET_break_op (0);
+ return;
+ }
+
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Received %s message from peer %s for experiment `%s'\n",
+ "START", GNUNET_i2s (&n->id), e->name);
+ GED_scheduler_add (n, e, GNUNET_NO);
}
+
/**
* Handle a START_ACK message from a remote node
*
start = GNUNET_TIME_absolute_get_remaining(e->start);
end = GNUNET_TIME_absolute_get_remaining(e->stop);
- if (0 == end.rel_value)
+ if (0 == end.rel_value_us)
return; /* End of experiment is reached */
/* Add additional checks here if required */
if (GNUNET_YES == outbound)
{
- if (0 == start.rel_value)
+ if (0 == start.rel_value_us)
se->task = GNUNET_SCHEDULER_add_now (&run_experiment_outbound, se);
else
se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_outbound, se);
}
else
{
- if (0 == start.rel_value)
+ if (0 == start.rel_value_us)
se->task = GNUNET_SCHEDULER_add_now (&run_experiment_inbound, se);
else
se->task = GNUNET_SCHEDULER_add_delayed (start, &run_experiment_inbound, se);