X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Ftestbed%2Ftest_testbed_api_topology_clique.c;h=658e33ab9e42fdd35f651469162bebac05daac00;hb=db9c68c76d7a9eb3f200df9d0fcaf971387cb061;hp=dc3a2364c5063f8749d7a71aab0f9958935242d3;hpb=949f21f03df9f08b0a73c3e47a798e63790edf7f;p=oweals%2Fgnunet.git diff --git a/src/testbed/test_testbed_api_topology_clique.c b/src/testbed/test_testbed_api_topology_clique.c index dc3a2364c..658e33ab9 100644 --- a/src/testbed/test_testbed_api_topology_clique.c +++ b/src/testbed/test_testbed_api_topology_clique.c @@ -1,6 +1,6 @@ /* This file is part of GNUnet - (C) 2008--2012 Christian Grothoff (and other contributing authors) + (C) 2008--2013 Christian Grothoff (and other contributing authors) GNUnet is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published @@ -25,7 +25,7 @@ */ #include "platform.h" -#include "gnunet_common.h" +#include "gnunet_util_lib.h" #include "gnunet_testbed_service.h" /** @@ -94,7 +94,8 @@ controller_event_cb (void *cls, if ((NUM_PEERS * (NUM_PEERS - 1)) == overlay_connects) { result = GNUNET_OK; - GNUNET_SCHEDULER_add_now (&do_shutdown, NULL); + GNUNET_SCHEDULER_cancel (shutdown_task); + shutdown_task = GNUNET_SCHEDULER_add_now (&do_shutdown, NULL); } break; case GNUNET_TESTBED_ET_OPERATION_FINISHED: @@ -113,6 +114,7 @@ controller_event_cb (void *cls, * Signature of a main function for a testcase. * * @param cls closure + * @param h the run handle * @param num_peers number of peers in 'peers' * @param peers_ handle to peers run in the testbed * @param links_succeeded the number of overlay link connection attempts that @@ -121,7 +123,9 @@ controller_event_cb (void *cls, * failed */ static void -test_master (void *cls, unsigned int num_peers, +test_master (void *cls, + struct GNUNET_TESTBED_RunHandle *h, + unsigned int num_peers, struct GNUNET_TESTBED_Peer **peers_, unsigned int links_succeeded, unsigned int links_failed) @@ -129,8 +133,12 @@ test_master (void *cls, unsigned int num_peers, unsigned int peer; GNUNET_assert (NULL == cls); + if (NULL == peers_) + { + GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failing test due to timeout\n"); + return; + } GNUNET_assert (NUM_PEERS == num_peers); - GNUNET_assert (NULL != peers_); for (peer = 0; peer < num_peers; peer++) GNUNET_assert (NULL != peers_[peer]); peers = peers_;