- name_len = strlen (name);
- msize = sizeof (struct GNUNET_TESTBED_BarrierWait) + name_len;
- msg = GNUNET_malloc (msize);
- msg->header.type = htons (GNUNET_MESSAGE_TYPE_TESTBED_BARRIER_WAIT);
- msg->header.size = htons (msize);
- (void) memcpy (msg->name, name, name_len);
- h->msg = &msg->header;
- h->tx =
- GNUNET_CLIENT_notify_transmit_ready (h->conn, msize,
- GNUNET_TIME_UNIT_FOREVER_REL,
- GNUNET_NO,
- &transmit_notify,
- h);
+ name_len = strlen (name); /* NOTE: unusual to not have 0-termination, change? */
+ env = GNUNET_MQ_msg_extra (msg,
+ name_len,
+ GNUNET_MESSAGE_TYPE_TESTBED_BARRIER_WAIT);
+ GNUNET_memcpy (msg->name,
+ name,
+ name_len);
+ GNUNET_MQ_send (h->mq,
+ env);