static void
-statistics_done_db (void *cls,
+statistics_done_cb (void *cls,
struct
GNUNET_TESTBED_Operation
*op,
GNUNET_TESTBED_operation_done (op);
if (NULL != statistics_file)
fclose (statistics_file);
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO, "got statistics, shutting down\n");
GNUNET_SCHEDULER_shutdown ();
}
statistics_file = fopen (statistics_filename, "w");
GNUNET_TESTBED_get_statistics (num_peers, peers, NULL, NULL,
statistics_cb,
- statistics_done_db,
+ statistics_done_cb,
NULL);
}
}
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"consensus %d done\n",
- chp - consensus_handles);
+ (int) (chp - consensus_handles));
GNUNET_SCHEDULER_add_now (destroy, *chp);
}
disconnect_adapter(void *cls, void *op_result)
{
/* FIXME: what to do here? */
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "disconnect adapter called\n");
}
case EVILNESS_SLACK:
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"P%u: evil peer: slacking\n",
- session->local_peer_idx,
- evil.num);
+ (unsigned int) session->local_peer_idx);
/* Do nothing. */
break;
case EVILNESS_NONE:
#ifdef GNUNET_EXTRA_LOGGING
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Decreased pending_prereq to %u for step `%s'.\n",
- step->subordinates[i]->pending_prereq,
+ (unsigned int) step->subordinates[i]->pending_prereq,
step->subordinates[i]->debug_name);
#endif
#ifdef GNUNET_EXTRA_LOGGING
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Decreased pending_prereq to %u for step `%s'.\n",
- step->subordinates[i]->pending_prereq,
+ (unsigned int) step->subordinates[i]->pending_prereq,
step->subordinates[i]->debug_name);
#endif
arrange_peers (&p1, &p2, n);
task = ((struct TaskEntry) {
.step = step,
- .key = (struct TaskKey) { PHASE_KIND_GRADECAST_LEADER, p1, p2, rep, lead},
+ .key = (struct TaskKey) { PHASE_KIND_GRADECAST_LEADER, p1, p2, rep, lead },
.start = task_start_reconcile,
.cancel = task_cancel_reconcile,
});
uint16_t me = session->local_peer_idx;
- uint16_t p1;
- uint16_t p2;
-
/* The task we're currently setting up. */
struct TaskEntry task;
for (i = 0; i < n; i++)
{
+ uint16_t p1;
+ uint16_t p2;
+
p1 = me;
p2 = i;
arrange_peers (&p1, &p2, n);
session->conclude_deadline = GNUNET_TIME_absolute_ntoh (join_msg->deadline);
session->conclude_start = GNUNET_TIME_absolute_ntoh (join_msg->start);
- GNUNET_log (GNUNET_ERROR_TYPE_INFO, "consensus with timeout %ums created\n",
- (GNUNET_TIME_absolute_get_difference (session->conclude_start, session->conclude_deadline)).rel_value_us / 1000);
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO, "consensus with timeout %llums created\n",
+ (long long) (GNUNET_TIME_absolute_get_difference (session->conclude_start, session->conclude_deadline)).rel_value_us / 1000);
session->local_peer_idx = get_peer_idx (&my_peer, session);
GNUNET_assert (-1 != session->local_peer_idx);
static void
shutdown_task (void *cls)
{
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO, "shutting down\n");
while (NULL != sessions_head)
destroy_session (sessions_head);
- GNUNET_STATISTICS_destroy (statistics, GNUNET_YES);
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "handled shutdown request\n");
+ GNUNET_STATISTICS_destroy (statistics, GNUNET_NO);
}