diff options
Diffstat (limited to 'src/testbed/test_testbed_api_barriers.c')
-rw-r--r-- | src/testbed/test_testbed_api_barriers.c | 18 |
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; |