GNUNET_DATASTORE_QueueEntry Struct Reference

Entry in our priority queue. More...

Collaboration diagram for GNUNET_DATASTORE_QueueEntry:

Data Fields
struct GNUNET_DATASTORE_QueueEntry *	next
	This is a linked list. More...
struct GNUNET_DATASTORE_QueueEntry *	prev
	This is a linked list. More...
struct GNUNET_DATASTORE_Handle *	h
	Handle to the master context. More...
GNUNET_DATASTORE_ContinuationWithStatus	cont
	Function to call after transmission of the request. More...
void *	cont_cls
	Closure for cont. More...
union QueueContext	qc
	Context for the operation. More...
struct GNUNET_MQ_Envelope *	env
	Envelope of the request to transmit, NULL after transmission. More...
struct GNUNET_SCHEDULER_Task *	delay_warn_task
	Task we run if this entry stalls the queue and we need to warn the user. More...
unsigned int	priority
	Priority in the queue. More...
unsigned int	max_queue
	Maximum allowed length of queue (otherwise this request should be discarded). More...
uint16_t	response_type
	Expected response type. More...

Detailed Description

Entry in our priority queue.

Definition at line 99 of file datastore_api.c.

Field Documentation

next

struct GNUNET_DATASTORE_QueueEntry* GNUNET_DATASTORE_QueueEntry::next

This is a linked list.

Definition at line 104 of file datastore_api.c.

Referenced by find_qe(), make_queue_entry(), process_job_queue(), and reconnect().

prev

struct GNUNET_DATASTORE_QueueEntry* GNUNET_DATASTORE_QueueEntry::prev

This is a linked list.

Definition at line 109 of file datastore_api.c.

Referenced by make_queue_entry().

h

struct GNUNET_DATASTORE_Handle* GNUNET_DATASTORE_QueueEntry::h

Handle to the master context.

Definition at line 114 of file datastore_api.c.

Referenced by free_qe(), free_queue_entry(), GNUNET_DATASTORE_cancel(), GNUNET_FS_dequeue_(), GNUNET_FS_queue_(), GNUNET_NAMESTORE_record_set_edit_begin(), GNUNET_NAMESTORE_record_set_edit_cancel(), GNUNET_NAMESTORE_records_store(), GNUNET_NAMESTORE_zone_to_name(), make_queue_entry(), records_lookup(), start_job(), and stop_job().

cont

GNUNET_DATASTORE_ContinuationWithStatus GNUNET_DATASTORE_QueueEntry::cont

Function to call after transmission of the request.

Definition at line 119 of file datastore_api.c.

Referenced by force_reconnect(), GNUNET_NAMECACHE_block_cache(), GNUNET_NAMESTORE_record_set_edit_cancel(), GNUNET_NAMESTORE_records_store(), handle_block_cache_response(), handle_generic_response(), and warn_delay().

cont_cls

void* GNUNET_DATASTORE_QueueEntry::cont_cls

Closure for cont.

Definition at line 124 of file datastore_api.c.

Referenced by force_reconnect(), GNUNET_NAMECACHE_block_cache(), GNUNET_NAMESTORE_record_set_edit_cancel(), GNUNET_NAMESTORE_records_store(), handle_block_cache_response(), handle_generic_response(), and warn_delay().

qc

union QueueContext GNUNET_DATASTORE_QueueEntry::qc

Context for the operation.

Definition at line 129 of file datastore_api.c.

Referenced by GNUNET_DATASTORE_disconnect(), handle_data(), handle_data_end(), handle_status(), make_queue_entry(), and mq_error_handler().

env

struct GNUNET_MQ_Envelope* GNUNET_DATASTORE_QueueEntry::env

Envelope of the request to transmit, NULL after transmission.

Definition at line 135 of file datastore_api.c.

Referenced by httpdomain.httpdomain.HTTPResource::add_target_and_index(), free_qe(), free_queue_entry(), get_queue_head(), GNUNET_DATASTORE_cancel(), GNUNET_NAMESTORE_record_set_edit_begin(), GNUNET_NAMESTORE_record_set_edit_cancel(), GNUNET_NAMESTORE_records_store(), GNUNET_NAMESTORE_zone_to_name(), make_queue_entry(), mq_error_handler(), process_queue(), reconnect(), records_lookup(), and typescriptdomain.TypeScriptDefinition::run().

delay_warn_task

struct GNUNET_SCHEDULER_Task* GNUNET_DATASTORE_QueueEntry::delay_warn_task

Task we run if this entry stalls the queue and we need to warn the user.

Definition at line 141 of file datastore_api.c.

Referenced by delay_warning(), free_queue_entry(), mq_error_handler(), and process_queue().

priority

unsigned int GNUNET_DATASTORE_QueueEntry::priority

Priority in the queue.

Definition at line 146 of file datastore_api.c.

Referenced by GNUNET_FS_queue_(), make_queue_entry(), and process_job_queue().

max_queue

unsigned int GNUNET_DATASTORE_QueueEntry::max_queue

Maximum allowed length of queue (otherwise this request should be discarded).

Definition at line 152 of file datastore_api.c.

Referenced by make_queue_entry().

response_type

uint16_t GNUNET_DATASTORE_QueueEntry::response_type

Expected response type.

Definition at line 157 of file datastore_api.c.

Referenced by delay_warning(), get_queue_head(), GNUNET_DATASTORE_disconnect(), make_queue_entry(), and mq_error_handler().

---

The documentation for this struct was generated from the following file:

• src/service/datastore/datastore_api.c