free_queue_entry (qe);
if (NULL == h->client)
return; /* forced disconnect */
+ rc.cont (rc.cont_cls,
+ GNUNET_SYSERR,
+ _("Failed to receive response from database."));
if (was_transmitted == GNUNET_YES)
- {
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- _("Failed to receive response from database.\n"));
- do_disconnect (h);
- }
+ do_disconnect (h);
return;
}
GNUNET_assert (GNUNET_YES == qe->was_transmitted);
(int) status,
emsg);
#endif
+ process_queue (h);
rc.cont (rc.cont_cls,
status,
emsg);
- process_queue (h);
}
h->in_receive = GNUNET_NO;
if (msg == NULL)
- {
+ {
was_transmitted = qe->was_transmitted;
free_queue_entry (qe);
if (was_transmitted == GNUNET_YES)