{
struct GNUNET_DATASTORE_QueueEntry *qe;
+ if (NULL != h->th)
+ {
+ GNUNET_CLIENT_notify_transmit_ready_cancel (h->th);
+ h->th = NULL;
+ }
if (h->client != NULL)
{
GNUNET_CLIENT_disconnect (h->client, GNUNET_NO);
GNUNET_SCHEDULER_cancel (h->reconnect_task);
h->reconnect_task = GNUNET_SCHEDULER_NO_TASK;
}
- if (NULL != h->th)
- {
- GNUNET_CLIENT_notify_transmit_ready_cancel (h->th);
- h->th = NULL;
- }
while (NULL != (qe = h->queue_head))
{
GNUNET_assert (NULL != qe->response_proc);
struct GNUNET_DATASTORE_QueueEntry *qe;
h->in_receive = GNUNET_NO;
+ if (h->skip_next_messages > 0)
+ {
+ h->skip_next_messages--;
+ process_queue (h);
+ return;
+ }
if (NULL == (qe = h->queue_head))
{
GNUNET_break (0);
int32_t status;
int was_transmitted;
- if (h->skip_next_messages > 0)
- {
- h->skip_next_messages--;
- process_queue (h);
- return;
- }
if (NULL == (qe = h->queue_head))
{
GNUNET_break (0);
struct ResultContext rc;
const struct DataMessage *dm;
- if (h->skip_next_messages > 0)
- {
- h->skip_next_messages--;
- process_queue (h);
- return;
- }
if (msg == NULL)
{
qe = h->queue_head;