/*
* This file is part of GNUnet.
- * (C)
+ * Copyright (C)
*
* GNUnet is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published
/**
* GNUNET scheduler task that forces the anomaly after a stabilization delay
*/
- GNUNET_SCHEDULER_TaskIdentifier delay_task;
+ struct GNUNET_SCHEDULER_Task * delay_task;
};
/**
* Test name
*/
-const static char *testname = "test_gnunet-service-sensor_reporting";
+static const char *testname = "test_gnunet-service-sensor_reporting";
/**
* Name of GNUNET config file used in this test
*/
-const static char *cfg_filename = "test_gnunet-service-sensor_reporting.conf";
+static const char *cfg_filename = "test_gnunet-service-sensor_reporting.conf";
/**
* Test sensor name
*/
-const static char *sensor_name = "test-sensor-statistics";
+static const char *sensor_name = "test-sensor-statistics";
/**
* Path to read test sensor from
*/
-const static char *sensor_path_src = "test_sensors/test-sensor-statistics";
+static const char *sensor_path_src = "test_sensors/test-sensor-statistics";
/**
* Path to write new test sensor to
*/
-const static char *sensor_path_dest =
+static const char *sensor_path_dest =
"/tmp/test-gnunet-service-sensor-reporting/test-sensor-statistics";
/**
/**
* Task used to shutdown / expire the test
*/
-static GNUNET_SCHEDULER_TaskIdentifier shutdown_task;
+static struct GNUNET_SCHEDULER_Task * shutdown_task;
/**
* Status of the test to be returned by main()
static void
destroy_peer (struct TestPeer *peer)
{
- if (GNUNET_SCHEDULER_NO_TASK != peer->delay_task)
+ if (NULL != peer->delay_task)
{
GNUNET_SCHEDULER_cancel (peer->delay_task);
- peer->delay_task = GNUNET_SCHEDULER_NO_TASK;
+ peer->delay_task = NULL;
}
if (NULL != peer->sensor_op)
{
* @return #GNUNET_YES to continue iterating, #GNUNET_NO to stop
*/
static int
-peerstore_watch_cb (void *cls, struct GNUNET_PEERSTORE_Record *record,
- char *emsg)
+peerstore_watch_cb (void *cls,
+ const struct GNUNET_PEERSTORE_Record *record,
+ const char *emsg)
{
struct TestPeer *peer = cls;
struct GNUNET_SENSOR_DashboardAnomalyEntry *anomaly;
{
struct TestPeer *peer = cls;
- peer->delay_task = GNUNET_SCHEDULER_NO_TASK;
+ peer->delay_task = NULL;
GNUNET_SENSOR_force_anomaly (peer->sensor, (char *) sensor_name, GNUNET_YES,
NULL, NULL);
}
{
struct TestPeer *peer = cls;
- GNUNET_assert (NULL == emsg);
+ if (NULL != emsg)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "ERROR: %s.\n", emsg);
+ GNUNET_assert (0);
+ }
peer->sensor_op =
GNUNET_TESTBED_service_connect (NULL, peer->testbed_peer, "sensor",
&sensor_connect_cb, peer,
dashboard_started (void *cls, struct GNUNET_TESTBED_Operation *op,
const char *emsg)
{
- GNUNET_assert (NULL == emsg);
+ if (NULL != emsg)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "ERROR: %s.\n", emsg);
+ GNUNET_assert (0);
+ }
GNUNET_TESTBED_operation_done (op);
/* Connect to peerstore service on first peer */
peerstore_op =
peer = GNUNET_new (struct TestPeer);
peer->testbed_peer = testbed_peer;
- peer->delay_task = GNUNET_SCHEDULER_NO_TASK;
+ peer->delay_task = NULL;
GNUNET_CRYPTO_get_peer_identity (pinfo->result.cfg, &peer->peer_id);
if (NULL == peer_head) /* First peer (collection point) */
{