QueueEntry Struct Reference

An entry in the operation queue. More...

Collaboration diagram for QueueEntry:

Data Fields
struct QueueEntry *	next
	The next DLL pointer. More...
struct QueueEntry *	prev
	The prev DLL pointer. More...
struct GNUNET_TESTBED_Operation *	op
	The operation this entry holds. More...
unsigned int	nres
	How many units of resources does the operation need. More...
struct Queue *	queue
	Queue this entry is queued with. More...
struct PendingMessage *	pm
	Pending message this entry is for, or NULL for none. More...
uint64_t	mid
	Message ID used for this message with the queue used for transmission. More...

Detailed Description

An entry in the operation queue.

Entry identifying transmission in one of our struct Queue which still awaits an ACK.

This is used to ensure we do not overwhelm a communicator and limit the number of messages outstanding per communicator (say in case communicator is CPU bound) and per queue (in case bandwidth allocation exceeds what the communicator can actually provide towards a particular peer/target).

Definition at line 47 of file testbed_api_operations.c.

Field Documentation

next

struct QueueEntry * QueueEntry::next

The next DLL pointer.

Kept as a DLL.

Definition at line 52 of file testbed_api_operations.c.

Referenced by decide_capacity(), and recheck_waiting().

prev

struct QueueEntry * QueueEntry::prev

The prev DLL pointer.

Kept as a DLL.

Definition at line 57 of file testbed_api_operations.c.

op

struct GNUNET_TESTBED_Operation* QueueEntry::op

The operation this entry holds.

Definition at line 62 of file testbed_api_operations.c.

Referenced by assign_timeslot(), change_state(), cleanup_tslots(), decide_capacity(), GNUNET_TESTBED_operation_create_(), GNUNET_TESTBED_operation_queue_reset_max_active_(), process_rq_task(), recheck_waiting(), and rq_add().

nres

unsigned int QueueEntry::nres

How many units of resources does the operation need.

Definition at line 67 of file testbed_api_operations.c.

Referenced by change_state(), decide_capacity(), and GNUNET_TESTBED_operation_release_().

queue

struct Queue* QueueEntry::queue

Queue this entry is queued with.

Definition at line 1676 of file gnunet-service-tng.c.

Referenced by __attribute__(), adaptive_queue_set_max_active(), GNUNET_TESTBED_operation_queue_create_(), handle_send_message_ack(), process_rq_task(), queue_send_msg(), and update_tslots().

pm

struct PendingMessage* QueueEntry::pm

Pending message this entry is for, or NULL for none.

Definition at line 1681 of file gnunet-service-tng.c.

Referenced by free_pending_message(), free_queue(), handle_send_message_ack(), and queue_send_msg().

mid

uint64_t QueueEntry::mid

Message ID used for this message with the queue used for transmission.

Definition at line 1686 of file gnunet-service-tng.c.

Referenced by queue_send_msg().

---

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

• src/testbed/testbed_api_operations.c
• src/transport/gnunet-service-tng.c