General-purpose message queue. More...

Collaboration diagram for MQ library:

Data Structures
struct	GNUNET_MQ_MessageHandler
	Message handler for a specific message type. More...

Macros
#define	GNUNET_MQ_msg_extra(mvar, esize, type)
	Allocate an envelope, with extra space allocated after the space needed by the message struct. More...

#define	GNUNET_MQ_msg(mvar, type) GNUNET_MQ_msg_extra (mvar, 0, type)
	Allocate a GNUNET_MQ_Envelope. More...

#define	GNUNET_MQ_msg_header(type) GNUNET_MQ_msg_ (NULL, sizeof(struct GNUNET_MessageHeader), type)
	Allocate a GNUNET_MQ_Envelope, where the message only consists of a header. More...

#define	GNUNET_MQ_msg_header_extra(mh, esize, type) GNUNET_MQ_msg_ (&mh, (esize) + sizeof(struct GNUNET_MessageHeader), type)
	Allocate a GNUNET_MQ_Envelope, where the message only consists of a header and extra space. More...

#define	GNUNET_MQ_msg_nested_mh(mvar, type, mh)
	Allocate a GNUNET_MQ_Envelope, and append a payload message after the given message struct. More...

#define	GNUNET_MQ_extract_nested_mh(var)
	Return a pointer to the message at the end of the given message. More...

#define	GNUNET_MQ_handler_end()
	End-marker for the handlers array. More...

Typedefs
typedef void(*	GNUNET_MQ_MessageCallback) (void cls, const struct GNUNET_MessageHeader msg)
	Called when a message has been received. More...

typedef int(*	GNUNET_MQ_MessageValidationCallback) (void cls, const struct GNUNET_MessageHeader msg)
	Called when a message needs to be validated. More...

typedef void(*	GNUNET_MQ_SendImpl) (struct GNUNET_MQ_Handle mq, const struct GNUNET_MessageHeader msg, void *impl_state)
	Signature of functions implementing the sending functionality of a message queue. More...

typedef void(*	GNUNET_MQ_DestroyImpl) (struct GNUNET_MQ_Handle mq, void impl_state)
	Signature of functions implementing the destruction of a message queue. More...

typedef void(*	GNUNET_MQ_CancelImpl) (struct GNUNET_MQ_Handle mq, void impl_state)
	Implementation function that cancels the currently sent message. More...

typedef void(*	GNUNET_MQ_ErrorHandler) (void *cls, enum GNUNET_MQ_Error error)
	Generic error handler, called with the appropriate error code and the same closure specified at the creation of the message queue. More...

Enumerations
enum	GNUNET_MQ_Error { GNUNET_MQ_ERROR_READ = 1 , GNUNET_MQ_ERROR_WRITE = 2 , GNUNET_MQ_ERROR_TIMEOUT = 4 , GNUNET_MQ_ERROR_MALFORMED = 8 , GNUNET_MQ_ERROR_NO_MATCH = 16 }
	Error codes for the queue. More...

enum	GNUNET_MQ_PriorityPreferences { GNUNET_MQ_PRIO_BACKGROUND = 0 , GNUNET_MQ_PRIO_BEST_EFFORT = 1 , GNUNET_MQ_PRIO_URGENT = 2 , GNUNET_MQ_PRIO_CRITICAL_CONTROL = 3 , GNUNET_MQ_PRIORITY_MASK = 3 , GNUNET_MQ_PREF_UNRELIABLE = 16 , GNUNET_MQ_PREF_LOW_LATENCY = 32 , GNUNET_MQ_PREF_CORK_ALLOWED = 64 , GNUNET_MQ_PREF_GOODPUT = 128 , GNUNET_MQ_PREF_OUT_OF_ORDER = 256 }
	Per envelope preferences and priorities. More...

Functions
const struct GNUNET_MessageHeader *	GNUNET_MQ_extract_nested_mh_ (const struct GNUNET_MessageHeader *mh, uint16_t base_size)
	Implementation of the #GNUNET_MQ_extract_nexted_mh macro. More...

const struct GNUNET_MessageHeader *	GNUNET_MQ_env_get_msg (const struct GNUNET_MQ_Envelope *env)
	Obtain message contained in envelope. More...

const struct GNUNET_MQ_Envelope *	GNUNET_MQ_env_next (const struct GNUNET_MQ_Envelope *env)
	Return next envelope in queue. More...

struct GNUNET_MQ_Envelope *	GNUNET_MQ_msg_nested_mh_ (struct GNUNET_MessageHeader *mhp, uint16_t base_size, uint16_t type, const struct GNUNET_MessageHeader nested_mh)
	Implementation of the GNUNET_MQ_msg_nested_mh macro. More...

void	GNUNET_MQ_dll_insert_head (struct GNUNET_MQ_Envelope env_head, struct GNUNET_MQ_Envelope env_tail, struct GNUNET_MQ_Envelope *env)
	Insert env into the envelope DLL starting at env_head Note that env must not be in any MQ while this function is used with DLLs defined outside of the MQ module. More...

void	GNUNET_MQ_dll_insert_tail (struct GNUNET_MQ_Envelope env_head, struct GNUNET_MQ_Envelope env_tail, struct GNUNET_MQ_Envelope *env)
	Insert env into the envelope DLL starting at env_head Note that env must not be in any MQ while this function is used with DLLs defined outside of the MQ module. More...

void	GNUNET_MQ_dll_remove (struct GNUNET_MQ_Envelope env_head, struct GNUNET_MQ_Envelope env_tail, struct GNUNET_MQ_Envelope *env)
	Remove env from the envelope DLL starting at env_head. More...

struct GNUNET_MQ_MessageHandler *	GNUNET_MQ_copy_handlers (const struct GNUNET_MQ_MessageHandler *handlers)
	Copy an array of handlers. More...

struct GNUNET_MQ_MessageHandler *	GNUNET_MQ_copy_handlers2 (const struct GNUNET_MQ_MessageHandler handlers, GNUNET_MQ_MessageCallback agpl_handler, void agpl_cls)
	Copy an array of handlers, appending AGPL handler. More...

unsigned int	GNUNET_MQ_count_handlers (const struct GNUNET_MQ_MessageHandler *handlers)
	Count the handlers in a handler array. More...

struct GNUNET_NotificationContext *	GNUNET_notification_context_create (unsigned int queue_length)
	Create a new notification context. More...

void	GNUNET_notification_context_destroy (struct GNUNET_NotificationContext *nc)
	Destroy the context, force disconnect for all subscribers. More...

void	GNUNET_notification_context_add (struct GNUNET_NotificationContext nc, struct GNUNET_MQ_Handle mq)
	Add a subscriber to the notification context. More...

void	GNUNET_notification_context_broadcast (struct GNUNET_NotificationContext nc, const struct GNUNET_MessageHeader msg, int can_drop)
	Send a message to all subscribers of this context. More...

unsigned int	GNUNET_notification_context_get_size (struct GNUNET_NotificationContext *nc)
	Return active number of subscribers in this context. More...

will return a <tt>struct

Defines a static function name which takes two arguments and a context-pointer for validating and handling variable-sized messages of type code and with a message type argument of str.

Given such arguments, the function GNUNET_MQ_MessageHandler for the given message type.

The macro is to be used as follows: struct GNUNET_MessageTest { ... }; // can be variable size static int check_test (void *cls, const struct GNUNET_MessageTest *msg) { const char *ctx = cls; GNUNET_assert (0 == strcmp ("context", ctx)); // ... } static void handle_test (void *cls, const struct GNUNET_MessageTest *msg) { const char *ctx = cls; GNUNET_assert (0 == strcmp ("context", ctx)); // ... }

struct GNUNET_MQ_MessageHandler handlers[] = { GNUNET_MQ_hd_var_size(test_message, GNUNET_MESSAGE_TYPE_TEST, struct GNUNET_MessageTest, "context"), GNUNET_MQ_handler_end() };

Parameters

name	unique basename for the functions
code	message type constant
str	type of the message (a struct)
ctx	context for the callbacks

enum GNUNET_MQ_PreferenceKind { GNUNET_MQ_PREFERENCE_NONE = 0 , GNUNET_MQ_PREFERENCE_BANDWIDTH = 1 , GNUNET_MQ_PREFERENCE_LATENCY = 2 , GNUNET_MQ_PREFERENCE_RELIABILITY }

Enum defining all known preference categories. More...

int GNUNET_MQ_handle_message (const struct GNUNET_MQ_MessageHandler *handlers, const struct GNUNET_MessageHeader *mh)

Call the message message handler that was registered for the type of the given message in the given handlers list. More...

struct GNUNET_MQ_Envelope * GNUNET_MQ_msg_ (struct GNUNET_MessageHeader **mhp, uint16_t size, uint16_t type)

Create a new envelope. More...

struct GNUNET_MQ_Envelope * GNUNET_MQ_msg_copy (const struct GNUNET_MessageHeader *hdr)

Create a new envelope by copying an existing message. More...

void GNUNET_MQ_discard (struct GNUNET_MQ_Envelope *mqm)

Discard the message queue message, free all allocated resources. More...

struct GNUNET_MQ_Envelope * GNUNET_MQ_get_current_envelope (struct GNUNET_MQ_Handle *mq)

Function to obtain the current envelope from within GNUNET_MQ_SendImpl implementations. More...

struct GNUNET_MQ_Envelope * GNUNET_MQ_env_copy (struct GNUNET_MQ_Envelope *env)

Function to copy an envelope. More...

struct GNUNET_MQ_Envelope * GNUNET_MQ_get_last_envelope (struct GNUNET_MQ_Handle *mq)

Function to obtain the last envelope in the queue. More...

void GNUNET_MQ_env_set_options (struct GNUNET_MQ_Envelope *env, enum GNUNET_MQ_PriorityPreferences pp)

Set application-specific options for this envelope. More...

enum GNUNET_MQ_PriorityPreferences GNUNET_MQ_env_get_options (struct GNUNET_MQ_Envelope *env)

Get performance preferences set for this envelope. More...

enum GNUNET_MQ_PriorityPreferences GNUNET_MQ_env_combine_options (enum GNUNET_MQ_PriorityPreferences p1, enum GNUNET_MQ_PriorityPreferences p2)

Combine performance preferences set for different envelopes that are being combined into one larger envelope. More...

struct GNUNET_MQ_Envelope * GNUNET_MQ_unsent_head (struct GNUNET_MQ_Handle *mq)

Remove the first envelope that has not yet been sent from the message queue and return it. More...

void GNUNET_MQ_set_options (struct GNUNET_MQ_Handle *mq, enum GNUNET_MQ_PriorityPreferences pp)

Set application-specific options for this queue. More...

unsigned int GNUNET_MQ_get_length (struct GNUNET_MQ_Handle *mq)

Obtain the current length of the message queue. More...

void GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq, struct GNUNET_MQ_Envelope *ev)

Send a message with the given message queue. More...

void GNUNET_MQ_send_copy (struct GNUNET_MQ_Handle *mq, const struct GNUNET_MQ_Envelope *ev)

Send a copy of a message with the given message queue. More...

void GNUNET_MQ_send_cancel (struct GNUNET_MQ_Envelope *ev)

Cancel sending the message. More...

uint32_t GNUNET_MQ_assoc_add (struct GNUNET_MQ_Handle *mq, void *assoc_data)

Associate the assoc_data in mq with a unique request id. More...

void * GNUNET_MQ_assoc_get (struct GNUNET_MQ_Handle *mq, uint32_t request_id)

Get the data associated with a request_id in a queue. More...

void * GNUNET_MQ_assoc_remove (struct GNUNET_MQ_Handle *mq, uint32_t request_id)

Remove the association for a request_id. More...

struct GNUNET_MQ_Handle * GNUNET_MQ_queue_for_callbacks (GNUNET_MQ_SendImpl send, GNUNET_MQ_DestroyImpl destroy, GNUNET_MQ_CancelImpl cancel, void *impl_state, const struct GNUNET_MQ_MessageHandler *handlers, GNUNET_MQ_ErrorHandler error_handler, void *cls)

Create a message queue for the specified handlers. More...

void GNUNET_MQ_set_handlers_closure (struct GNUNET_MQ_Handle *mq, void *handlers_cls)

Change the closure argument in all of the handlers of the mq. More...

void GNUNET_MQ_notify_sent (struct GNUNET_MQ_Envelope *ev, GNUNET_SCHEDULER_TaskCallback cb, void *cb_cls)

Call a callback once the envelope has been sent, that is, sending it can not be canceled anymore. More...

void GNUNET_MQ_destroy (struct GNUNET_MQ_Handle *mq)

Destroy the message queue. More...

struct GNUNET_MQ_DestroyNotificationHandle * GNUNET_MQ_destroy_notify (struct GNUNET_MQ_Handle *mq, GNUNET_SCHEDULER_TaskCallback cb, void *cb_cls)

Register function to be called whenever mq is being destroyed. More...

void GNUNET_MQ_destroy_notify_cancel (struct GNUNET_MQ_DestroyNotificationHandle *dnh)

Cancel registration from GNUNET_MQ_destroy_notify(). More...

void GNUNET_MQ_inject_message (struct GNUNET_MQ_Handle *mq, const struct GNUNET_MessageHeader *mh)

Call the message message handler that was registered for the type of the given message in the given message queue. More...

void GNUNET_MQ_inject_error (struct GNUNET_MQ_Handle *mq, enum GNUNET_MQ_Error error)

Call the error handler of a message queue with the given error code. More...

void GNUNET_MQ_impl_send_continue (struct GNUNET_MQ_Handle *mq)

Call the send implementation for the next queued message, if any. More...

void GNUNET_MQ_impl_send_in_flight (struct GNUNET_MQ_Handle *mq)

Call the send notification for the current message, but do not try to send the next message until #gnunet_mq_impl_send_continue is called. More...

void * GNUNET_MQ_impl_state (struct GNUNET_MQ_Handle *mq)

Get the implementation state associated with the message queue. More...

const struct GNUNET_MessageHeader * GNUNET_MQ_impl_current (struct GNUNET_MQ_Handle *mq)

Get the message that should currently be sent. More...

const char * GNUNET_MQ_preference_to_string (enum GNUNET_MQ_PreferenceKind type)

Convert an enum GNUNET_MQ_PreferenceType to a string. More...

#define GNUNET_MQ_hd_var_size(name, code, str, ctx)

#define GNUNET_MQ_check_zero_termination(m)

Insert code for a "check_" function that verifies that a given variable-length message received over the network is followed by a 0-terminated string. More...

#define GNUNET_MQ_check_boxed_message(m)

Insert code for a "check_" function that verifies that a given variable-length message received over the network is followed by another variable-length message that fits exactly with the given size. More...

will return a <tt>struct GNUNET_MQ_MessageHandler</tt>

Defines a static function name which takes as a single argument a message handler for fixed-sized messages of type code and with a message type argument of str.

Given such an argument, the function for the given message type.

The macro is to be used as follows: struct GNUNET_MessageTest { ... }; // must be fixed size static void handle_test_message (void *cls, const struct GNUNET_MessageTest *msg) { ... }

struct GNUNET_MQ_MessageHandler handlers[] = { GNUNET_MQ_hd_fixed_size(test_message, GNUNET_MESSAGE_TYPE_TEST, struct GNUNET_MessageTest, "context"), GNUNET_MQ_handler_end() };

Parameters


  
    name unique basename for the functions 
    code message type constant 
    str type of the message (a struct) 
    ctx context for the callbacks

#define GNUNET_MQ_hd_fixed_size(name, code, str, ctx)

Detailed Description

General-purpose message queue.

General-purpose broadcast mechanism for message queues.

See also: Documentation; Documentation

Macro Definition Documentation

◆ GNUNET_MQ_msg_extra

#define GNUNET_MQ_msg_extra	(	mvar,
		esize,
		type
	)

Value:

  GNUNET_MQ_msg_ (((struct GNUNET_MessageHeader **) &(mvar)), \
                  (esize) + sizeof *(mvar),                   \
                  (type))

Allocate an envelope, with extra space allocated after the space needed by the message struct.

The allocated message will already have the type and size field set.

Parameters

mvar	variable to store the allocated message in; must have a header field; can be NULL
esize	extra space to allocate after the message
type	type of the message

Returns: the MQ message

Definition at line 62 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_msg

#define GNUNET_MQ_msg	(	mvar,
		type
	)	GNUNET_MQ_msg_extra (mvar, 0, type)

Allocate a GNUNET_MQ_Envelope.

The contained message will already have the type and size field set.

Parameters

mvar	variable to store the allocated message in; must have a header field; can be NULL
type	type of the message

Returns: the allocated envelope

Definition at line 77 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_msg_header

#define GNUNET_MQ_msg_header ( type ) GNUNET_MQ_msg_ (NULL, sizeof(struct GNUNET_MessageHeader), type)

Allocate a GNUNET_MQ_Envelope, where the message only consists of a header.

The allocated message will already have the type and size field set.

Parameters

type	type of the message

Definition at line 86 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_msg_header_extra

#define GNUNET_MQ_msg_header_extra	(	mh,
		esize,
		type
	)	GNUNET_MQ_msg_ (&mh, (esize) + sizeof(struct GNUNET_MessageHeader), type)

Allocate a GNUNET_MQ_Envelope, where the message only consists of a header and extra space.

The allocated message will already have the type and size field set.

Parameters

mh	pointer that will changed to point at to the allocated message header
esize	extra space to allocate after the message header
type	type of the message

Definition at line 98 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_msg_nested_mh

#define GNUNET_MQ_msg_nested_mh	(	mvar,
		type,
		mh
	)

Value:

  ({                                                                          \
    struct GNUNET_MQ_Envelope *_ev;                                           \
    _ev = GNUNET_MQ_msg_nested_mh_ ((struct GNUNET_MessageHeader **) &(mvar), \
                                    sizeof(*(mvar)),                         \
                                    (type),                                   \
                                    (mh));                                    \
    (void) (mvar)->header;  /* type check */                                   \
    _ev;                                                                      \
  })

Allocate a GNUNET_MQ_Envelope, and append a payload message after the given message struct.

Parameters

mvar	pointer to a message struct, will be changed to point at the newly allocated message, whose size is 'sizeof(*mvar) + ntohs (mh->size)'
type	message type of the allocated message, has no effect on the nested message
mh	message to nest

Returns: a newly allocated 'struct GNUNET_MQ_Envelope *'

Definition at line 112 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_extract_nested_mh

#define GNUNET_MQ_extract_nested_mh ( var )

Value:

GNUNET_MQ_extract_nested_mh_ ((struct GNUNET_MessageHeader *) (var), \

sizeof(*(var)))

GNUNET_MQ_extract_nested_mh_

const struct GNUNET_MessageHeader * GNUNET_MQ_extract_nested_mh_(const struct GNUNET_MessageHeader *mh, uint16_t base_size)

Implementation of the #GNUNET_MQ_extract_nexted_mh macro.

Definition: mq.c:740

Return a pointer to the message at the end of the given message.

Parameters

var	pointer to a message struct, the type of the expression determines the base size, the space after the base size is the nested message

Returns: a 'struct GNUNET_MessageHeader *' that points at the nested message of the given message, or NULL if the given message in var does not have any space after the message struct

Definition at line 132 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_handler_end

#define GNUNET_MQ_handler_end ( )

Value:

  {                             \
    NULL, NULL, NULL, 0, 0      \
  }

End-marker for the handlers array.

Definition at line 531 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_hd_fixed_size

#define GNUNET_MQ_hd_fixed_size	(	name,
		code,
		str,
		ctx
	)

Value:

  ({                                                                    \
    void (*_cb)(void *cls, const str *msg) = &handle_ ## name;           \
    ((struct GNUNET_MQ_MessageHandler){ NULL,                            \
                                        (GNUNET_MQ_MessageCallback) _cb, \
                                        (ctx),                           \
                                        (code),                          \
                                        sizeof(str) });                  \
  })

Definition at line 565 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_hd_var_size

#define GNUNET_MQ_hd_var_size	(	name,
		code,
		str,
		ctx
	)

Value:

  __extension__ ({                                                            \
    int (*_mv)(void *cls, const str *msg) = &check_ ## name;                  \
    void (*_cb)(void *cls, const str *msg) = &handle_ ## name;                \
    ((struct GNUNET_MQ_MessageHandler){ (GNUNET_MQ_MessageValidationCallback) \
                                        _mv,                                \
                                        (GNUNET_MQ_MessageCallback) _cb,      \
                                        (ctx),                                \
                                        (code),                               \
                                        sizeof(str) });                       \
  })

Definition at line 617 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_check_zero_termination

#define GNUNET_MQ_check_zero_termination ( m )

Value:

  {                                                               \
    const char *str = (const char *) &m[1];                       \
    const struct GNUNET_MessageHeader *hdr =                      \
      (const struct GNUNET_MessageHeader *) m;                    \
    uint16_t slen = ntohs (hdr->size) - sizeof(*m);              \
    if ((0 == slen) || (memchr (str, 0, slen) != &str[slen - 1])) \
    {                                                             \
      GNUNET_break (0);                                           \
      return GNUNET_NO;                                           \
    }                                                             \
  }

Insert code for a "check_" function that verifies that a given variable-length message received over the network is followed by a 0-terminated string.

If the message m is not followed by a 0-terminated string, an error is logged and the function is returned with GNUNET_NO.

Parameters

an	IPC message with proper type to determine the size, starting with a `struct GNUNET_MessageHeader`

Definition at line 640 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_check_boxed_message

#define GNUNET_MQ_check_boxed_message ( m )

Value:

  {                                                      \
    const struct GNUNET_MessageHeader *inbox =           \
      (const struct GNUNET_MessageHeader *) &m[1];       \
    const struct GNUNET_MessageHeader *hdr =             \
      (const struct GNUNET_MessageHeader *) m;           \
    uint16_t slen = ntohs (hdr->size) - sizeof(*m);     \
    if ((slen < sizeof(struct GNUNET_MessageHeader)) || \
        (slen != ntohs (inbox->size)))                   \
    {                                                    \
      GNUNET_break (0);                                  \
      return GNUNET_NO;                                  \
    }                                                    \
  }

Insert code for a "check_" function that verifies that a given variable-length message received over the network is followed by another variable-length message that fits exactly with the given size.

If the message m is not followed by another struct GNUNET_MessageHeader with a size that adds up to the total size, an error is logged and the function is returned with GNUNET_NO.

Parameters

an	IPC message with proper type to determine the size, starting with a `struct GNUNET_MessageHeader`

Definition at line 666 of file gnunet_mq_lib.h.

Typedef Documentation

◆ GNUNET_MQ_MessageCallback

typedef void(* GNUNET_MQ_MessageCallback) (void *cls, const struct GNUNET_MessageHeader *msg)

Called when a message has been received.

Parameters

cls	closure
msg	the received message

Definition at line 318 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_MessageValidationCallback

typedef int(* GNUNET_MQ_MessageValidationCallback) (void *cls, const struct GNUNET_MessageHeader *msg)

Called when a message needs to be validated.

Parameters

cls	closure
msg	the received message

Returns: GNUNET_OK if the message is well-formed, GNUNET_SYSERR if not

Definition at line 332 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_SendImpl

typedef void(* GNUNET_MQ_SendImpl) (struct GNUNET_MQ_Handle *mq, const struct GNUNET_MessageHeader *msg, void *impl_state)

Signature of functions implementing the sending functionality of a message queue.

Parameters

mq	the message queue
msg	the message to send
impl_state	state of the implementation

Definition at line 346 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_DestroyImpl

typedef void(* GNUNET_MQ_DestroyImpl) (struct GNUNET_MQ_Handle *mq, void *impl_state)

Signature of functions implementing the destruction of a message queue.

Implementations must not free mq, but should take care of impl_state.

Parameters

mq	the message queue to destroy
impl_state	state of the implementation

Definition at line 361 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_CancelImpl

typedef void(* GNUNET_MQ_CancelImpl) (struct GNUNET_MQ_Handle *mq, void *impl_state)

Implementation function that cancels the currently sent message.

Parameters

mq	message queue
impl_state	state specific to the implementation

Definition at line 372 of file gnunet_mq_lib.h.

◆ GNUNET_MQ_ErrorHandler

typedef void(* GNUNET_MQ_ErrorHandler) (void *cls, enum GNUNET_MQ_Error error)

Generic error handler, called with the appropriate error code and the same closure specified at the creation of the message queue.

Not every message queue implementation supports an error handler.

Parameters

cls	closure
error	error code

Definition at line 386 of file gnunet_mq_lib.h.

Enumeration Type Documentation

◆ GNUNET_MQ_Error

enum GNUNET_MQ_Error

Error codes for the queue.

Enumerator
GNUNET_MQ_ERROR_READ	Failed to read message from the network. FIXME: Likely not properly distinguished from TIMEOUT case in the code!
GNUNET_MQ_ERROR_WRITE	FIXME: document!
GNUNET_MQ_ERROR_TIMEOUT	FIXME: document!
GNUNET_MQ_ERROR_MALFORMED	We received a message that was malformed and thus could not be passed to its handler.
GNUNET_MQ_ERROR_NO_MATCH	We received a message for which we have no matching handler.

Definition at line 201 of file gnunet_mq_lib.h.

 {
   GNUNET_MQ_ERROR_READ = 1,
  
   GNUNET_MQ_ERROR_WRITE = 2,
  
   GNUNET_MQ_ERROR_TIMEOUT = 4,
  
   GNUNET_MQ_ERROR_MALFORMED = 8,
  
   GNUNET_MQ_ERROR_NO_MATCH = 16
 };

◆ GNUNET_MQ_PriorityPreferences

enum GNUNET_MQ_PriorityPreferences

Per envelope preferences and priorities.

Enumerator
GNUNET_MQ_PRIO_BACKGROUND	Lowest priority, i.e. background traffic (e.g. NSE, FS). This is the default!
GNUNET_MQ_PRIO_BEST_EFFORT	Best-effort traffic (e.g. CADET relay, DHT)
GNUNET_MQ_PRIO_URGENT	Urgent traffic (local peer, e.g. Conversation).
GNUNET_MQ_PRIO_CRITICAL_CONTROL	Highest priority, control traffic (e.g. CORE/CADET KX).
GNUNET_MQ_PRIORITY_MASK	Bit mask to apply to extract the priority bits.
GNUNET_MQ_PREF_UNRELIABLE	Flag to indicate that unreliable delivery is acceptable. This means TRANSPORT will not attempt to receive an acknowledgment. CORE will just pass this flag through. CADET will use unreliable delivery if this flag is set. Note that even without this flag, messages may be lost by TRANSPORT and CORE. Thus, how "strong" the semantics of reliable delivery are depends on the layer!
GNUNET_MQ_PREF_LOW_LATENCY	Flag to indicate that low latency is important. This flag must generally not be used in combination with #GNUNET_MQ_PREF_CORKING_ALLOWED as it would be a contradiction. When this flags is set, the envelope may skip forward in the queue (depending on priority) and also TRANSPORT should attempt to pick a communicator with particularly low latency.
GNUNET_MQ_PREF_CORK_ALLOWED	Flag to indicate that CORKing is acceptable. This allows the receiver to delay transmission in hope of combining this message with other messages into a larger transmission with less per-message overhead.
GNUNET_MQ_PREF_GOODPUT	Flag to indicate that high bandwidth is desired. This flag indicates that the method chosen for transmission should focus on overall goodput. It rarely makes sense to combine this flag with GNUNET_MQ_PREF_LOW_LATENCY.
GNUNET_MQ_PREF_OUT_OF_ORDER	Flag to indicate that out-of-order delivery is OK.

Definition at line 237 of file gnunet_mq_lib.h.

 {
   GNUNET_MQ_PRIO_BACKGROUND = 0,
  
   GNUNET_MQ_PRIO_BEST_EFFORT = 1,
  
   GNUNET_MQ_PRIO_URGENT = 2,
  
   GNUNET_MQ_PRIO_CRITICAL_CONTROL = 3,
  
   GNUNET_MQ_PRIORITY_MASK = 3,
  
   GNUNET_MQ_PREF_UNRELIABLE = 16,
  
   GNUNET_MQ_PREF_LOW_LATENCY = 32,
  
   GNUNET_MQ_PREF_CORK_ALLOWED = 64,
  
   GNUNET_MQ_PREF_GOODPUT = 128,
  
   GNUNET_MQ_PREF_OUT_OF_ORDER = 256,
 };

◆ GNUNET_MQ_PreferenceKind

enum GNUNET_MQ_PreferenceKind

Enum defining all known preference categories.

Deprecated:: will be replaced by enum GNUNET_MQ_PriorityPreference

Enumerator
GNUNET_MQ_PREFERENCE_NONE	No preference was expressed.
GNUNET_MQ_PREFERENCE_BANDWIDTH	The preferred transmission for this envelope focuses on maximizing bandwidth.
GNUNET_MQ_PREFERENCE_LATENCY	The preferred transmission for this envelope foces on minimizing latency.
GNUNET_MQ_PREFERENCE_RELIABILITY	The preferred transmission for this envelope foces on reliability.

Definition at line 1087 of file gnunet_mq_lib.h.

 {
   GNUNET_MQ_PREFERENCE_NONE = 0,
  
   GNUNET_MQ_PREFERENCE_BANDWIDTH = 1,
  
   GNUNET_MQ_PREFERENCE_LATENCY = 2,
  
   GNUNET_MQ_PREFERENCE_RELIABILITY = 3
  
 #define GNUNET_MQ_PREFERENCE_COUNT 4
 };

Function Documentation

◆ GNUNET_MQ_extract_nested_mh_()

const struct GNUNET_MessageHeader* GNUNET_MQ_extract_nested_mh_	(	const struct GNUNET_MessageHeader *	mh,
		uint16_t	base_size
	)

Implementation of the #GNUNET_MQ_extract_nexted_mh macro.

Parameters

mh	message header to extract nested message header from
base_size	size of the message before the nested message's header appears

Returns: pointer to the nested message, does not copy the message OR NULL in case of a malformed message.

Definition at line 740 of file mq.c.

 {
   uint16_t whole_size;
   uint16_t nested_size;
   const struct GNUNET_MessageHeader *nested_msg;
  
   whole_size = ntohs (mh->size);
   GNUNET_assert (whole_size >= base_size);
   nested_size = whole_size - base_size;
   if (0 == nested_size)
     return NULL;
   if (nested_size < sizeof(struct GNUNET_MessageHeader))
   {
     GNUNET_break_op (0);
     return NULL;
   }
   nested_msg = (const struct GNUNET_MessageHeader *) ((char *) mh + base_size);
   if (ntohs (nested_msg->size) != nested_size)
   {
     GNUNET_break_op (0);
     return NULL;
   }
   return nested_msg;
 }

References GNUNET_assert, GNUNET_break_op, mh, and GNUNET_MessageHeader::size.

◆ GNUNET_MQ_env_get_msg()

const struct GNUNET_MessageHeader* GNUNET_MQ_env_get_msg ( const struct GNUNET_MQ_Envelope * env )

Obtain message contained in envelope.

Parameters

env	the envelope

Returns: message contained in the envelope

Definition at line 879 of file mq.c.

 {
   return env->mh;
 }

References env, and GNUNET_MQ_Envelope::mh.

Referenced by do_send(), mqm_execute(), and route_message().

Here is the caller graph for this function:

◆ GNUNET_MQ_env_next()

const struct GNUNET_MQ_Envelope* GNUNET_MQ_env_next ( const struct GNUNET_MQ_Envelope * env )

Return next envelope in queue.

Parameters

env	a queued envelope

Returns: next one, or NULL

Definition at line 886 of file mq.c.

 {
   return env->next;
 }

References env, and GNUNET_MQ_Envelope::next.

Referenced by route_message().

Here is the caller graph for this function:

◆ GNUNET_MQ_msg_nested_mh_()

struct GNUNET_MQ_Envelope* GNUNET_MQ_msg_nested_mh_	(	struct GNUNET_MessageHeader **	mhp,
		uint16_t	base_size,
		uint16_t	type,
		const struct GNUNET_MessageHeader *	nested_mh
	)

Implementation of the GNUNET_MQ_msg_nested_mh macro.

Parameters

mhp	pointer to the message header pointer that will be changed to allocate at the newly allocated space for the message.
base_size	size of the data before the nested message
type	type of the message in the envelope
nested_mh	the message to append to the message after base_size

Definition at line 548 of file mq.c.

 {
   struct GNUNET_MQ_Envelope *mqm;
   uint16_t size;
  
   if (NULL == nested_mh)
     return GNUNET_MQ_msg_ (mhp,
                            base_size,
                            type);
   size = base_size + ntohs (nested_mh->size);
   /* check for uint16_t overflow */
   if (size < base_size)
     return NULL;
   mqm = GNUNET_MQ_msg_ (mhp,
                         size,
                         type);
   GNUNET_memcpy ((char *) mqm->mh + base_size,
                  nested_mh,
                  ntohs (nested_mh->size));
   return mqm;
 }

References GNUNET_memcpy, GNUNET_MQ_msg_(), GNUNET_MQ_Envelope::mh, GNUNET_MessageHeader::size, size, and type.

Here is the call graph for this function:

◆ GNUNET_MQ_dll_insert_head()

void GNUNET_MQ_dll_insert_head	(	struct GNUNET_MQ_Envelope **	env_head,
		struct GNUNET_MQ_Envelope **	env_tail,
		struct GNUNET_MQ_Envelope *	env
	)

Insert env into the envelope DLL starting at env_head Note that env must not be in any MQ while this function is used with DLLs defined outside of the MQ module.

This is just in case some application needs to also manage a FIFO of envelopes independent of MQ itself and wants to re-use the pointers internal to env. Use with caution.

Parameters

[in,out]	env_head	of envelope DLL
[in,out]	env_tail	tail of envelope DLL
[in,out]	env	element to insert at the tail

Definition at line 924 of file mq.c.

 {
   GNUNET_CONTAINER_DLL_insert (*env_head,
                                *env_tail,
                                env);
 }

References env, and GNUNET_CONTAINER_DLL_insert.

Referenced by route_message().

Here is the caller graph for this function:

◆ GNUNET_MQ_dll_insert_tail()

void GNUNET_MQ_dll_insert_tail	(	struct GNUNET_MQ_Envelope **	env_head,
		struct GNUNET_MQ_Envelope **	env_tail,
		struct GNUNET_MQ_Envelope *	env
	)

Insert env into the envelope DLL starting at env_head Note that env must not be in any MQ while this function is used with DLLs defined outside of the MQ module.

This is just in case some application needs to also manage a FIFO of envelopes independent of MQ itself and wants to re-use the pointers internal to env. Use with caution.

Parameters

[in,out]	env_head	of envelope DLL
[in,out]	env_tail	tail of envelope DLL
[in,out]	env	element to insert at the tail

Definition at line 935 of file mq.c.

 {
   GNUNET_CONTAINER_DLL_insert_tail (*env_head,
                                     *env_tail,
                                     env);
 }

References env, and GNUNET_CONTAINER_DLL_insert_tail.

Referenced by route_message().

Here is the caller graph for this function:

◆ GNUNET_MQ_dll_remove()

void GNUNET_MQ_dll_remove	(	struct GNUNET_MQ_Envelope **	env_head,
		struct GNUNET_MQ_Envelope **	env_tail,
		struct GNUNET_MQ_Envelope *	env
	)

Remove env from the envelope DLL starting at env_head.

Note that env must not be in any MQ while this function is used with DLLs defined outside of the MQ module. This is just in case some application needs to also manage a FIFO of envelopes independent of MQ itself and wants to re-use the pointers internal to env. Use with caution.

Parameters

[in,out]	env_head	of envelope DLL
[in,out]	env_tail	tail of envelope DLL
[in,out]	env	element to remove from the DLL

Definition at line 946 of file mq.c.

 {
   GNUNET_CONTAINER_DLL_remove (*env_head,
                                *env_tail,
                                env);
 }

References env, and GNUNET_CONTAINER_DLL_remove.

Referenced by dir_ready_cb(), and discard_buffer().

Here is the caller graph for this function:

◆ GNUNET_MQ_copy_handlers()

struct GNUNET_MQ_MessageHandler* GNUNET_MQ_copy_handlers ( const struct GNUNET_MQ_MessageHandler * handlers )

Copy an array of handlers.

Useful if the array has been declared in local memory and needs to be persisted for future use.

Parameters

handlers Array of handlers to be copied.

Returns: A newly allocated array of handlers. Needs to be freed with GNUNET_free.

Definition at line 957 of file mq.c.

 {
   struct GNUNET_MQ_MessageHandler *copy;
   unsigned int count;
  
   if (NULL == handlers)
     return NULL;
   count = GNUNET_MQ_count_handlers (handlers);
   copy = GNUNET_new_array (count + 1,
                            struct GNUNET_MQ_MessageHandler);
   GNUNET_memcpy (copy,
                  handlers,
                  count * sizeof(struct GNUNET_MQ_MessageHandler));
   return copy;
 }

References GNUNET_memcpy, GNUNET_MQ_count_handlers(), GNUNET_new_array, and handlers.

Referenced by GNUNET_CADET_open_port(), GNUNET_CADET_TEST_ruN(), GNUNET_CORE_connect(), GNUNET_MQ_queue_for_callbacks(), and GNUNET_SERVICE_run_().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_copy_handlers2()

struct GNUNET_MQ_MessageHandler* GNUNET_MQ_copy_handlers2	(	const struct GNUNET_MQ_MessageHandler *	handlers,
		GNUNET_MQ_MessageCallback	agpl_handler,
		void *	agpl_cls
	)

Copy an array of handlers, appending AGPL handler.

Useful if the array has been declared in local memory and needs to be persisted for future use.

Parameters

handlers	Array of handlers to be copied. Can be NULL (nothing done).
agpl_handler	function to call for AGPL handling
agpl_cls	closure for agpl_handler

Returns: A newly allocated array of handlers. Needs to be freed with GNUNET_free.

Definition at line 975 of file mq.c.

 {
   struct GNUNET_MQ_MessageHandler *copy;
   unsigned int count;
  
   if (NULL == handlers)
     return NULL;
   count = GNUNET_MQ_count_handlers (handlers);
   copy = GNUNET_new_array (count + 2,
                            struct GNUNET_MQ_MessageHandler);
   GNUNET_memcpy (copy,
                  handlers,
                  count * sizeof(struct GNUNET_MQ_MessageHandler));
   copy[count].mv = NULL;
   copy[count].cb = agpl_handler;
   copy[count].cls = agpl_cls;
   copy[count].type = GNUNET_MESSAGE_TYPE_REQUEST_AGPL;
   copy[count].expected_size = sizeof(struct GNUNET_MessageHeader);
   return copy;
 }

References GNUNET_MQ_MessageHandler::cb, GNUNET_MQ_MessageHandler::cls, GNUNET_MQ_MessageHandler::expected_size, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_REQUEST_AGPL, GNUNET_MQ_count_handlers(), GNUNET_new_array, handlers, GNUNET_MQ_MessageHandler::mv, and GNUNET_MQ_MessageHandler::type.

Referenced by GNUNET_CADET_open_port(), GNUNET_SERVICE_run_(), and GNUNET_SERVICE_start().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_count_handlers()

unsigned int GNUNET_MQ_count_handlers ( const struct GNUNET_MQ_MessageHandler * handlers )

Count the handlers in a handler array.

Parameters

handlers Array of handlers to be counted.

Returns: The number of handlers in the array.

Definition at line 1000 of file mq.c.

 {
   unsigned int i;
  
   if (NULL == handlers)
     return 0;
   for (i = 0; NULL != handlers[i].cb; i++)
     ;
   return i;
 }

References handlers.

Referenced by GNUNET_CORE_connect(), GNUNET_MQ_copy_handlers(), and GNUNET_MQ_copy_handlers2().

Here is the caller graph for this function:

◆ GNUNET_MQ_handle_message()

int GNUNET_MQ_handle_message	(	const struct GNUNET_MQ_MessageHandler *	handlers,
		const struct GNUNET_MessageHeader *	mh
	)

Call the message message handler that was registered for the type of the given message in the given handlers list.

This function is indented to be used for the implementation of message queues.

Parameters

handlers	a set of handlers
mh	message to dispatch

Returns: GNUNET_OK on success, GNUNET_NO if no handler matched, GNUNET_SYSERR if message was rejected by check function

Definition at line 187 of file mq.c.

 {
   bool handled = false;
   uint16_t msize = ntohs (mh->size);
   uint16_t mtype = ntohs (mh->type);
  
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Received message of type %u and size %u\n",
        mtype,
        msize);
   if (NULL == handlers)
     goto done;
   for (const struct GNUNET_MQ_MessageHandler *handler = handlers;
        NULL != handler->cb;
        handler++)
   {
     if (handler->type == mtype)
     {
       handled = true;
       if ( (handler->expected_size > msize) ||
            ( (handler->expected_size != msize) &&
              (NULL == handler->mv) ) )
       {
         /* Too small, or not an exact size and
            no 'mv' handler to check rest */
         LOG (GNUNET_ERROR_TYPE_ERROR,
              "Received malformed message of type %u\n",
              (unsigned int) handler->type);
         return GNUNET_SYSERR;
       }
       if ( (NULL == handler->mv) ||
            (GNUNET_OK ==
             handler->mv (handler->cls,
                          mh)) )
       {
         /* message well-formed, pass to handler */
         handler->cb (handler->cls, mh);
       }
       else
       {
         /* Message rejected by check routine */
         LOG (GNUNET_ERROR_TYPE_ERROR,
              "Received malformed message of type %u\n",
              (unsigned int) handler->type);
         return GNUNET_SYSERR;
       }
       break;
     }
   }
 done:
   if (! handled)
   {
     LOG (GNUNET_ERROR_TYPE_INFO,
          "No handler for message of type %u and size %u\n",
          mtype,
          msize);
     return GNUNET_NO;
   }
   return GNUNET_OK;
 }

References GNUNET_break_op, GNUNET_MQ_ERROR_MALFORMED, GNUNET_MQ_handle_message(), GNUNET_MQ_inject_error(), GNUNET_SYSERR, GNUNET_MQ_Handle::handlers, mh, mq, and ret.

Referenced by demultiplex_with_cmc(), GDS_u_receive(), and GNUNET_MQ_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_msg_()

struct GNUNET_MQ_Envelope* GNUNET_MQ_msg_	(	struct GNUNET_MessageHeader **	mhp,
		uint16_t	size,
		uint16_t	type
	)

Create a new envelope.

Parameters

mhp	message header to store the allocated message header in, can be NULL
size	size of the message to allocate
type	type of the message, will be set in the allocated message

Returns: the allocated MQ message

Definition at line 516 of file mq.c.

 {
   struct GNUNET_MQ_Envelope *ev;
  
   ev = GNUNET_malloc (size + sizeof(struct GNUNET_MQ_Envelope));
   ev->mh = (struct GNUNET_MessageHeader *) &ev[1];
   ev->mh->size = htons (size);
   ev->mh->type = htons (type);
   if (NULL != mhp)
     *mhp = ev->mh;
   return ev;
 }

References GNUNET_malloc, GNUNET_MQ_Envelope::mh, GNUNET_MessageHeader::size, size, GNUNET_MessageHeader::type, and type.

Referenced by GNUNET_MQ_msg_nested_mh_().

Here is the caller graph for this function:

◆ GNUNET_MQ_msg_copy()

struct GNUNET_MQ_Envelope* GNUNET_MQ_msg_copy ( const struct GNUNET_MessageHeader * hdr )

Create a new envelope by copying an existing message.

Parameters

hdr	header of the message to copy

Returns: envelope containing hdr

Definition at line 533 of file mq.c.

 {
   struct GNUNET_MQ_Envelope *mqm;
   uint16_t size = ntohs (hdr->size);
  
   mqm = GNUNET_malloc (sizeof(*mqm) + size);
   mqm->mh = (struct GNUNET_MessageHeader *) &mqm[1];
   GNUNET_memcpy (mqm->mh,
                  hdr,
                  size);
   return mqm;
 }

References GNUNET_malloc, GNUNET_memcpy, GNUNET_MQ_Envelope::mh, GNUNET_MessageHeader::size, and size.

Referenced by do_connect(), GNUNET_MQ_env_copy(), GNUNET_notification_context_broadcast(), GNUNET_PEERINFO_add_peer(), GNUNET_TRANSPORT_offer_hello(), GST_clients_broadcast_peer_notification(), GST_forwarded_operation_reply_relay(), handle_barrier_status(), handle_send_msg(), handle_start(), notify_client(), plugin_session_info_cb(), route_message(), schedule_next_hello(), send_key(), send_peer_information(), send_ping(), transmit_task_cb(), and unicast().

Here is the caller graph for this function:

◆ GNUNET_MQ_discard()

void GNUNET_MQ_discard ( struct GNUNET_MQ_Envelope * mqm )

Discard the message queue message, free all allocated resources.

Must be called in the event that a message is created but should not actually be sent.

Parameters

mqm	the message to discard

Definition at line 285 of file mq.c.

 {
   GNUNET_assert (NULL == ev->parent_queue);
   GNUNET_free (ev);
 }

References GNUNET_assert, GNUNET_free, and GNUNET_MQ_Envelope::parent_queue.

Referenced by abort_all_requests(), broadcast_status(), cadet_mq_cancel_impl(), core_mq_cancel_impl(), destroy_channel(), discard_buffer(), disconnect_and_free_peer_entry(), free_ait(), free_channel_client(), free_it(), free_op(), free_qe(), free_queue_entry(), free_ze(), GCCH_handle_channel_plaintext_data(), GCP_request_mq_cancel(), GCP_send_ooo(), GCP_set_mq(), GCT_send_cancel(), GNUNET_ABD_request_cancel(), GNUNET_GNS_lookup_cancel(), GNUNET_MQ_destroy(), GSF_peer_disconnect_handler(), handle_dns_response(), handle_result(), make_queue_entry(), mqm_execute(), send_client_element(), send_to_channel(), and set_operation_destroy().

Here is the caller graph for this function:

◆ GNUNET_MQ_get_current_envelope()

struct GNUNET_MQ_Envelope* GNUNET_MQ_get_current_envelope ( struct GNUNET_MQ_Handle * mq )

Function to obtain the current envelope from within GNUNET_MQ_SendImpl implementations.

Parameters

mq	message queue to interrogate

Returns: the current envelope

Definition at line 813 of file mq.c.

 {
   return mq->current_envelope;
 }

References GNUNET_MQ_Handle::current_envelope, and mq.

Referenced by cadet_mq_send_impl(), core_mq_send_impl(), and mq_send_impl().

Here is the caller graph for this function:

◆ GNUNET_MQ_env_copy()

struct GNUNET_MQ_Envelope* GNUNET_MQ_env_copy ( struct GNUNET_MQ_Envelope * env )

Function to copy an envelope.

The envelope must not yet be in any queue or have any options or callbacks set.

Parameters

env	envelope to copy

Returns: copy of env

Definition at line 359 of file mq.c.

 {
   GNUNET_assert (NULL == env->next);
   GNUNET_assert (NULL == env->parent_queue);
   GNUNET_assert (NULL == env->sent_cb);
   GNUNET_assert (GNUNET_NO == env->have_custom_options);
   return GNUNET_MQ_msg_copy (env->mh);
 }

References env, GNUNET_assert, GNUNET_MQ_msg_copy(), GNUNET_NO, GNUNET_MQ_Envelope::have_custom_options, GNUNET_MQ_Envelope::mh, GNUNET_MQ_Envelope::next, GNUNET_MQ_Envelope::parent_queue, and GNUNET_MQ_Envelope::sent_cb.

Referenced by cadet_channel_end_cb(), and dns_pre_request_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_get_last_envelope()

struct GNUNET_MQ_Envelope* GNUNET_MQ_get_last_envelope ( struct GNUNET_MQ_Handle * mq )

Function to obtain the last envelope in the queue.

Parameters

mq	message queue to interrogate

Returns: the last envelope in the queue

Definition at line 820 of file mq.c.

 {
   if (NULL != mq->envelope_tail)
     return mq->envelope_tail;
  
   return mq->current_envelope;
 }

References GNUNET_MQ_Handle::current_envelope, GNUNET_MQ_Handle::envelope_tail, and mq.

◆ GNUNET_MQ_env_set_options()

void GNUNET_MQ_env_set_options	(	struct GNUNET_MQ_Envelope *	env,
		enum GNUNET_MQ_PriorityPreferences	pp
	)

Set application-specific options for this envelope.

Overrides the options set for the queue with GNUNET_MQ_set_options() for this message only.

Parameters

env	message to set options for
pp	priority and preferences to set for env

Definition at line 830 of file mq.c.

 {
   env->priority = pp;
   env->have_custom_options = GNUNET_YES;
 }

Referenced by adv_transmit(), client_request_complete_alice(), route_message(), send_to_channel(), and transmit_pending().

Here is the caller graph for this function:

◆ GNUNET_MQ_env_get_options()

enum GNUNET_MQ_PriorityPreferences GNUNET_MQ_env_get_options ( struct GNUNET_MQ_Envelope * env )

Get performance preferences set for this envelope.

Parameters

env	message to set options for

Returns: priority and preferences to use

Definition at line 830 of file mq.c.

 {
   struct GNUNET_MQ_Handle *mq = env->parent_queue;
  
   if (GNUNET_YES == env->have_custom_options)
     return env->priority;
   if (NULL == mq)
     return 0;
   return mq->priority;
 }

Referenced by cadet_mq_send_impl(), core_mq_send_impl(), mq_send_impl(), and route_message().

Here is the caller graph for this function:

◆ GNUNET_MQ_env_combine_options()

enum GNUNET_MQ_PriorityPreferences GNUNET_MQ_env_combine_options	(	enum GNUNET_MQ_PriorityPreferences	p1,
		enum GNUNET_MQ_PriorityPreferences	p2
	)

Combine performance preferences set for different envelopes that are being combined into one larger envelope.

Parameters

p1	one set of preferences
p2	second set of preferences

Returns: combined priority and preferences to use

Definition at line 830 of file mq.c.

 {
   enum GNUNET_MQ_PriorityPreferences ret;
  
   ret = GNUNET_MAX (p1 & GNUNET_MQ_PRIORITY_MASK, p2 & GNUNET_MQ_PRIORITY_MASK);
   ret |= ((p1 & GNUNET_MQ_PREF_UNRELIABLE) & (p2 & GNUNET_MQ_PREF_UNRELIABLE));
   ret |=
     ((p1 & GNUNET_MQ_PREF_LOW_LATENCY) | (p2 & GNUNET_MQ_PREF_LOW_LATENCY));
   ret |=
     ((p1 & GNUNET_MQ_PREF_CORK_ALLOWED) & (p2 & GNUNET_MQ_PREF_CORK_ALLOWED));
   ret |= ((p1 & GNUNET_MQ_PREF_GOODPUT) & (p2 & GNUNET_MQ_PREF_GOODPUT));
   ret |=
     ((p1 & GNUNET_MQ_PREF_OUT_OF_ORDER) & (p2 & GNUNET_MQ_PREF_OUT_OF_ORDER));
   return ret;
 }

References env, GNUNET_YES, GNUNET_MQ_Envelope::have_custom_options, and GNUNET_MQ_Envelope::priority.

◆ GNUNET_MQ_unsent_head()

struct GNUNET_MQ_Envelope* GNUNET_MQ_unsent_head ( struct GNUNET_MQ_Handle * mq )

Remove the first envelope that has not yet been sent from the message queue and return it.

Parameters

mq	queue to remove envelope from

Returns: NULL if queue is empty (or has no envelope that is not under transmission)

Definition at line 344 of file mq.c.

 {
   struct GNUNET_MQ_Envelope *env;
  
   env = mq->envelope_head;
   GNUNET_CONTAINER_DLL_remove (mq->envelope_head,
                                mq->envelope_tail,
                                env);
   mq->queue_length--;
   env->parent_queue = NULL;
   return env;
 }

References env, GNUNET_MQ_Handle::envelope_head, GNUNET_MQ_Handle::envelope_tail, GNUNET_CONTAINER_DLL_remove, mq, GNUNET_MQ_Envelope::parent_queue, and GNUNET_MQ_Handle::queue_length.

Referenced by send_to_channel().

Here is the caller graph for this function:

◆ GNUNET_MQ_set_options()

void GNUNET_MQ_set_options	(	struct GNUNET_MQ_Handle *	mq,
		enum GNUNET_MQ_PriorityPreferences	pp
	)

Set application-specific options for this queue.

Parameters

mq	message queue to set options for
pp	priority and preferences to use by default

Definition at line 871 of file mq.c.

 {
   mq->priority = pp;
 }

References mq, and GNUNET_MQ_Handle::priority.

Referenced by connect_notify(), and handle_core_connect().

Here is the caller graph for this function:

◆ GNUNET_MQ_get_length()

unsigned int GNUNET_MQ_get_length ( struct GNUNET_MQ_Handle * mq )

Obtain the current length of the message queue.

Parameters

mq	queue to inspect

Returns: number of queued, non-transmitted messages

Definition at line 293 of file mq.c.

 {
   if (! mq->in_flight)
   {
     return mq->queue_length;
   }
   return mq->queue_length - 1;
 }

References GNUNET_MQ_Handle::in_flight, mq, and GNUNET_MQ_Handle::queue_length.

Referenced by continue_writing(), GCP_send(), GCP_send_ooo(), GNUNET_notification_context_broadcast(), GNUNET_STATISTICS_destroy(), GNUNET_TRANSPORT_communicator_receive(), GSC_CLIENTS_deliver_message(), GSC_NEIGHBOURS_get_queue_length(), handle_p2p_get(), schedule_action(), send_to_channel(), transmit_pending(), and unicast().

Here is the caller graph for this function:

◆ GNUNET_MQ_send()

void GNUNET_MQ_send	(	struct GNUNET_MQ_Handle *	mq,
		struct GNUNET_MQ_Envelope *	ev
	)

Send a message with the given message queue.

May only be called once per message.

Parameters

mq	message queue
ev	the envelope with the message to send.

Definition at line 304 of file mq.c.

 {
   GNUNET_assert (NULL != mq);
   GNUNET_assert (NULL == ev->parent_queue);
  
   mq->queue_length++;
   if (mq->queue_length >= 10000000)
   {
     /* This would seem like a bug... */
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "MQ with %u entries extended by message of type %u (FC broken?)\n",
                 (unsigned int) mq->queue_length,
                 (unsigned int) ntohs (ev->mh->type));
   }
   ev->parent_queue = mq;
   /* is the implementation busy? queue it! */
   if ((NULL != mq->current_envelope) || (NULL != mq->send_task))
   {
     GNUNET_CONTAINER_DLL_insert_tail (mq->envelope_head,
                                       mq->envelope_tail,
                                       ev);
     return;
   }
   GNUNET_assert (NULL == mq->envelope_head);
   mq->current_envelope = ev;
  
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "sending message of type %u and size %u, queue empty (MQ: %p)\n",
        ntohs (ev->mh->type),
        ntohs (ev->mh->size),
        mq);
  
   mq->send_impl (mq,
                  ev->mh,
                  mq->impl_state);
 }

References GNUNET_MQ_Handle::current_envelope, GNUNET_MQ_Handle::envelope_head, GNUNET_MQ_Handle::envelope_tail, GNUNET_assert, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MQ_Handle::impl_state, LOG, GNUNET_MQ_Envelope::mh, mq, GNUNET_MQ_Envelope::parent_queue, GNUNET_MQ_Handle::queue_length, GNUNET_MQ_Handle::send_impl, GNUNET_MQ_Handle::send_task, GNUNET_MessageHeader::size, and GNUNET_MessageHeader::type.

Referenced by add_get_request_to_pending(), add_to_tc(), addr_cb(), adv_transmit(), announce_reconnect(), attr_iter_cb(), attr_iter_finished(), attr_store_cont(), broadcast_status(), cadet_channel_end_cb(), cadet_mq_send_now(), cancel_stream(), change_handle_ego(), change_handle_name(), change_service(), change_srv_handle_member_id(), check_cadet_ring_message(), check_credential_iteration_start(), check_dht_local_hello_offer(), check_peer_online(), check_phone_ring(), check_ticket_iteration_start(), check_zone_to_name(), clean_up_channel(), client_request_complete_alice(), client_response_handler(), client_send_response(), conclude_autoconfig_request(), connect_cb(), consume_result_cb(), core_mq_send_impl(), core_send_connect_info(), cores_send_disconnect_info(), create_internal(), create_loc_uri(), cred_iter_finished(), cred_store_cont(), decode_and_send(), decrypt_conclude(), dispatch_buffer(), dns_pre_request_handler(), do_blacklist_check(), do_connect(), do_flood(), do_peer_connect(), do_plugin_connect(), do_send(), fail_intersection_operation(), fail_union_operation(), finish_cmc_handling_with_continue(), finish_handling_raw_message(), GAS_handle_address_destroyed(), GAS_handle_reservation_request(), GAS_scheduling_transmit_address_suggestion(), GCP_request_mq_cancel(), GCP_send_ooo(), get_action(), get_all_peers_iterator(), get_all_tunnels_iterator(), GNUNET_ARM_request_service_list(), GNUNET_ATS_address_destroy(), GNUNET_ATS_address_update(), GNUNET_ATS_performance_change_preference(), GNUNET_ATS_performance_give_feedback(), GNUNET_ATS_performance_list_addresses(), GNUNET_ATS_reserve_bandwidth(), GNUNET_CADET_channel_create(), GNUNET_CADET_channel_destroy(), GNUNET_CADET_close_port(), GNUNET_CADET_drop_message(), GNUNET_CADET_receive_done(), GNUNET_CONSENSUS_conclude(), GNUNET_CONSENSUS_create(), GNUNET_CONSENSUS_insert(), GNUNET_CONVERSATION_call_resume(), GNUNET_CONVERSATION_call_suspend(), GNUNET_CONVERSATION_caller_hang_up(), GNUNET_CONVERSATION_caller_pick_up(), GNUNET_CONVERSATION_caller_resume(), GNUNET_CONVERSATION_caller_suspend(), GNUNET_DATASTORE_disconnect(), GNUNET_DHT_get_stop(), GNUNET_DHT_hello_get(), GNUNET_DHT_hello_offer(), GNUNET_DHT_monitor_stop(), GNUNET_DHT_put(), GNUNET_DNS_request_answer(), GNUNET_DNS_request_drop(), GNUNET_DNS_request_forward(), GNUNET_FS_get_indexed_files(), GNUNET_FS_indexing_send_list(), GNUNET_IDENTITY_create(), GNUNET_IDENTITY_delete(), GNUNET_IDENTITY_ego_lookup(), GNUNET_IDENTITY_ego_lookup_by_suffix(), GNUNET_IDENTITY_rename(), GNUNET_MESSENGER_connect(), GNUNET_MESSENGER_disconnect(), GNUNET_MESSENGER_get_message(), GNUNET_MESSENGER_send_message(), GNUNET_MESSENGER_set_name(), GNUNET_MESSENGER_update(), GNUNET_MQ_send_copy(), GNUNET_NAMECACHE_block_cache(), GNUNET_NAMECACHE_lookup_block(), GNUNET_NAMESTORE_records_store2(), GNUNET_NAMESTORE_zone_iteration_start(), GNUNET_NAMESTORE_zone_iteration_start2(), GNUNET_NAMESTORE_zone_iteration_stop(), GNUNET_NAMESTORE_zone_iterator_next(), GNUNET_NAMESTORE_zone_monitor_next(), GNUNET_NAMESTORE_zone_to_name(), GNUNET_NAT_AUTO_autoconfig_start(), GNUNET_NAT_request_reversal(), GNUNET_NAT_stun_handle_packet(), GNUNET_notification_context_broadcast(), GNUNET_PEERINFO_add_peer(), GNUNET_PEERSTORE_iterate(), GNUNET_PEERSTORE_store(), GNUNET_PEERSTORE_watch(), GNUNET_PEERSTORE_watch_cancel(), GNUNET_RECLAIM_get_attributes_next(), GNUNET_RECLAIM_get_attributes_start(), GNUNET_RECLAIM_get_attributes_stop(), GNUNET_RECLAIM_get_credentials_next(), GNUNET_RECLAIM_get_credentials_start(), GNUNET_RECLAIM_get_credentials_stop(), GNUNET_RECLAIM_ticket_iteration_next(), GNUNET_RECLAIM_ticket_iteration_start(), GNUNET_RECLAIM_ticket_iteration_stop(), GNUNET_RECLAIM_ticket_revoke(), GNUNET_REVOCATION_query(), GNUNET_REVOCATION_revoke(), GNUNET_RPS_seed_ids(), GNUNET_RPS_stream_request(), GNUNET_RPS_sub_start(), GNUNET_RPS_sub_stop(), GNUNET_RPS_view_request(), GNUNET_RPS_view_request_cancel(), GNUNET_SCALARPRODUCT_accept_computation(), GNUNET_SCALARPRODUCT_start_computation(), GNUNET_SECRETSHARING_create_session(), GNUNET_SECRETSHARING_decrypt(), gnunet_send(), GNUNET_SET_add_element(), GNUNET_SET_commit(), GNUNET_SET_copy_lazy(), GNUNET_SET_iterate(), GNUNET_SET_operation_cancel(), GNUNET_SET_remove_element(), GNUNET_SETI_add_element(), GNUNET_SETI_commit(), GNUNET_SETI_create(), GNUNET_SETI_operation_cancel(), GNUNET_SETU_add_element(), GNUNET_SETU_commit(), GNUNET_SETU_create(), GNUNET_SETU_operation_cancel(), GNUNET_TESTBED_barrier_cancel(), GNUNET_TESTBED_barrier_init_(), GNUNET_TESTBED_barrier_wait(), GNUNET_TESTBED_controller_connect(), GNUNET_TESTBED_forward_operation_msg_(), GNUNET_TESTBED_queue_message_(), GNUNET_TRANSPORT_address_to_string(), GNUNET_TRANSPORT_application_suggest_cancel(), GNUNET_TRANSPORT_communicator_notify(), GNUNET_TRANSPORT_communicator_receive(), GNUNET_TRANSPORT_manipulation_set(), GNUNET_TRANSPORT_offer_hello(), GNUNET_TRANSPORT_TESTING_send(), GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue(), GNUNET_TRANSPORT_TESTING_transport_communicator_send(), GSC_CLIENTS_deliver_message(), GSC_CLIENTS_notify_client_about_neighbour(), GSC_CLIENTS_solicit_request(), GSC_KX_encrypt_and_transmit(), GSC_send_to_client(), GST_clients_broadcast_peer_notification(), GST_forwarded_operation_reply_relay(), GST_send_operation_fail_msg(), GST_send_operation_success_msg(), handle_add_host(), handle_backchannel_encapsulation(), handle_barrier_status(), handle_block_cache(), handle_cadet_audio_message(), handle_cadet_hangup_message(), handle_cadet_pickup_message(), handle_cadet_resume_message(), handle_cadet_ring_message(), handle_cadet_suspend_message(), handle_channel_created(), handle_client_accept(), handle_client_address_to_string(), handle_client_call_message(), handle_client_copy_lazy_prepare(), handle_client_evaluate(), handle_client_hangup_message(), handle_client_init(), handle_client_loc_sign(), handle_client_monitor_peers(), handle_client_pickup_message(), handle_client_resume_message(), handle_client_suspend_message(), handle_client_unindex(), handle_communicator_backchannel(), handle_create_queue(), handle_data(), handle_datastore_reply(), handle_disconnect(), handle_get(), handle_get_all(), handle_get_peers(), handle_gns_response(), handle_incoming_msg(), handle_info_tunnels(), handle_iter_element(), handle_list(), handle_lookup_block(), handle_lookup_block_it(), handle_lookup_by_suffix_message(), handle_lookup_message(), handle_notify(), handle_peer_create(), handle_peer_get_config(), handle_peer_start(), handle_peer_stop(), handle_ping(), handle_query(), handle_record_lookup(), handle_request(), handle_revoke_message(), handle_room_close(), handle_room_entry(), handle_room_open(), handle_search_result(), handle_send_msg(), handle_send_ready(), handle_show_path(), handle_slave_get_config(), handle_start(), handle_start_message(), handle_test(), handle_union_p2p_demand(), handle_union_p2p_full_done(), handle_union_p2p_offer(), handle_union_p2p_strata_estimator(), handle_zone_to_name(), hash_for_index_cb(), hash_for_index_val(), intersection_evaluate(), keygen_round2_conclude(), listen_connect(), maybe_finish(), monitor_sync(), mq_send_impl(), mqm_execute(), notify_change(), notify_client(), notify_clients_stun_change(), notify_monitor(), notify_srv_handle_message(), open_port_cb(), opstart_manage_service(), opstart_overlay_connect(), opstart_peer_create(), opstart_peer_destroy(), opstart_peer_reconfigure(), opstart_peer_start(), opstart_peer_stop(), opstart_shutdown_peers(), path_info_iterator(), peer_transmit(), plugin_session_info_cb(), prepare_client_end_notification(), process_dns_result(), process_queue(), process_requests(), put_action(), queue_send_msg(), read_stdio(), reconnect(), reconnect_arm(), reconnect_arm_monitor(), reconnect_phone(), record_iterator(), records_lookup(), response_action(), retry_entry(), return_agpl(), reversal_callback(), revoke_result_cb(), rewatch_it(), schedule_action(), schedule_next_hello(), schedule_transmit_search_request(), search_reconnect(), send_ack(), send_add_address(), send_add_address_message(), send_add_queue(), send_alices_cryptodata_message(), send_bloomfilter(), send_client_done(), send_client_done_and_destroy(), send_client_element(), send_client_removed_element(), send_client_reply(), send_client_status_msg(), send_close_room(), send_controller_link_response(), send_del_address(), send_del_queue(), send_delete_response(), send_echo(), send_element_count(), send_end_msg(), send_enter_room(), send_full_element_iterator(), send_full_set(), send_get(), send_ibf(), send_ic_request(), send_intermediate_response(), send_key(), send_lookup_response(), send_lookup_response_with_filter(), send_message(), send_missing_full_elements_iter(), send_monitor_start(), send_msg(), send_offers_iterator(), send_open_room(), send_overlay_connect_success_msg(), send_p2p_done(), send_packet_to_cadet_channel(), send_peer_information(), send_ping(), send_remaining_elements(), send_reply(), send_request(), send_request_to_client(), send_result_code(), send_simple_cb(), send_simple_single(), send_start_monitor(), send_store_response(), send_stream_peers(), send_ticket_result(), send_to_channel(), send_to_client_iter(), send_transaction_control_msg(), send_tunnel_envelope(), send_tx_response(), send_update_queue(), send_view(), signal_index_ok(), signal_result(), suggest_to_connect(), test_nat_punched(), transmit(), transmit_address_to_client(), transmit_bobs_cryptodata_message(), transmit_bobs_cryptodata_message_multipart(), transmit_call_audio(), transmit_client_response(), transmit_get(), transmit_item(), transmit_pending(), transmit_req_addr(), transmit_set(), transmit_status(), transmit_suggestion(), transmit_task_cb(), transmit_watch(), unicast(), unindex_finish(), union_accept(), union_evaluate(), watch_notifier_it(), and zone_iteration_done_client_continue().

◆ GNUNET_MQ_send_copy()

void GNUNET_MQ_send_copy	(	struct GNUNET_MQ_Handle *	mq,
		const struct GNUNET_MQ_Envelope *	ev
	)

Send a copy of a message with the given message queue.

Can be called repeatedly on the same envelope.

Parameters

mq	message queue
ev	the envelope with the message to send.

Definition at line 370 of file mq.c.

 {
   struct GNUNET_MQ_Envelope *env;
   uint16_t msize;
  
   msize = ntohs (ev->mh->size);
   env = GNUNET_malloc (sizeof(struct GNUNET_MQ_Envelope) + msize);
   env->mh = (struct GNUNET_MessageHeader *) &env[1];
   env->sent_cb = ev->sent_cb;
   env->sent_cls = ev->sent_cls;
   GNUNET_memcpy (&env[1], ev->mh, msize);
   GNUNET_MQ_send (mq, env);
 }

References env, GNUNET_malloc, GNUNET_memcpy, GNUNET_MQ_send(), GNUNET_MQ_Envelope::mh, mq, GNUNET_MQ_Envelope::sent_cb, GNUNET_MQ_Envelope::sent_cls, and GNUNET_MessageHeader::size.

Referenced by GNUNET_ABD_collect(), GNUNET_ABD_verify(), GNUNET_GNS_lookup_limited(), GNUNET_RECLAIM_attribute_delete(), GNUNET_RECLAIM_attribute_store(), GNUNET_RECLAIM_credential_delete(), GNUNET_RECLAIM_credential_store(), GNUNET_RECLAIM_ticket_consume(), GNUNET_RECLAIM_ticket_issue(), and reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_send_cancel()

void GNUNET_MQ_send_cancel ( struct GNUNET_MQ_Envelope * ev )

Cancel sending the message.

Message must have been sent with GNUNET_MQ_send before. May not be called after the notify sent callback has been called

Parameters

ev	queued envelope to cancel

Definition at line 768 of file mq.c.

 {
   struct GNUNET_MQ_Handle *mq = ev->parent_queue;
  
   GNUNET_assert (NULL != mq);
   GNUNET_assert (NULL != mq->cancel_impl);
   GNUNET_assert (0 < mq->queue_length);
   mq->queue_length--;
   if (mq->current_envelope == ev)
   {
     /* complex case, we already started with transmitting
        the message using the callbacks. */
     GNUNET_assert (! mq->in_flight);
     mq->cancel_impl (mq,
                      mq->impl_state);
     /* continue sending the next message, if any */
     mq->current_envelope = mq->envelope_head;
     if (NULL != mq->current_envelope)
     {
       GNUNET_CONTAINER_DLL_remove (mq->envelope_head,
                                    mq->envelope_tail,
                                    mq->current_envelope);
       LOG (GNUNET_ERROR_TYPE_DEBUG,
            "sending canceled message of type %u queue\n",
            ntohs (ev->mh->type));
       mq->send_impl (mq,
                      mq->current_envelope->mh,
                      mq->impl_state);
     }
   }
   else
   {
     /* simple case, message is still waiting in the queue */
     GNUNET_CONTAINER_DLL_remove (mq->envelope_head,
                                  mq->envelope_tail,
                                  ev);
   }
   ev->parent_queue = NULL;
   ev->mh = NULL;
   /* also frees ev */
   GNUNET_free (ev);
 }

References GNUNET_MQ_Handle::cancel_impl, GNUNET_MQ_Handle::current_envelope, GNUNET_MQ_Handle::envelope_head, GNUNET_MQ_Handle::envelope_tail, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_MQ_Handle::impl_state, GNUNET_MQ_Handle::in_flight, LOG, GNUNET_MQ_Envelope::mh, mq, GNUNET_MQ_Envelope::parent_queue, GNUNET_MQ_Handle::queue_length, GNUNET_MQ_Handle::send_impl, and GNUNET_MessageHeader::type.

Referenced by check_cadet_ring_message(), GSF_push_stop_(), mq_cancel_impl(), neighbour_delete(), and shutdown_task().

Here is the caller graph for this function:

◆ GNUNET_MQ_assoc_add()

uint32_t GNUNET_MQ_assoc_add	(	struct GNUNET_MQ_Handle *	mq,
		void *	assoc_data
	)

Associate the assoc_data in mq with a unique request id.

Parameters

mq	message queue, id will be unique for the queue
assoc_data	to associate

Definition at line 575 of file mq.c.

 {
   uint32_t id;
  
   if (NULL == mq->assoc_map)
   {
     mq->assoc_map = GNUNET_CONTAINER_multihashmap32_create (8);
     mq->assoc_id = 1;
   }
   id = mq->assoc_id++;
   GNUNET_assert (GNUNET_OK ==
                  GNUNET_CONTAINER_multihashmap32_put (
                    mq->assoc_map,
                    id,
                    assoc_data,
                    GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
   return id;
 }

References GNUNET_MQ_Handle::assoc_id, GNUNET_MQ_Handle::assoc_map, GNUNET_assert, GNUNET_CONTAINER_multihashmap32_create(), GNUNET_CONTAINER_multihashmap32_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY, GNUNET_OK, id, and mq.

Referenced by GNUNET_SET_commit(), GNUNET_SETI_commit(), and GNUNET_SETU_commit().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_assoc_get()

void* GNUNET_MQ_assoc_get	(	struct GNUNET_MQ_Handle *	mq,
		uint32_t	request_id
	)

Get the data associated with a request_id in a queue.

Parameters

mq	the message queue with the association
request_id	the request id we are interested in

Returns: the associated data

Definition at line 604 of file mq.c.

 {
   if (NULL == mq->assoc_map)
     return NULL;
   return GNUNET_CONTAINER_multihashmap32_get (mq->assoc_map,
                                               request_id);
 }

References GNUNET_MQ_Handle::assoc_map, GNUNET_CONTAINER_multihashmap32_get(), and mq.

Referenced by handle_result().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_assoc_remove()

void* GNUNET_MQ_assoc_remove	(	struct GNUNET_MQ_Handle *	mq,
		uint32_t	request_id
	)

Remove the association for a request_id.

Parameters

mq	the message queue with the association
request_id	the request id we want to remove

Returns: the associated data

Definition at line 622 of file mq.c.

 {
   void *val;
  
   if (NULL == mq->assoc_map)
     return NULL;
   val = GNUNET_CONTAINER_multihashmap32_get (mq->assoc_map,
                                              request_id);
   GNUNET_CONTAINER_multihashmap32_remove_all (mq->assoc_map,
                                               request_id);
   return val;
 }

References GNUNET_MQ_Handle::assoc_map, GNUNET_CONTAINER_multihashmap32_get(), GNUNET_CONTAINER_multihashmap32_remove_all(), and mq.

Referenced by handle_result(), and set_operation_destroy().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_queue_for_callbacks()

struct GNUNET_MQ_Handle* GNUNET_MQ_queue_for_callbacks	(	GNUNET_MQ_SendImpl	send,
		GNUNET_MQ_DestroyImpl	destroy,
		GNUNET_MQ_CancelImpl	cancel,
		void *	impl_state,
		const struct GNUNET_MQ_MessageHandler *	handlers,
		GNUNET_MQ_ErrorHandler	error_handler,
		void *	cls
	)

Create a message queue for the specified handlers.

Parameters

send	function the implements sending messages
destroy	function that implements destroying the queue
cancel	function that implements canceling a message
impl_state	for the queue, passed to send, destroy and cancel
handlers	array of message handlers
error_handler	handler for read and write errors
cls	closure for message handlers and error handler

Returns: a new message queue

Definition at line 465 of file mq.c.

 {
   struct GNUNET_MQ_Handle *mq;
  
   mq = GNUNET_new (struct GNUNET_MQ_Handle);
   mq->send_impl = send;
   mq->destroy_impl = destroy;
   mq->cancel_impl = cancel;
   mq->handlers = GNUNET_MQ_copy_handlers (handlers);
   mq->error_handler = error_handler;
   mq->error_handler_cls = error_handler_cls;
   mq->impl_state = impl_state;
  
   return mq;
 }

References GNUNET_MQ_Handle::cancel_impl, destroy(), GNUNET_MQ_Handle::destroy_impl, error_handler(), GNUNET_MQ_Handle::error_handler, GNUNET_MQ_Handle::error_handler_cls, GNUNET_MQ_copy_handlers(), GNUNET_new, handlers, GNUNET_MQ_Handle::handlers, GNUNET_MQ_Handle::impl_state, mq, and GNUNET_MQ_Handle::send_impl.

Referenced by boot_queue(), connect_peer(), GCT_create_tunnel(), GNUNET_CADET_channel_create(), GNUNET_CLIENT_connect(), handle_channel_created(), handle_connect(), setup_queue(), setup_receiver_mq(), and start_client().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_set_handlers_closure()

void GNUNET_MQ_set_handlers_closure	(	struct GNUNET_MQ_Handle *	mq,
		void *	handlers_cls
	)

Change the closure argument in all of the handlers of the mq.

Parameters

mq	to modify
handlers_cls	new closure to use

Definition at line 489 of file mq.c.

 {
   if (NULL == mq->handlers)
     return;
   for (unsigned int i = 0; NULL != mq->handlers[i].cb; i++)
     mq->handlers[i].cls = handlers_cls;
 }

References GNUNET_MQ_MessageHandler::cb, GNUNET_MQ_MessageHandler::cls, GNUNET_MQ_Handle::handlers, and mq.

Referenced by connect_peer(), GNUNET_CADET_channel_create(), handle_channel_created(), handle_connect(), and start_client().

Here is the caller graph for this function:

◆ GNUNET_MQ_notify_sent()

void GNUNET_MQ_notify_sent	(	struct GNUNET_MQ_Envelope *	ev,
		GNUNET_SCHEDULER_TaskCallback	cb,
		void *	cb_cls
	)

Call a callback once the envelope has been sent, that is, sending it can not be canceled anymore.

There can be only one notify sent callback per envelope.

Parameters

ev	message to call the notify callback for
cb	the notify callback
cb_cls	closure for the callback

Definition at line 638 of file mq.c.

 {
   /* allow setting *OR* clearing callback */
   GNUNET_assert ((NULL == ev->sent_cb) || (NULL == cb));
   ev->sent_cb = cb;
   ev->sent_cls = cb_cls;
 }

References GNUNET_assert, GNUNET_MQ_Envelope::sent_cb, and GNUNET_MQ_Envelope::sent_cls.

Referenced by check_cadet_ring_message(), check_peer_online(), dispatch_buffer(), do_send(), finish_handling_raw_message(), GCP_request_mq_cancel(), GCP_send(), GCP_send_ooo(), GNUNET_CONSENSUS_insert(), GNUNET_DATASTORE_disconnect(), GNUNET_DHT_hello_offer(), GNUNET_DHT_put(), GNUNET_DHT_put_cancel(), GNUNET_PEERINFO_add_peer(), GNUNET_PEERSTORE_store(), gnunet_send(), GNUNET_SET_add_element(), GNUNET_SET_remove_element(), GNUNET_SETI_add_element(), GNUNET_SETU_add_element(), GNUNET_TRANSPORT_offer_hello(), GNUNET_TRANSPORT_TESTING_send(), GNUNET_TRANSPORT_TESTING_transport_communicator_send(), handle_client_hangup_message(), handle_datastore_reply(), handle_send_msg(), mq_send_impl(), read_stdio(), reconnect(), schedule_action(), schedule_peer_transmission(), send_message(), send_msg(), send_p2p_done(), send_remaining_elements(), send_tunnel_envelope(), transmit_bobs_cryptodata_message(), transmit_bobs_cryptodata_message_multipart(), transmit_content(), transmit_get(), transmit_pending(), transmit_set(), and transmit_watch().

Here is the caller graph for this function:

◆ GNUNET_MQ_destroy()

void GNUNET_MQ_destroy ( struct GNUNET_MQ_Handle * mq )

Destroy the message queue.

Parameters

mq	message queue to destroy

Definition at line 683 of file mq.c.

 {
   struct GNUNET_MQ_DestroyNotificationHandle *dnh;
  
   if (NULL != mq->destroy_impl)
   {
     mq->destroy_impl (mq, mq->impl_state);
   }
   if (NULL != mq->send_task)
   {
     GNUNET_SCHEDULER_cancel (mq->send_task);
     mq->send_task = NULL;
   }
   while (NULL != mq->envelope_head)
   {
     struct GNUNET_MQ_Envelope *ev;
  
     ev = mq->envelope_head;
     ev->parent_queue = NULL;
     GNUNET_CONTAINER_DLL_remove (mq->envelope_head, mq->envelope_tail, ev);
     GNUNET_assert (0 < mq->queue_length);
     mq->queue_length--;
     LOG (GNUNET_ERROR_TYPE_DEBUG,
          "MQ destroy drops message of type %u\n",
          ntohs (ev->mh->type));
     GNUNET_MQ_discard (ev);
   }
   if (NULL != mq->current_envelope)
   {
     /* we can only discard envelopes that
      * are not queued! */
     mq->current_envelope->parent_queue = NULL;
     LOG (GNUNET_ERROR_TYPE_DEBUG,
          "MQ destroy drops current message of type %u\n",
          ntohs (mq->current_envelope->mh->type));
     GNUNET_MQ_discard (mq->current_envelope);
     mq->current_envelope = NULL;
     GNUNET_assert (0 < mq->queue_length);
     mq->queue_length--;
   }
   GNUNET_assert (0 == mq->queue_length);
   while (NULL != (dnh = mq->dnh_head))
   {
     dnh->cb (dnh->cb_cls);
     GNUNET_MQ_destroy_notify_cancel (dnh);
   }
   if (NULL != mq->assoc_map)
   {
     GNUNET_CONTAINER_multihashmap32_destroy (mq->assoc_map);
     mq->assoc_map = NULL;
   }
   GNUNET_free (mq->handlers);
   GNUNET_free (mq);
 }

Here is the call graph for this function:

◆ GNUNET_MQ_destroy_notify()

struct GNUNET_MQ_DestroyNotificationHandle* GNUNET_MQ_destroy_notify	(	struct GNUNET_MQ_Handle *	mq,
		GNUNET_SCHEDULER_TaskCallback	cb,
		void *	cb_cls
	)

Register function to be called whenever mq is being destroyed.

Parameters

mq	message queue to watch
cb	function to call on mq destruction
cb_cls	closure for cb

Returns: handle for GNUNET_MQ_destroy_notify_cancel().

Definition at line 893 of file mq.c.

 {
   struct GNUNET_MQ_DestroyNotificationHandle *dnh;
  
   dnh = GNUNET_new (struct GNUNET_MQ_DestroyNotificationHandle);
   dnh->mq = mq;
   dnh->cb = cb;
   dnh->cb_cls = cb_cls;
   GNUNET_CONTAINER_DLL_insert (mq->dnh_head,
                                mq->dnh_tail,
                                dnh);
   return dnh;
 }

References GNUNET_MQ_DestroyNotificationHandle::cb, GNUNET_MQ_DestroyNotificationHandle::cb_cls, GNUNET_MQ_Handle::dnh_head, GNUNET_MQ_Handle::dnh_tail, GNUNET_CONTAINER_DLL_insert, GNUNET_new, mq, and GNUNET_MQ_DestroyNotificationHandle::mq.

Referenced by GNUNET_notification_context_add().

Here is the caller graph for this function:

◆ GNUNET_MQ_destroy_notify_cancel()

void GNUNET_MQ_destroy_notify_cancel ( struct GNUNET_MQ_DestroyNotificationHandle * dnh )

Cancel registration from GNUNET_MQ_destroy_notify().

Parameters

dnh	handle for registration to cancel

Definition at line 911 of file mq.c.

 {
   struct GNUNET_MQ_Handle *mq = dnh->mq;
  
   GNUNET_CONTAINER_DLL_remove (mq->dnh_head,
                                mq->dnh_tail,
                                dnh);
   GNUNET_free (dnh);
 }

References GNUNET_MQ_Handle::dnh_head, GNUNET_MQ_Handle::dnh_tail, GNUNET_CONTAINER_DLL_remove, GNUNET_free, mq, and GNUNET_MQ_DestroyNotificationHandle::mq.

Referenced by GNUNET_MQ_destroy(), and GNUNET_notification_context_destroy().

Here is the caller graph for this function:

◆ GNUNET_MQ_inject_message()

void GNUNET_MQ_inject_message	(	struct GNUNET_MQ_Handle *	mq,
		const struct GNUNET_MessageHeader *	mh
	)

Call the message message handler that was registered for the type of the given message in the given message queue.

This function is intended to be used for the implementation of message queues.

Parameters

mq	message queue with the handlers
mh	message to dispatch

Definition at line 187 of file mq.c.

 {
   enum GNUNET_GenericReturnValue ret;
  
   ret = GNUNET_MQ_handle_message (mq->handlers,
                                   mh);
   if (GNUNET_SYSERR == ret)
   {
     GNUNET_break_op (0);
     GNUNET_MQ_inject_error (mq,
                             GNUNET_MQ_ERROR_MALFORMED);
     return;
   }
 }

Referenced by handle_decrypted(), handle_local_data(), handle_notify_inbound(), handle_recv(), and service_client_mst_cb().

Here is the caller graph for this function:

◆ GNUNET_MQ_inject_error()

void GNUNET_MQ_inject_error	(	struct GNUNET_MQ_Handle *	mq,
		enum GNUNET_MQ_Error	error
	)

Call the error handler of a message queue with the given error code.

If there is no error handler, log a warning.

This function is intended to be used for the implementation of message queues.

Parameters

mq	message queue
error	the error type

Definition at line 269 of file mq.c.

 {
   if (NULL == mq->error_handler)
   {
     LOG (GNUNET_ERROR_TYPE_WARNING,
          "Got error %d, but no handler installed\n",
          (int) error);
     return;
   }
   mq->error_handler (mq->error_handler_cls,
                      error);
 }

References GNUNET_MQ_Handle::error_handler, GNUNET_MQ_Handle::error_handler_cls, GNUNET_ERROR_TYPE_WARNING, LOG, and mq.

Referenced by do_send(), GNUNET_MQ_handle_message(), receive_ready(), and recv_message().

Here is the caller graph for this function:

◆ GNUNET_MQ_impl_send_continue()

void GNUNET_MQ_impl_send_continue ( struct GNUNET_MQ_Handle * mq )

Call the send implementation for the next queued message, if any.

Calls the send notification for the current message unless GNUNET_MQ_impl_send_in_flight was called for this envelope.

Only useful for implementing message queues, results in undefined behavior if not used carefully.

Parameters

mq	message queue to send the next message with

Definition at line 421 of file mq.c.

 {
   struct GNUNET_MQ_Envelope *current_envelope;
   GNUNET_SCHEDULER_TaskCallback cb;
  
   GNUNET_assert (0 < mq->queue_length);
   mq->queue_length--;
   mq->in_flight = false;
   current_envelope = mq->current_envelope;
   current_envelope->parent_queue = NULL;
   mq->current_envelope = NULL;
   GNUNET_assert (NULL == mq->send_task);
   mq->send_task = GNUNET_SCHEDULER_add_now (&impl_send_continue, mq);
   if (NULL != (cb = current_envelope->sent_cb))
   {
     current_envelope->sent_cb = NULL;
     cb (current_envelope->sent_cls);
   }
   GNUNET_free (current_envelope);
 }

References GNUNET_MQ_Handle::current_envelope, GNUNET_assert, GNUNET_free, GNUNET_SCHEDULER_add_now(), impl_send_continue(), GNUNET_MQ_Handle::in_flight, mq, GNUNET_MQ_Envelope::parent_queue, GNUNET_MQ_Handle::queue_length, GNUNET_MQ_Handle::send_task, GNUNET_MQ_Envelope::sent_cb, and GNUNET_MQ_Envelope::sent_cls.

Referenced by cadet_mq_send_impl(), cadet_mq_send_now(), core_mq_send_impl(), do_send(), handle_send_ok(), handle_send_ready(), mq_send_d(), mq_send_impl(), mq_send_kx(), notify_send_done(), notify_send_done_fin(), queue_write(), recv_message(), and select_write_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_MQ_impl_send_in_flight()

void GNUNET_MQ_impl_send_in_flight ( struct GNUNET_MQ_Handle * mq )

Call the send notification for the current message, but do not try to send the next message until #gnunet_mq_impl_send_continue is called.

Only useful for implementing message queues, results in undefined behavior if not used carefully.

Parameters

mq	message queue to send the next message with

Definition at line 444 of file mq.c.

 {
   struct GNUNET_MQ_Envelope *current_envelope;
   GNUNET_SCHEDULER_TaskCallback cb;
  
   mq->in_flight = true;
   /* call is only valid if we're actually currently sending
    * a message */
   current_envelope = mq->current_envelope;
   GNUNET_assert (NULL != current_envelope);
   /* can't call cancel from now on anymore */
   current_envelope->parent_queue = NULL;
   if (NULL != (cb = current_envelope->sent_cb))
   {
     current_envelope->sent_cb = NULL;
     cb (current_envelope->sent_cls);
   }
 }

References GNUNET_MQ_Handle::current_envelope, GNUNET_assert, GNUNET_MQ_Handle::in_flight, mq, GNUNET_MQ_Envelope::parent_queue, GNUNET_MQ_Envelope::sent_cb, and GNUNET_MQ_Envelope::sent_cls.

Referenced by do_send(), notify_send_done(), and recv_message().

Here is the caller graph for this function:

◆ GNUNET_MQ_impl_state()

void* GNUNET_MQ_impl_state ( struct GNUNET_MQ_Handle * mq )

Get the implementation state associated with the message queue.

While the GNUNET_MQ_Impl* callbacks receive the implementation state, continuations that are scheduled by the implementation function often only have one closure argument, with this function it is possible to get at the implementation state when only passing the struct GNUNET_MQ_Handle as closure.

Parameters

mq	message queue with the current message

Returns: message to send, never NULL

Definition at line 509 of file mq.c.

 {
   return mq->impl_state;
 }

References GNUNET_MQ_Handle::impl_state, and mq.

◆ GNUNET_MQ_impl_current()

const struct GNUNET_MessageHeader* GNUNET_MQ_impl_current ( struct GNUNET_MQ_Handle * mq )

Get the message that should currently be sent.

Fails if there is no current message. Only useful for implementing message queues, results in undefined behavior if not used carefully.

Parameters

mq	message queue with the current message

Returns: message to send, never NULL

Definition at line 500 of file mq.c.

 {
   GNUNET_assert (NULL != mq->current_envelope);
   GNUNET_assert (NULL != mq->current_envelope->mh);
   return mq->current_envelope->mh;
 }

References GNUNET_MQ_Handle::current_envelope, GNUNET_assert, GNUNET_MQ_Envelope::mh, and mq.

◆ GNUNET_MQ_preference_to_string()

const char* GNUNET_MQ_preference_to_string ( enum GNUNET_MQ_PreferenceKind type )

Convert an enum GNUNET_MQ_PreferenceType to a string.

Parameters

type	the preference type

Returns: a string or NULL if invalid

Deprecated:: will be replaced by enum GNUNET_MQ_PriorityPreference

Definition at line 1013 of file mq.c.

 {
   switch (type)
   {
   case GNUNET_MQ_PREFERENCE_NONE:
     return "NONE";
   case GNUNET_MQ_PREFERENCE_BANDWIDTH:
     return "BANDWIDTH";
   case GNUNET_MQ_PREFERENCE_LATENCY:
     return "LATENCY";
   case GNUNET_MQ_PREFERENCE_RELIABILITY:
     return "RELIABILITY";
   }
   return NULL;
 }

References GNUNET_MQ_PREFERENCE_BANDWIDTH, GNUNET_MQ_PREFERENCE_LATENCY, GNUNET_MQ_PREFERENCE_NONE, GNUNET_MQ_PREFERENCE_RELIABILITY, and type.

◆ GNUNET_notification_context_create()

struct GNUNET_NotificationContext* GNUNET_notification_context_create ( unsigned int queue_length )

Create a new notification context.

Parameters

queue_length maximum number of messages to keep in the notification queue; optional messages are dropped if the queue gets longer than this number of messages

Returns: handle to the notification context

Definition at line 122 of file nc.c.

 {
   struct GNUNET_NotificationContext *nc;
  
   nc = GNUNET_new (struct GNUNET_NotificationContext);
   nc->queue_length = queue_length;
   return nc;
 }

References GNUNET_new, nc, and GNUNET_NotificationContext::queue_length.

Referenced by GAS_performance_init(), GSC_KX_init(), and run().

Here is the caller graph for this function:

◆ GNUNET_notification_context_destroy()

void GNUNET_notification_context_destroy ( struct GNUNET_NotificationContext * nc )

Destroy the context, force disconnect for all subscribers.

Parameters

nc	context to destroy.

Definition at line 138 of file nc.c.

 {
   struct SubscriberList *pos;
  
   while (NULL != (pos = nc->subscribers_head))
   {
     GNUNET_CONTAINER_DLL_remove (nc->subscribers_head,
                                  nc->subscribers_tail,
                                  pos);
     GNUNET_MQ_destroy_notify_cancel (pos->mq_nh);
     GNUNET_free (pos);
   }
   GNUNET_free (nc);
 }

References GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_MQ_destroy_notify_cancel(), SubscriberList::mq_nh, and nc.

Referenced by cleanup_task(), do_shutdown(), GAS_performance_done(), GSC_KX_done(), and shutdown_task().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_notification_context_add()

void GNUNET_notification_context_add	(	struct GNUNET_NotificationContext *	nc,
		struct GNUNET_MQ_Handle *	mq
	)

Add a subscriber to the notification context.

Parameters

nc	context to modify
mq	message queue add

Definition at line 161 of file nc.c.

 {
   struct SubscriberList *cl;
  
   for (cl = nc->subscribers_head; NULL != cl; cl = cl->next)
     if (cl->mq == mq)
       return;
   /* already present */
   cl = GNUNET_new (struct SubscriberList);
   GNUNET_CONTAINER_DLL_insert (nc->subscribers_head,
                                nc->subscribers_tail,
                                cl);
   cl->nc = nc;
   cl->mq = mq;
   cl->mq_nh = GNUNET_MQ_destroy_notify (cl->mq,
                                         &handle_mq_destroy,
                                         cl);
 }

References GNUNET_CONTAINER_DLL_insert, GNUNET_MQ_destroy_notify(), GNUNET_new, handle_mq_destroy(), mq, SubscriberList::mq, SubscriberList::mq_nh, nc, SubscriberList::nc, and SubscriberList::next.

Referenced by client_connect_cb(), GAS_performance_add_client(), handle_client_monitor_plugins(), handle_monitor(), handle_monitor_start(), handle_notify(), handle_start(), and handle_start_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_notification_context_broadcast()

void GNUNET_notification_context_broadcast	(	struct GNUNET_NotificationContext *	nc,
		const struct GNUNET_MessageHeader *	msg,
		int	can_drop
	)

Send a message to all subscribers of this context.

Parameters

nc	context to modify
msg	message to send
can_drop	can this message be dropped due to queue length limitations

Definition at line 190 of file nc.c.

 {
   struct SubscriberList *pos;
   struct GNUNET_MQ_Envelope *env;
  
   for (pos = nc->subscribers_head; NULL != pos; pos = pos->next)
   {
     if ((GNUNET_YES == can_drop) &&
         (GNUNET_MQ_get_length (pos->mq) > nc->queue_length))
       continue;
     env = GNUNET_MQ_msg_copy (msg);
     GNUNET_MQ_send (pos->mq,
                     env);
   }
 }

References env, GNUNET_MQ_get_length(), GNUNET_MQ_msg_copy(), GNUNET_MQ_send(), GNUNET_YES, SubscriberList::mq, msg, nc, and SubscriberList::next.

Referenced by broadcast_status(), monitor_notify_all(), notify_all(), notify_client(), notify_listeners(), plugin_session_info_cb(), and update_network_size_estimate().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_notification_context_get_size()

unsigned int GNUNET_notification_context_get_size ( struct GNUNET_NotificationContext * nc )

Return active number of subscribers in this context.

Parameters

nc	context to query

Returns: number of current subscribers

Definition at line 216 of file nc.c.

 {
   unsigned int num;
   struct SubscriberList *pos;
  
   num = 0;
   for (pos = nc->subscribers_head; NULL != pos; pos = pos->next)
     num++;
   return num;
 }

References nc, and SubscriberList::next.

Referenced by plugin_session_info_cb().

Here is the caller graph for this function:

Data Structures

Macros

Typedefs

Enumerations

Functions

will return a <tt>struct

will return a <tt>struct GNUNET_MQ_MessageHandler</tt>

Detailed Description

Macro Definition Documentation

◆ GNUNET_MQ_msg_extra

◆ GNUNET_MQ_msg

◆ GNUNET_MQ_msg_header

◆ GNUNET_MQ_msg_header_extra

◆ GNUNET_MQ_msg_nested_mh

◆ GNUNET_MQ_extract_nested_mh

◆ GNUNET_MQ_handler_end

◆ GNUNET_MQ_hd_fixed_size

◆ GNUNET_MQ_hd_var_size

◆ GNUNET_MQ_check_zero_termination

◆ GNUNET_MQ_check_boxed_message

Typedef Documentation

◆ GNUNET_MQ_MessageCallback

◆ GNUNET_MQ_MessageValidationCallback

◆ GNUNET_MQ_SendImpl

◆ GNUNET_MQ_DestroyImpl

◆ GNUNET_MQ_CancelImpl

◆ GNUNET_MQ_ErrorHandler

Enumeration Type Documentation

◆ GNUNET_MQ_Error

◆ GNUNET_MQ_PriorityPreferences

◆ GNUNET_MQ_PreferenceKind

Function Documentation

◆ GNUNET_MQ_extract_nested_mh_()

◆ GNUNET_MQ_env_get_msg()

◆ GNUNET_MQ_env_next()

◆ GNUNET_MQ_msg_nested_mh_()

◆ GNUNET_MQ_dll_insert_head()

◆ GNUNET_MQ_dll_insert_tail()

◆ GNUNET_MQ_dll_remove()

◆ GNUNET_MQ_copy_handlers()

◆ GNUNET_MQ_copy_handlers2()

◆ GNUNET_MQ_count_handlers()

◆ GNUNET_MQ_handle_message()

◆ GNUNET_MQ_msg_()

◆ GNUNET_MQ_msg_copy()

◆ GNUNET_MQ_discard()

◆ GNUNET_MQ_get_current_envelope()

◆ GNUNET_MQ_env_copy()

◆ GNUNET_MQ_get_last_envelope()

◆ GNUNET_MQ_env_set_options()

◆ GNUNET_MQ_env_get_options()

◆ GNUNET_MQ_env_combine_options()

◆ GNUNET_MQ_unsent_head()

◆ GNUNET_MQ_set_options()

◆ GNUNET_MQ_get_length()

◆ GNUNET_MQ_send()

◆ GNUNET_MQ_send_copy()

◆ GNUNET_MQ_send_cancel()

◆ GNUNET_MQ_assoc_add()

◆ GNUNET_MQ_assoc_get()

◆ GNUNET_MQ_assoc_remove()

◆ GNUNET_MQ_queue_for_callbacks()

◆ GNUNET_MQ_set_handlers_closure()

◆ GNUNET_MQ_notify_sent()

◆ GNUNET_MQ_destroy()

◆ GNUNET_MQ_destroy_notify()

◆ GNUNET_MQ_destroy_notify_cancel()

◆ GNUNET_MQ_inject_message()

◆ GNUNET_MQ_inject_error()

◆ GNUNET_MQ_impl_send_continue()

◆ GNUNET_MQ_impl_send_in_flight()

◆ GNUNET_MQ_impl_state()

◆ GNUNET_MQ_impl_current()

◆ GNUNET_MQ_preference_to_string()

◆ GNUNET_notification_context_create()

◆ GNUNET_notification_context_destroy()

◆ GNUNET_notification_context_add()

◆ GNUNET_notification_context_broadcast()

◆ GNUNET_notification_context_get_size()