aboutsummaryrefslogtreecommitdiff
path: root/src/testbed/test_testbed_api_barriers.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/testbed/test_testbed_api_barriers.c')
-rw-r--r--src/testbed/test_testbed_api_barriers.c18
1 files changed, 9 insertions, 9 deletions
diff --git a/src/testbed/test_testbed_api_barriers.c b/src/testbed/test_testbed_api_barriers.c
index 2fbd6ea81..648af792b 100644
--- a/src/testbed/test_testbed_api_barriers.c
+++ b/src/testbed/test_testbed_api_barriers.c
@@ -21,7 +21,7 @@
21/** 21/**
22 * @file testbed/test_testbed_api_barriers.c 22 * @file testbed/test_testbed_api_barriers.c
23 * @brief testcase binary for testing testbed barriers API 23 * @brief testcase binary for testing testbed barriers API
24 * @author Sree Harsha Totakura <sreeharsha@totakura.in> 24 * @author Sree Harsha Totakura <sreeharsha@totakura.in>
25 */ 25 */
26 26
27#include "platform.h" 27#include "platform.h"
@@ -73,7 +73,7 @@ do_shutdown (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
73 GNUNET_TESTBED_barrier_cancel (barrier); 73 GNUNET_TESTBED_barrier_cancel (barrier);
74 barrier = NULL; 74 barrier = NULL;
75 } 75 }
76 76
77 GNUNET_SCHEDULER_shutdown (); 77 GNUNET_SCHEDULER_shutdown ();
78} 78}
79 79
@@ -99,7 +99,7 @@ barrier_cb (void *cls,
99 const char *emsg) 99 const char *emsg)
100{ 100{
101 static enum GNUNET_TESTBED_BarrierStatus old_status; 101 static enum GNUNET_TESTBED_BarrierStatus old_status;
102 102
103 GNUNET_assert (NULL == cls); 103 GNUNET_assert (NULL == cls);
104 GNUNET_assert (_barrier == barrier); 104 GNUNET_assert (_barrier == barrier);
105 switch (status) 105 switch (status)
@@ -109,14 +109,14 @@ barrier_cb (void *cls,
109 old_status = status; 109 old_status = status;
110 return; 110 return;
111 case GNUNET_TESTBED_BARRIERSTATUS_ERROR: 111 case GNUNET_TESTBED_BARRIERSTATUS_ERROR:
112 LOG (GNUNET_ERROR_TYPE_ERROR, "Barrier initialisation failed: %s", 112 LOG (GNUNET_ERROR_TYPE_ERROR, "Barrier initialisation failed: %s",
113 (NULL == emsg) ? "unknown reason" : emsg); 113 (NULL == emsg) ? "unknown reason" : emsg);
114 barrier = NULL; 114 barrier = NULL;
115 GNUNET_SCHEDULER_shutdown (); 115 GNUNET_SCHEDULER_shutdown ();
116 return; 116 return;
117 case GNUNET_TESTBED_BARRIERSTATUS_CROSSED: 117 case GNUNET_TESTBED_BARRIERSTATUS_CROSSED:
118 LOG (GNUNET_ERROR_TYPE_INFO, "Barrier crossed\n"); 118 LOG (GNUNET_ERROR_TYPE_INFO, "Barrier crossed\n");
119 if (old_status == GNUNET_TESTBED_BARRIERSTATUS_INITIALISED) 119 if (old_status == GNUNET_TESTBED_BARRIERSTATUS_INITIALISED)
120 result = GNUNET_OK; 120 result = GNUNET_OK;
121 barrier = NULL; 121 barrier = NULL;
122 GNUNET_SCHEDULER_shutdown (); 122 GNUNET_SCHEDULER_shutdown ();
@@ -161,7 +161,7 @@ test_master (void *cls,
161 &barrier_cb, NULL); 161 &barrier_cb, NULL);
162 shutdown_task = 162 shutdown_task =
163 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply 163 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply
164 (GNUNET_TIME_UNIT_SECONDS, 164 (GNUNET_TIME_UNIT_SECONDS,
165 10 * (NUM_PEERS + 1)), 165 10 * (NUM_PEERS + 1)),
166 &do_shutdown, NULL); 166 &do_shutdown, NULL);
167} 167}
@@ -181,7 +181,7 @@ main (int argc, char **argv)
181 result = GNUNET_SYSERR; 181 result = GNUNET_SYSERR;
182 event_mask = 0; 182 event_mask = 0;
183 cfg = GNUNET_CONFIGURATION_create (); 183 cfg = GNUNET_CONFIGURATION_create ();
184 GNUNET_assert (GNUNET_YES == 184 GNUNET_assert (GNUNET_YES ==
185 GNUNET_CONFIGURATION_parse (cfg, 185 GNUNET_CONFIGURATION_parse (cfg,
186 "test_testbed_api_barriers.conf.in")); 186 "test_testbed_api_barriers.conf.in"));
187 if (NULL == getcwd (pwd, PATH_MAX)) 187 if (NULL == getcwd (pwd, PATH_MAX))
@@ -191,7 +191,7 @@ main (int argc, char **argv)
191 GNUNET_CONFIGURATION_set_value_string (cfg, "test-barriers","BINARY", binary); 191 GNUNET_CONFIGURATION_set_value_string (cfg, "test-barriers","BINARY", binary);
192 GNUNET_assert (GNUNET_OK == GNUNET_CONFIGURATION_write 192 GNUNET_assert (GNUNET_OK == GNUNET_CONFIGURATION_write
193 (cfg, "test_testbed_api_barriers.conf")); 193 (cfg, "test_testbed_api_barriers.conf"));
194 GNUNET_CONFIGURATION_destroy (cfg); 194 GNUNET_CONFIGURATION_destroy (cfg);
195 cfg = NULL; 195 cfg = NULL;
196 GNUNET_free (binary); 196 GNUNET_free (binary);
197 binary = NULL; 197 binary = NULL;