aboutsummaryrefslogtreecommitdiff
path: root/src/testbed/testbed_api_barriers.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-10-10 15:47:00 +0000
committerChristian Grothoff <christian@grothoff.org>2016-10-10 15:47:00 +0000
commit93085e8a2991fde229400b588a5930e9fcca0d75 (patch)
tree0384246adbd96fa0138a46ad5fecb777aa40e789 /src/testbed/testbed_api_barriers.c
parent2bf962c76bb82c1f38acea42c7bdfb241e2582e7 (diff)
downloadgnunet-93085e8a2991fde229400b588a5930e9fcca0d75.tar.gz
gnunet-93085e8a2991fde229400b588a5930e9fcca0d75.zip
migrating testbed to new service API
Diffstat (limited to 'src/testbed/testbed_api_barriers.c')
-rw-r--r--src/testbed/testbed_api_barriers.c10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/testbed/testbed_api_barriers.c b/src/testbed/testbed_api_barriers.c
index 3761fbbdf..1679756a1 100644
--- a/src/testbed/testbed_api_barriers.c
+++ b/src/testbed/testbed_api_barriers.c
@@ -105,6 +105,9 @@ handle_status (void *cls,
105{ 105{
106 struct GNUNET_TESTBED_BarrierWaitHandle *h = cls; 106 struct GNUNET_TESTBED_BarrierWaitHandle *h = cls;
107 107
108 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
109 "Got barrier status %d\n",
110 (int) ntohs (msg->status));
108 switch (ntohs (msg->status)) 111 switch (ntohs (msg->status))
109 { 112 {
110 case GNUNET_TESTBED_BARRIERSTATUS_ERROR: 113 case GNUNET_TESTBED_BARRIERSTATUS_ERROR:
@@ -206,6 +209,9 @@ GNUNET_TESTBED_barrier_wait (const char *name,
206 GNUNET_free (h); 209 GNUNET_free (h);
207 return NULL; 210 return NULL;
208 } 211 }
212 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
213 "Waiting on barrier `%s'\n",
214 name);
209 h->name = GNUNET_strdup (name); 215 h->name = GNUNET_strdup (name);
210 h->cb = cb; 216 h->cb = cb;
211 h->cb_cls = cb_cls; 217 h->cb_cls = cb_cls;
@@ -226,8 +232,8 @@ GNUNET_TESTBED_barrier_wait (const char *name,
226 name_len, 232 name_len,
227 GNUNET_MESSAGE_TYPE_TESTBED_BARRIER_WAIT); 233 GNUNET_MESSAGE_TYPE_TESTBED_BARRIER_WAIT);
228 GNUNET_memcpy (msg->name, 234 GNUNET_memcpy (msg->name,
229 name, 235 name,
230 name_len); 236 name_len);
231 GNUNET_MQ_send (h->mq, 237 GNUNET_MQ_send (h->mq,
232 env); 238 env);
233 return h; 239 return h;