reply_counter++;
if (reply_counter >= MAX_REPLY_TIMES)
reply_counter = 0;
- peer->th = GNUNET_CORE_notify_transmit_ready(coreAPI, pending->importance,
- pending->timeout, &peer->id,
- ssize, &core_transmit_notify, peer);
+ peer->th = GNUNET_CORE_notify_transmit_ready (coreAPI, pending->importance,
+ pending->timeout, &peer->id,
+ ssize, &core_transmit_notify, peer);
+ if (peer->th == NULL)
+ increment_stats("# notify transmit ready failed");
}
}
&selected->id);
}
#endif
- forward_message(msg, selected, msg_ctx);
+ forward_message (msg, selected, msg_ctx);
}
}