if (NULL != e_ctx->n->cth)
return;
- e_ctx->n->cth = GNUNET_CORE_notify_transmit_ready (ch, GNUNET_NO, 0, FAST_TIMEOUT,
+ e_ctx->n->cth = GNUNET_CORE_notify_transmit_ready (ch, GNUNET_NO,
+ GNUNET_CORE_PRIO_BEST_EFFORT,
+ FAST_TIMEOUT,
&e_ctx->n->id, e_ctx->size,
transmit_read_wrapper, e_ctx);
if (NULL == e_ctx->n->cth)
size_t ri_size = sizeof (struct GNUNET_CRYPTO_EddsaPublicKey) * my_issuer_count;
size_t total_size = msg_size + ri_size;
struct GNUNET_CRYPTO_EddsaPublicKey *issuers;
-
+
n->cth = NULL;
if (NULL == buf)
{
"Sending %s for experiment request to peer `%s' for experiment `%s'\n",
"START_ACK" ,GNUNET_i2s(&n->id), e->name);
- e_ctx = GNUNET_malloc (sizeof (struct NodeComCtx));
+ e_ctx = GNUNET_new (struct NodeComCtx);
e_ctx->n = n;
e_ctx->e = e;
e_ctx->size = sizeof (struct GED_start_ack_message) + strlen (e->name) + 1;
"Sending %s for experiment request to peer `%s' for experiment `%s'\n",
"START", GNUNET_i2s(&n->id), e->name);
- e_ctx = GNUNET_malloc (sizeof (struct NodeComCtx));
+ e_ctx = GNUNET_new (struct NodeComCtx);
e_ctx->n = n;
e_ctx->e = e;
e_ctx->size = sizeof (struct GED_start_message) + strlen (e->name) + 1;