{
struct GNUNET_TESTBED_BarrierWaitHandle *h = cls;
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Got barrier status %d\n",
+ (int) ntohs (msg->status));
switch (ntohs (msg->status))
{
case GNUNET_TESTBED_BARRIERSTATUS_ERROR:
GNUNET_free (h);
return NULL;
}
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Waiting on barrier `%s'\n",
+ name);
h->name = GNUNET_strdup (name);
h->cb = cb;
h->cb_cls = cb_cls;
- h->mq = GNUNET_CLIENT_connecT (h->cfg,
+ h->mq = GNUNET_CLIENT_connect (h->cfg,
"testbed-barrier",
handlers,
&mq_error_handler,
name_len,
GNUNET_MESSAGE_TYPE_TESTBED_BARRIER_WAIT);
GNUNET_memcpy (msg->name,
- name,
- name_len);
+ name,
+ name_len);
GNUNET_MQ_send (h->mq,
env);
return h;