implementation of the gnunet_transport_communication_service.h API More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_protocols.h"
#include "gnunet_transport_communication_service.h"
#include "gnunet_ats_transport_service.h"
#include "transport.h"

Include dependency graph for transport_api2_communication.c:

Data Structures
struct	FlowControl
	Information we track per packet to enable flow control. More...

struct	AckPending
	Information we track per message to tell the transport about success or failures. More...

struct	GNUNET_TRANSPORT_CommunicatorHandle
	Opaque handle to the transport service for communicators. More...

struct	GNUNET_TRANSPORT_QueueHandle
	Handle returned to identify the internal data structure the transport API has created to manage a message queue to a particular peer. More...

struct	GNUNET_TRANSPORT_AddressIdentifier
	Internal representation of an address a communicator is currently providing for the transport service. More...

Macros
#define	DEFAULT_MAX_QUEUE_LENGTH 16
	How many messages do we keep at most in the queue to the transport service before we start to drop (default, can be changed via the configuration file). More...

Functions
static void	reconnect (struct GNUNET_TRANSPORT_CommunicatorHandle *ch)
	(re)connect our communicator to the transport service More...

static void	send_add_address (struct GNUNET_TRANSPORT_AddressIdentifier *ai)
	Send message to the transport service about address ai being now available. More...

static void	send_del_address (struct GNUNET_TRANSPORT_AddressIdentifier *ai)
	Send message to the transport service about address ai being no longer available. More...

static void	send_add_queue (struct GNUNET_TRANSPORT_QueueHandle *qh)
	Send message to the transport service about queue qh being now available. More...

static void	send_update_queue (struct GNUNET_TRANSPORT_QueueHandle *qh)
	Send message to the transport service about queue qh updated. More...

static void	send_del_queue (struct GNUNET_TRANSPORT_QueueHandle *qh)
	Send message to the transport service about queue qh being no longer available. More...

static void	disconnect (struct GNUNET_TRANSPORT_CommunicatorHandle *ch)
	Disconnect from the transport service. More...

static void	error_handler (void *cls, enum GNUNET_MQ_Error error)
	Function called on MQ errors. More...

static void	handle_incoming_ack (void cls, const struct GNUNET_TRANSPORT_IncomingMessageAck incoming_ack)
	Transport service acknowledged a message we gave it (with flow control enabled). More...

static int	check_create_queue (void cls, const struct GNUNET_TRANSPORT_CreateQueue cq)
	Transport service wants us to create a queue. More...

static void	handle_create_queue (void cls, const struct GNUNET_TRANSPORT_CreateQueue cq)
	Transport service wants us to create a queue. More...

static int	check_send_msg (void cls, const struct GNUNET_TRANSPORT_SendMessageTo smt)
	Transport service wants us to send a message. More...

static void	send_ack (struct GNUNET_TRANSPORT_CommunicatorHandle ch, int status, const struct GNUNET_PeerIdentity receiver, uint64_t mid, uint32_t qid)
	Notify transport service about status of a message with mid sent to receiver. More...

static void	send_ack_cb (void *cls)
	Message queue transmission by communicator was successful, notify transport service. More...

static void	handle_send_msg (void cls, const struct GNUNET_TRANSPORT_SendMessageTo smt)
	Transport service wants us to send a message. More...

static int	check_backchannel_incoming (void cls, const struct GNUNET_TRANSPORT_CommunicatorBackchannelIncoming bi)
	Transport service gives us backchannel message. More...

static void	handle_backchannel_incoming (void cls, const struct GNUNET_TRANSPORT_CommunicatorBackchannelIncoming bi)
	Transport service gives us backchannel message. More...

struct GNUNET_TRANSPORT_CommunicatorHandle *	GNUNET_TRANSPORT_communicator_connect (const struct GNUNET_CONFIGURATION_Handle cfg, const char config_section, const char addr_prefix, enum GNUNET_TRANSPORT_CommunicatorCharacteristics cc, GNUNET_TRANSPORT_CommunicatorMqInit mq_init, void mq_init_cls, GNUNET_TRANSPORT_CommunicatorNotify notify_cb, void *notify_cb_cls)
	Connect to the transport service. More...

void	GNUNET_TRANSPORT_communicator_disconnect (struct GNUNET_TRANSPORT_CommunicatorHandle *ch)
	Disconnect from the transport service. More...

int	GNUNET_TRANSPORT_communicator_receive (struct GNUNET_TRANSPORT_CommunicatorHandle ch, const struct GNUNET_PeerIdentity sender, const struct GNUNET_MessageHeader msg, struct GNUNET_TIME_Relative expected_addr_validity, GNUNET_TRANSPORT_MessageCompletedCallback cb, void cb_cls)
	Notify transport service that the communicator has received a message. More...

struct GNUNET_TRANSPORT_QueueHandle *	GNUNET_TRANSPORT_communicator_mq_add (struct GNUNET_TRANSPORT_CommunicatorHandle ch, const struct GNUNET_PeerIdentity peer, const char address, uint32_t mtu, uint64_t q_len, uint32_t priority, enum GNUNET_NetworkType nt, enum GNUNET_TRANSPORT_ConnectionStatus cs, struct GNUNET_MQ_Handle mq)
	Notify transport service that a MQ became available due to an "inbound" connection or because the communicator discovered the presence of another peer. More...

void	GNUNET_TRANSPORT_communicator_mq_update (struct GNUNET_TRANSPORT_CommunicatorHandle ch, const struct GNUNET_TRANSPORT_QueueHandle u_qh, uint64_t q_len, uint32_t priority)
	Notify transport service that an MQ was updated. More...

void	GNUNET_TRANSPORT_communicator_mq_del (struct GNUNET_TRANSPORT_QueueHandle *qh)
	Notify transport service that an MQ became unavailable due to a disconnect or timeout. More...

struct GNUNET_TRANSPORT_AddressIdentifier *	GNUNET_TRANSPORT_communicator_address_add (struct GNUNET_TRANSPORT_CommunicatorHandle ch, const char address, enum GNUNET_NetworkType nt, struct GNUNET_TIME_Relative expiration)
	Notify transport service about an address that this communicator provides for this peer. More...

void	GNUNET_TRANSPORT_communicator_address_remove (struct GNUNET_TRANSPORT_AddressIdentifier *ai)
	Notify transport service about an address that this communicator no longer provides for this peer. More...

void	GNUNET_TRANSPORT_communicator_address_remove_all (struct GNUNET_TRANSPORT_CommunicatorHandle *ch)
	Notify transport service that this communicator no longer provides all its addresses for this peer. More...

void	GNUNET_TRANSPORT_communicator_notify (struct GNUNET_TRANSPORT_CommunicatorHandle ch, const struct GNUNET_PeerIdentity pid, const char comm, const struct GNUNET_MessageHeader header)
	The communicator asks the transport service to route a message via a different path to another communicator service at another peer. More...

Detailed Description

implementation of the gnunet_transport_communication_service.h API

Author: Christian Grothoff

Definition in file transport_api2_communication.c.

Macro Definition Documentation

◆ DEFAULT_MAX_QUEUE_LENGTH

#define DEFAULT_MAX_QUEUE_LENGTH 16

How many messages do we keep at most in the queue to the transport service before we start to drop (default, can be changed via the configuration file).

Definition at line 39 of file transport_api2_communication.c.

Function Documentation

◆ reconnect()

static void reconnect ( struct GNUNET_TRANSPORT_CommunicatorHandle * ch )

static

(re)connect our communicator to the transport service

Parameters

ch	handle to reconnect

Definition at line 772 of file transport_api2_communication.c.

 {
   struct GNUNET_MQ_MessageHandler handlers[] =
   { GNUNET_MQ_hd_fixed_size (incoming_ack,
                              GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG_ACK,
                              struct GNUNET_TRANSPORT_IncomingMessageAck,
                              ch),
     GNUNET_MQ_hd_var_size (create_queue,
                            GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE,
                            struct GNUNET_TRANSPORT_CreateQueue,
                            ch),
     GNUNET_MQ_hd_var_size (send_msg,
                            GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG,
                            struct GNUNET_TRANSPORT_SendMessageTo,
                            ch),
     GNUNET_MQ_hd_var_size (
       backchannel_incoming,
       GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL_INCOMING,
       struct GNUNET_TRANSPORT_CommunicatorBackchannelIncoming,
       ch),
     GNUNET_MQ_handler_end () };
   struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *cam;
   struct GNUNET_MQ_Envelope *env;
  
   ch->mq =
     GNUNET_CLIENT_connect (ch->cfg, "transport", handlers, &error_handler, ch);
   if (NULL == ch->mq)
     return;
   env = GNUNET_MQ_msg_extra (cam,
                              strlen (ch->addr_prefix) + 1,
                              GNUNET_MESSAGE_TYPE_TRANSPORT_NEW_COMMUNICATOR);
   cam->cc = htonl ((uint32_t) ch->cc);
   memcpy (&cam[1], ch->addr_prefix, strlen (ch->addr_prefix) + 1);
   GNUNET_MQ_send (ch->mq, env);
   for (struct GNUNET_TRANSPORT_AddressIdentifier *ai = ch->ai_head; NULL != ai;
        ai = ai->next)
     send_add_address (ai);
   for (struct GNUNET_TRANSPORT_QueueHandle *qh = ch->queue_head; NULL != qh;
        qh = qh->next)
     send_add_queue (qh);
 }

References ai, ch, env, error_handler(), GNUNET_CLIENT_connect(), GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL_INCOMING, GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG_ACK, GNUNET_MESSAGE_TYPE_TRANSPORT_NEW_COMMUNICATOR, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE, GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG, GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_hd_var_size, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), handlers, GNUNET_CADET_Channel::mq, GNUNET_TRANSPORT_AddressIdentifier::next, send_add_address(), send_add_queue(), and send_msg().

Referenced by error_handler(), GNUNET_TRANSPORT_communicator_connect(), and handle_incoming_ack().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_add_address()

static void send_add_address ( struct GNUNET_TRANSPORT_AddressIdentifier * ai )

static

Send message to the transport service about address ai being now available.

Parameters

ai	address to add

Definition at line 361 of file transport_api2_communication.c.

 {
   struct GNUNET_MQ_Envelope *env;
   struct GNUNET_TRANSPORT_AddAddressMessage *aam;
  
   if (NULL == ai->ch->mq)
     return;
   env = GNUNET_MQ_msg_extra (aam,
                              strlen (ai->address) + 1,
                              GNUNET_MESSAGE_TYPE_TRANSPORT_ADD_ADDRESS);
   aam->expiration = GNUNET_TIME_relative_hton (ai->expiration);
   aam->nt = htonl ((uint32_t) ai->nt);
   memcpy (&aam[1], ai->address, strlen (ai->address) + 1);
   GNUNET_MQ_send (ai->ch->mq, env);
 }

References GNUNET_TRANSPORT_AddressIdentifier::address, ai, GNUNET_TRANSPORT_AddressIdentifier::ch, env, GNUNET_TRANSPORT_AddressIdentifier::expiration, GNUNET_MESSAGE_TYPE_TRANSPORT_ADD_ADDRESS, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_TIME_relative_hton(), GNUNET_TRANSPORT_CommunicatorHandle::mq, and GNUNET_TRANSPORT_AddressIdentifier::nt.

Referenced by GNUNET_TRANSPORT_communicator_address_add(), and reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_del_address()

static void send_del_address ( struct GNUNET_TRANSPORT_AddressIdentifier * ai )

static

Send message to the transport service about address ai being no longer available.

Parameters

ai	address to delete

Definition at line 385 of file transport_api2_communication.c.

 {
   struct GNUNET_MQ_Envelope *env;
   struct GNUNET_TRANSPORT_DelAddressMessage *dam;
  
   if (NULL == ai->ch->mq)
     return;
   env = GNUNET_MQ_msg (dam, GNUNET_MESSAGE_TYPE_TRANSPORT_DEL_ADDRESS);
   dam->aid = htonl (ai->aid);
   GNUNET_MQ_send (ai->ch->mq, env);
 }

References ai, GNUNET_TRANSPORT_AddressIdentifier::aid, GNUNET_TRANSPORT_AddressIdentifier::ch, env, GNUNET_MESSAGE_TYPE_TRANSPORT_DEL_ADDRESS, GNUNET_MQ_msg, GNUNET_MQ_send(), and GNUNET_TRANSPORT_CommunicatorHandle::mq.

Referenced by GNUNET_TRANSPORT_communicator_address_remove().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_add_queue()

static void send_add_queue ( struct GNUNET_TRANSPORT_QueueHandle * qh )

static

Send message to the transport service about queue qh being now available.

Parameters

qh	queue to add

Definition at line 405 of file transport_api2_communication.c.

 {
   struct GNUNET_MQ_Envelope *env;
   struct GNUNET_TRANSPORT_AddQueueMessage *aqm;
  
   if (NULL == qh->ch->mq)
     return;
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Sending `GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_SETUP` message\n");
   env = GNUNET_MQ_msg_extra (aqm,
                              strlen (qh->address) + 1,
                              GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_SETUP);
   aqm->qid = htonl (qh->queue_id);
   aqm->receiver = qh->peer;
   aqm->nt = htonl ((uint32_t) qh->nt);
   aqm->mtu = htonl (qh->mtu);
   aqm->q_len = GNUNET_htonll (qh->q_len);
   aqm->priority = htonl (qh->priority);
   aqm->cs = htonl ((uint32_t) qh->cs);
   memcpy (&aqm[1], qh->address, strlen (qh->address) + 1);
   GNUNET_MQ_send (qh->ch->mq, env);
 }

Referenced by GNUNET_TRANSPORT_communicator_mq_add(), and reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_update_queue()

static void send_update_queue ( struct GNUNET_TRANSPORT_QueueHandle * qh )

static

Send message to the transport service about queue qh updated.

Parameters

qh	queue to add

Definition at line 436 of file transport_api2_communication.c.

 {
   struct GNUNET_MQ_Envelope *env;
   struct GNUNET_TRANSPORT_UpdateQueueMessage *uqm;
  
   if (NULL == qh->ch->mq)
     return;
   env = GNUNET_MQ_msg (uqm, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_UPDATE);
   uqm->qid = htonl (qh->queue_id);
   uqm->receiver = qh->peer;
   uqm->nt = htonl ((uint32_t) qh->nt);
   uqm->mtu = htonl (qh->mtu);
   uqm->q_len = GNUNET_htonll (qh->q_len);
   uqm->priority = htonl (qh->priority);
   uqm->cs = htonl ((uint32_t) qh->cs);
   GNUNET_MQ_send (qh->ch->mq, env);
 }

References GNUNET_TRANSPORT_QueueHandle::ch, GNUNET_TRANSPORT_QueueHandle::cs, env, GNUNET_htonll(), GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_UPDATE, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_TRANSPORT_CommunicatorHandle::mq, GNUNET_TRANSPORT_QueueHandle::mtu, GNUNET_TRANSPORT_QueueHandle::nt, GNUNET_TRANSPORT_QueueHandle::peer, GNUNET_TRANSPORT_QueueHandle::priority, GNUNET_TRANSPORT_QueueHandle::q_len, and GNUNET_TRANSPORT_QueueHandle::queue_id.

Referenced by GNUNET_TRANSPORT_communicator_mq_update().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_del_queue()

static void send_del_queue ( struct GNUNET_TRANSPORT_QueueHandle * qh )

static

Send message to the transport service about queue qh being no longer available.

Parameters

qh	queue to delete

Definition at line 462 of file transport_api2_communication.c.

 {
   struct GNUNET_MQ_Envelope *env;
   struct GNUNET_TRANSPORT_DelQueueMessage *dqm;
  
   if (NULL == qh->ch->mq)
     return;
   env = GNUNET_MQ_msg (dqm, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_TEARDOWN);
   dqm->qid = htonl (qh->queue_id);
   dqm->receiver = qh->peer;
   GNUNET_MQ_send (qh->ch->mq, env);
 }

References GNUNET_TRANSPORT_QueueHandle::ch, env, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_TEARDOWN, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_TRANSPORT_CommunicatorHandle::mq, GNUNET_TRANSPORT_QueueHandle::peer, and GNUNET_TRANSPORT_QueueHandle::queue_id.

Referenced by GNUNET_TRANSPORT_communicator_mq_del().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ disconnect()

static void disconnect ( struct GNUNET_TRANSPORT_CommunicatorHandle * ch )

static

Disconnect from the transport service.

Purges all flow control entries as we will no longer receive the ACKs. Purges the ack pending entries as the transport will no longer expect the confirmations.

Parameters

ch	service to disconnect from

Definition at line 485 of file transport_api2_communication.c.

 {
   struct FlowControl *fcn;
   struct AckPending *apn;
  
   for (struct FlowControl *fc = ch->fc_head; NULL != fc; fc = fcn)
   {
     fcn = fc->next;
     GNUNET_CONTAINER_DLL_remove (ch->fc_head, ch->fc_tail, fc);
     fc->cb (fc->cb_cls, GNUNET_SYSERR);
     GNUNET_free (fc);
   }
   for (struct AckPending *ap = ch->ap_head; NULL != ap; ap = apn)
   {
     apn = ap->next;
     GNUNET_CONTAINER_DLL_remove (ch->ap_head, ch->ap_tail, ap);
     GNUNET_free (ap);
   }
   if (NULL == ch->mq)
     return;
   GNUNET_MQ_destroy (ch->mq);
   ch->mq = NULL;
 }

References ch, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_MQ_destroy(), GNUNET_SYSERR, GNUNET_CADET_Channel::mq, FlowControl::next, and AckPending::next.

Referenced by error_handler(), GNUNET_TRANSPORT_communicator_disconnect(), and handle_incoming_ack().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ error_handler()

static void error_handler	(	void *	cls,
		enum GNUNET_MQ_Error	error
	)

static

Function called on MQ errors.

Definition at line 514 of file transport_api2_communication.c.

 {
   struct GNUNET_TRANSPORT_CommunicatorHandle *ch = cls;
  
   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
               "MQ failure %d, reconnecting to transport service.\n",
               error);
   disconnect (ch);
   /* TODO: maybe do this with exponential backoff/delay */
   reconnect (ch);
 }

References ch, disconnect(), GNUNET_ERROR_TYPE_INFO, GNUNET_log, and reconnect().

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ handle_incoming_ack()

static void handle_incoming_ack	(	void *	cls,
		const struct GNUNET_TRANSPORT_IncomingMessageAck *	incoming_ack
	)

static

Transport service acknowledged a message we gave it (with flow control enabled).

Tell the communicator.

Parameters

cls	our `struct GNUNET_TRANSPORT_CommunicatorHandle *`
incoming_ack	the ack

Definition at line 535 of file transport_api2_communication.c.

 {
   struct GNUNET_TRANSPORT_CommunicatorHandle *ch = cls;
  
   for (struct FlowControl *fc = ch->fc_head; NULL != fc; fc = fc->next)
   {
     if ((fc->id == incoming_ack->fc_id) &&
         (0 == memcmp (&fc->sender,
                       &incoming_ack->sender,
                       sizeof(struct GNUNET_PeerIdentity))))
     {
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                   "Done with message with flow control id %" PRIu64
                   " for sender %s from sender %s\n",
                   incoming_ack->fc_id,
                   GNUNET_i2s (&fc->sender),
                   GNUNET_i2s (&incoming_ack->sender));
       GNUNET_CONTAINER_DLL_remove (ch->fc_head, ch->fc_tail, fc);
       fc->cb (fc->cb_cls, GNUNET_OK);
       GNUNET_free (fc);
       return;
     }
   }
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Message with flow control id %" PRIu64
               " from sender %s not found\n",
               incoming_ack->fc_id,
               GNUNET_i2s (&incoming_ack->sender));
   GNUNET_break (0);
   disconnect (ch);
   /* TODO: maybe do this with exponential backoff/delay */
   reconnect (ch);
 }

References ch, disconnect(), GNUNET_break, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_i2s(), GNUNET_log, GNUNET_OK, and reconnect().

Here is the call graph for this function:

◆ check_create_queue()

static int check_create_queue	(	void *	cls,
		const struct GNUNET_TRANSPORT_CreateQueue *	cq
	)

static

Transport service wants us to create a queue.

Check if cq is well-formed.

Parameters

cls	our `struct GNUNET_TRANSPORT_CommunicatorHandle *`
cq	the queue creation request

Returns: GNUNET_OK if smt is well-formed

Definition at line 581 of file transport_api2_communication.c.

 {
   (void) cls;
   GNUNET_MQ_check_zero_termination (cq);
   return GNUNET_OK;
 }

References GNUNET_MQ_check_zero_termination, and GNUNET_OK.

◆ handle_create_queue()

static void handle_create_queue	(	void *	cls,
		const struct GNUNET_TRANSPORT_CreateQueue *	cq
	)

static

Transport service wants us to create a queue.

Tell the communicator.

Parameters

cls	our `struct GNUNET_TRANSPORT_CommunicatorHandle *`
cq	the queue creation request

Definition at line 596 of file transport_api2_communication.c.

 {
   struct GNUNET_TRANSPORT_CommunicatorHandle *ch = cls;
   const char *addr = (const char *) &cq[1];
   struct GNUNET_TRANSPORT_CreateQueueResponse *cqr;
   struct GNUNET_MQ_Envelope *env;
  
   if (GNUNET_OK != ch->mq_init (ch->mq_init_cls, &cq->receiver, addr))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Address `%s' invalid for this communicator\n",
                 addr);
     env = GNUNET_MQ_msg (cqr, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL);
   }
   else
   {
     env = GNUNET_MQ_msg (cqr, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_OK);
   }
   cqr->request_id = cq->request_id;
   GNUNET_MQ_send (ch->mq, env);
 }

References ch, env, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_OK, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_OK, and GNUNET_CADET_Channel::mq.

Here is the call graph for this function:

◆ check_send_msg()

static int check_send_msg	(	void *	cls,
		const struct GNUNET_TRANSPORT_SendMessageTo *	smt
	)

static

Transport service wants us to send a message.

Check if smt is well-formed.

Parameters

cls	our `struct GNUNET_TRANSPORT_CommunicatorHandle *`
smt	the transmission request

Returns: GNUNET_OK if smt is well-formed

Definition at line 628 of file transport_api2_communication.c.

 {
   (void) cls;
   GNUNET_MQ_check_boxed_message (smt);
   return GNUNET_OK;
 }

References GNUNET_MQ_check_boxed_message, and GNUNET_OK.

◆ send_ack()

static void send_ack	(	struct GNUNET_TRANSPORT_CommunicatorHandle *	ch,
		int	status,
		const struct GNUNET_PeerIdentity *	receiver,
		uint64_t	mid,
		uint32_t	qid
	)

static

Notify transport service about status of a message with mid sent to receiver.

Parameters

ch	handle
status	GNUNET_OK on success, GNUNET_SYSERR on failure
receiver	which peer was the receiver
mid	message that the ack is about

Definition at line 646 of file transport_api2_communication.c.

 {
   struct GNUNET_MQ_Envelope *env;
   struct GNUNET_TRANSPORT_SendMessageToAck *ack;
  
   env = GNUNET_MQ_msg (ack, GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG_ACK);
   ack->status = htonl (status);
   ack->mid = mid;
   ack->qid = qid;
   ack->receiver = *receiver;
   GNUNET_MQ_send (ch->mq, env);
 }

References ch, env, GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG_ACK, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_CADET_Channel::mq, receiver(), and status.

Referenced by handle_send_msg(), and send_ack_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_ack_cb()

static void send_ack_cb ( void * cls )

static

Message queue transmission by communicator was successful, notify transport service.

Parameters

cls	an `struct AckPending *`

Definition at line 671 of file transport_api2_communication.c.

 {
   struct AckPending *ap = cls;
   struct GNUNET_TRANSPORT_CommunicatorHandle *ch = ap->ch;
  
   GNUNET_CONTAINER_DLL_remove (ch->ap_head, ch->ap_tail, ap);
   send_ack (ch, GNUNET_OK, &ap->receiver, ap->mid, ap->qid);
   GNUNET_free (ap);
 }

References ch, AckPending::ch, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_OK, AckPending::mid, AckPending::qid, AckPending::receiver, and send_ack().

Referenced by handle_send_msg().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ handle_send_msg()

static void handle_send_msg	(	void *	cls,
		const struct GNUNET_TRANSPORT_SendMessageTo *	smt
	)

static

Transport service wants us to send a message.

Tell the communicator.

Parameters

cls	our `struct GNUNET_TRANSPORT_CommunicatorHandle *`
smt	the transmission request

Definition at line 689 of file transport_api2_communication.c.

 {
   struct GNUNET_TRANSPORT_CommunicatorHandle *ch = cls;
   const struct GNUNET_MessageHeader *mh;
   struct GNUNET_MQ_Envelope *env;
   struct AckPending *ap;
   struct GNUNET_TRANSPORT_QueueHandle *qh;
  
   for (qh = ch->queue_head; NULL != qh; qh = qh->next)
     if ((qh->queue_id == ntohl (smt->qid)) &&
         (0 == memcmp (&qh->peer,
                       &smt->receiver,
                       sizeof(struct GNUNET_PeerIdentity))))
       break;
   if (NULL == qh)
   {
     /* queue is already gone, tell transport this one failed */
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 "Transmission failed, queue no longer exists.\n");
     send_ack (ch, GNUNET_NO, &smt->receiver, smt->mid, smt->qid);
     return;
   }
   ap = GNUNET_new (struct AckPending);
   ap->ch = ch;
   ap->receiver = smt->receiver;
   ap->mid = smt->mid;
   ap->qid = smt->qid;
   GNUNET_CONTAINER_DLL_insert (ch->ap_head, ch->ap_tail, ap);
   mh = (const struct GNUNET_MessageHeader *) &smt[1];
   env = GNUNET_MQ_msg_copy (mh);
   GNUNET_MQ_notify_sent (env, &send_ack_cb, ap);
   GNUNET_MQ_send (qh->mq, env);
 }

References ch, AckPending::ch, env, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_MQ_msg_copy(), GNUNET_MQ_notify_sent(), GNUNET_MQ_send(), GNUNET_new, GNUNET_NO, mh, AckPending::mid, GNUNET_TRANSPORT_QueueHandle::mq, GNUNET_TRANSPORT_QueueHandle::next, GNUNET_TRANSPORT_QueueHandle::peer, AckPending::qid, GNUNET_TRANSPORT_QueueHandle::queue_id, AckPending::receiver, send_ack(), and send_ack_cb().

Here is the call graph for this function:

◆ check_backchannel_incoming()

static int check_backchannel_incoming	(	void *	cls,
		const struct GNUNET_TRANSPORT_CommunicatorBackchannelIncoming *	bi
	)

static

Transport service gives us backchannel message.

Check if bi is well-formed.

Parameters

cls	our `struct GNUNET_TRANSPORT_CommunicatorHandle *`
bi	the backchannel message

Returns: GNUNET_OK if smt is well-formed

Definition at line 733 of file transport_api2_communication.c.

 {
   (void) cls;
   GNUNET_MQ_check_boxed_message (bi);
   return GNUNET_OK;
 }

References GNUNET_MQ_check_boxed_message, and GNUNET_OK.

◆ handle_backchannel_incoming()

static void handle_backchannel_incoming	(	void *	cls,
		const struct GNUNET_TRANSPORT_CommunicatorBackchannelIncoming *	bi
	)

static

Transport service gives us backchannel message.

Handle it.

Parameters

cls	our `struct GNUNET_TRANSPORT_CommunicatorHandle *`
bi	the backchannel message

Definition at line 750 of file transport_api2_communication.c.

 {
   struct GNUNET_TRANSPORT_CommunicatorHandle *ch = cls;
   if (NULL != ch->notify_cb)
     ch->notify_cb (ch->notify_cb_cls,
                    &bi->pid,
                    (const struct GNUNET_MessageHeader *) &bi[1]);
   else
     GNUNET_log (
       GNUNET_ERROR_TYPE_INFO,
       _ ("Dropped backchanel message: handler not provided by communicator\n"));
 }

References _, ch, GNUNET_ERROR_TYPE_INFO, and GNUNET_log.

Data Structures

Macros

Functions

Detailed Description

Macro Definition Documentation

◆ DEFAULT_MAX_QUEUE_LENGTH

Function Documentation

◆ reconnect()

◆ send_add_address()

◆ send_del_address()

◆ send_add_queue()

◆ send_update_queue()

◆ send_del_queue()

◆ disconnect()

◆ error_handler()

◆ handle_incoming_ack()

◆ check_create_queue()

◆ handle_create_queue()

◆ check_send_msg()

◆ send_ack()

◆ send_ack_cb()

◆ handle_send_msg()

◆ check_backchannel_incoming()

◆ handle_backchannel_incoming()