/**
* If a client stopped asking for more results, how many more do
* we receive from the DB before killing the connection? Trade-off
/**
* If a client stopped asking for more results, how many more do
* we receive from the DB before killing the connection? Trade-off
/**
* Has this message been transmitted to the service?
* Only ever GNUNET_YES for the head of the queue.
/**
* Has this message been transmitted to the service?
* Only ever GNUNET_YES for the head of the queue.
* @param timeout timeout for the operation
* @param response_proc function to call with replies (can be NULL)
* @param qc client context (NOT a closure for response_proc)
* @param timeout timeout for the operation
* @param response_proc function to call with replies (can be NULL)
* @param qc client context (NOT a closure for response_proc)
*/
static struct GNUNET_DATASTORE_QueueEntry *
make_queue_entry (struct GNUNET_DATASTORE_Handle *h, size_t msize,
*/
static struct GNUNET_DATASTORE_QueueEntry *
make_queue_entry (struct GNUNET_DATASTORE_Handle *h, size_t msize,
if ((pos->max_queue < h->queue_size) && (pos->was_transmitted == GNUNET_NO))
{
GNUNET_assert (pos->response_proc != NULL);
if ((pos->max_queue < h->queue_size) && (pos->was_transmitted == GNUNET_NO))
{
GNUNET_assert (pos->response_proc != NULL);
* killed on 'NULL' call below */
#if DEBUG_DATASTORE
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
* killed on 'NULL' call below */
#if DEBUG_DATASTORE
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
* Free a queue entry. Removes the given entry from the
* queue and releases associated resources. Does NOT
* call the callback.
* Free a queue entry. Removes the given entry from the
* queue and releases associated resources. Does NOT
* call the callback.