diff options
author | Christian Grothoff <christian@grothoff.org> | 2016-10-10 15:47:00 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2016-10-10 15:47:00 +0000 |
commit | 93085e8a2991fde229400b588a5930e9fcca0d75 (patch) | |
tree | 0384246adbd96fa0138a46ad5fecb777aa40e789 /src/testbed/testbed_api_barriers.c | |
parent | 2bf962c76bb82c1f38acea42c7bdfb241e2582e7 (diff) | |
download | gnunet-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.c | 10 |
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; |