![]() |
GNUnet
0.11.x
|
An entry in the operation queue. More...
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... | |
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.
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().
struct QueueEntry * QueueEntry::prev |
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().
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_().
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().
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().
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().