transport-testing-communicator.c File Reference

functions related to testing-tng More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_protocols.h"
#include "gnunet_constants.h"
#include "transport-testing-communicator.h"
#include "gnunet_ats_transport_service.h"
#include "gnunet_hello_lib.h"
#include "gnunet_signatures.h"
#include "transport.h"
#include <inttypes.h>

Include dependency graph for transport-testing-communicator.c:

Go to the source code of this file.

Data Structures
struct	MyClient
struct	GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue
	Queue of a communicator and some context. More...
struct	GNUNET_TRANSPORT_TESTING_TransportCommunicatorTransmission
	Handle/Context to a single transmission. More...

Macros
#define	LOG(kind, ...)   GNUNET_log_from (kind, "transport-testing2", __VA_ARGS__)

Functions
static int	check_communicator_available (void *cls, const struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *msg)
	Check whether incoming msg indicating available communicator is correct. More...
static void	handle_communicator_available (void *cls, const struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *msg)
	Handle new communicator. More...
static int	check_communicator_backchannel (void *cls, const struct GNUNET_TRANSPORT_CommunicatorBackchannel *msg)
	Incoming message. More...
static void	handle_communicator_backchannel (void *cls, const struct GNUNET_TRANSPORT_CommunicatorBackchannel *bc_msg)
	Receive an incoming message. More...
static int	check_add_address (void *cls, const struct GNUNET_TRANSPORT_AddAddressMessage *msg)
	Address of our peer added. More...
static void	handle_add_address (void *cls, const struct GNUNET_TRANSPORT_AddAddressMessage *msg)
	The communicator informs about an address. More...
static int	check_incoming_msg (void *cls, const struct GNUNET_TRANSPORT_IncomingMessage *msg)
	Incoming message. More...
static void	handle_incoming_msg (void *cls, const struct GNUNET_TRANSPORT_IncomingMessage *inc_msg)
	Receive an incoming message. More...
static void	handle_queue_create_ok (void *cls, const struct GNUNET_TRANSPORT_CreateQueueResponse *msg)
	Communicator informs that it tries to establish requested queue. More...
static void	handle_queue_create_fail (void *cls, const struct GNUNET_TRANSPORT_CreateQueueResponse *msg)
	Communicator informs that it won't try establishing requested queue. More...
static int	check_add_queue_message (void *cls, const struct GNUNET_TRANSPORT_AddQueueMessage *aqm)
	New queue became available. More...
static void	handle_add_queue_message (void *cls, const struct GNUNET_TRANSPORT_AddQueueMessage *msg)
	Handle new queue. More...
static void	handle_update_queue_message (void *cls, const struct GNUNET_TRANSPORT_UpdateQueueMessage *msg)
	Handle new queue. More...
static void	shutdown_service (void *cls)
	Shut down the service. More...
static void *	connect_cb (void *cls, struct GNUNET_SERVICE_Client *client, struct GNUNET_MQ_Handle *mq)
	Callback called when new Client (Communicator) connects. More...
static void	disconnect_cb (void *cls, struct GNUNET_SERVICE_Client *client, void *internal_cls)
	Callback called when Client disconnects. More...
static void	handle_send_message_ack (void *cls, const struct GNUNET_TRANSPORT_SendMessageToAck *sma)
	Message was transmitted. More...
static void	transport_communicator_start (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
	Start the communicator part of the transport service. More...
static void	shutdown_process (struct GNUNET_OS_Process *proc)
	Task run at shutdown to kill communicator and clean up. More...
static void	shutdown_statistics (void *cls)
	Task run at shutdown to kill the statistics process. More...
static void	shutdown_peerstore (void *cls)
	Task run at shutdown to kill the peerstore process. More...
static void	shutdown_communicator (void *cls)
	Task run at shutdown to kill a communicator process. More...
static void	communicator_start (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *binary_name)
	Start the communicator. More...
static void	shutdown_nat (void *cls)
	Task run at shutdown to kill communicator and clean up. More...
static void	shutdown_resolver (void *cls)
	Task run at shutdown to kill the resolver process. More...
static void	resolver_start (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
	Start Resolver. More...
static void	statistics_start (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
	Start Statistics. More...
static void	peerstore_start (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
	Start Peerstore. More...
static void	nat_start (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
	Start NAT. More...
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *	GNUNET_TRANSPORT_TESTING_transport_communicator_service_start (const char *service_name, const char *binary_name, const char *cfg_filename, const struct GNUNET_PeerIdentity *peer_id, GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback communicator_available_cb, GNUNET_TRANSPORT_TESTING_AddAddressCallback add_address_cb, GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback queue_create_reply_cb, GNUNET_TRANSPORT_TESTING_AddQueueCallback add_queue_cb, GNUNET_TRANSPORT_TESTING_IncomingMessageCallback incoming_message_cb, GNUNET_TRANSPORT_TESTING_BackchannelCallback bc_cb, void *cb_cls)
	Start communicator part of transport service and communicator. More...
void	GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
void	GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const struct GNUNET_PeerIdentity *peer_id, const char *address)
	Instruct communicator to open a queue. More...
void	GNUNET_TRANSPORT_TESTING_transport_communicator_send (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, GNUNET_SCHEDULER_TaskCallback cont, void *cont_cls, const void *payload, size_t payload_size)
	Instruct communicator to send data. More...

Detailed Description

functions related to testing-tng

Author

Christian Grothoff

Julius Bünger

Definition in file transport-testing-communicator.c.

Macro Definition Documentation

LOG

#define LOG	(		kind,
			...
	)		GNUNET_log_from (kind, "transport-testing2", __VA_ARGS__)

Definition at line 38 of file transport-testing-communicator.c.

Function Documentation

check_communicator_available()

static int check_communicator_available ( void *  cls, const struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *  msg  )

static

Check whether incoming msg indicating available communicator is correct.

Parameters

cls	Closure
msg	Message struct

Returns

GNUNET_YES in case message is correct

Definition at line 150 of file transport-testing-communicator.c.

{
  uint16_t size;
 
  size = ntohs (msg->header.size) - sizeof(*msg);
  if (0 == size)
    return GNUNET_OK; /* receive-only communicator */
  GNUNET_MQ_check_zero_termination (msg);
  return GNUNET_OK;
}

References GNUNET_MQ_check_zero_termination, GNUNET_OK, msg, GNUNET_MessageHeader::size, and size.

handle_communicator_available()

static void handle_communicator_available ( void *  cls, const struct GNUNET_TRANSPORT_CommunicatorAvailableMessage *  msg  )

static

Handle new communicator.

Store characteristics of communicator, call respective client callback.

Parameters

cls	Closure - communicator handle
msg	Message struct

Definition at line 173 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
  uint16_t size;
  tc_h->c_mq = client->c_mq;
 
  size = ntohs (msg->header.size) - sizeof(*msg);
  if (0 == size)
  {
    GNUNET_SERVICE_client_continue (client->client);
    return; /* receive-only communicator */
  }
  tc_h->c_characteristics = ntohl (msg->cc);
  tc_h->c_addr_prefix = GNUNET_strdup ((const char *) &msg[1]);
  if (NULL != tc_h->communicator_available_cb)
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG, "calling communicator_available_cb()\n");
    tc_h->communicator_available_cb (tc_h->cb_cls,
                                     tc_h,
                                     tc_h->c_characteristics,
                                     tc_h->c_addr_prefix);
  }
  GNUNET_SERVICE_client_continue (client->client);
  LOG (GNUNET_ERROR_TYPE_DEBUG, "finished communicator_available_cb()\n");
 
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_addr_prefix, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_characteristics, MyClient::c_mq, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_mq, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cb_cls, MyClient::client, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::communicator_available_cb, GNUNET_ERROR_TYPE_DEBUG, GNUNET_SERVICE_client_continue(), GNUNET_strdup, LOG, msg, GNUNET_MessageHeader::size, size, and MyClient::tc.

Here is the call graph for this function:

check_communicator_backchannel()

static int check_communicator_backchannel ( void *  cls, const struct GNUNET_TRANSPORT_CommunicatorBackchannel *  msg  )

static

Incoming message.

Test message is well-formed.

Parameters

cls	the client
msg	the send message that was sent

Returns

GNUNET_OK if message is well-formed

Definition at line 213 of file transport-testing-communicator.c.

{
  // struct TransportClient *tc = cls;
 
  // if (CT_COMMUNICATOR != tc->type)
  // {
  //  GNUNET_break (0);
  //  return GNUNET_SYSERR;
  // }
  // GNUNET_MQ_check_boxed_message (msg);
  return GNUNET_OK;
}

References GNUNET_OK.

handle_communicator_backchannel()

static void handle_communicator_backchannel ( void *  cls, const struct GNUNET_TRANSPORT_CommunicatorBackchannel *  bc_msg  )

static

Receive an incoming message.

Pass the message to the client.

Parameters

cls	Closure - communicator handle
bc_msg	Message

Definition at line 238 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *other_tc_h;
  struct GNUNET_MessageHeader *msg;
  msg = (struct GNUNET_MessageHeader *) &bc_msg[1];
  uint16_t isize = ntohs (msg->size);
  const char *target_communicator = ((const char *) msg) + isize;
  struct GNUNET_TRANSPORT_CommunicatorBackchannelIncoming *cbi;
  struct GNUNET_MQ_Envelope *env;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Received backchannel message\n");
  if (tc_h->bc_enabled != GNUNET_YES)
  {
    GNUNET_SERVICE_client_continue (client->client);
    return;
  }
  /* Find client providing this communicator */
  /* Finally, deliver backchannel message to communicator */
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Delivering backchannel message of type %u to %s\n",
       ntohs (msg->type),
       target_communicator);
  other_tc_h = tc_h->bc_cb (tc_h, msg, (struct
                                        GNUNET_PeerIdentity*) &bc_msg->pid);
  env = GNUNET_MQ_msg_extra (
    cbi,
    isize,
    GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL_INCOMING);
  cbi->pid = tc_h->peer_id;
  memcpy (&cbi[1], msg, isize);
 
 
  GNUNET_MQ_send (other_tc_h->c_mq, env);
  GNUNET_SERVICE_client_continue (client->client);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::bc_cb, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::bc_enabled, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_mq, MyClient::client, env, GNUNET_ERROR_TYPE_DEBUG, GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL_INCOMING, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), GNUNET_YES, LOG, msg, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::peer_id, GNUNET_MessageHeader::size, MyClient::tc, and GNUNET_MessageHeader::type.

Here is the call graph for this function:

check_add_address()

static int check_add_address ( void *  cls, const struct GNUNET_TRANSPORT_AddAddressMessage *  msg  )

static

Address of our peer added.

Test message is well-formed.

Parameters

cls	the client
msg	the send message that was sent

Returns

GNUNET_OK if message is well-formed

Definition at line 290 of file transport-testing-communicator.c.

{
  // if (CT_COMMUNICATOR != tc->type)
  // {
  //  GNUNET_break (0);
  //  return GNUNET_SYSERR;
  // }
  GNUNET_MQ_check_zero_termination (msg);
  return GNUNET_OK;
}

References GNUNET_MQ_check_zero_termination, GNUNET_OK, and msg.

handle_add_address()

static void handle_add_address ( void *  cls, const struct GNUNET_TRANSPORT_AddAddressMessage *  msg  )

static

The communicator informs about an address.

Store address and call client callback.

Parameters

cls	Closure - communicator handle
msg	Message

Definition at line 312 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
  uint16_t size;
  size = ntohs (msg->header.size) - sizeof(*msg);
  LOG (GNUNET_ERROR_TYPE_DEBUG, "received add address cb %u\n", size);
  if (0 == size)
    return; /* receive-only communicator */
  LOG (GNUNET_ERROR_TYPE_DEBUG, "received add address cb %u\n", size);
  tc_h->c_address = GNUNET_strdup ((const char *) &msg[1]);
  if (NULL != tc_h->add_address_cb)
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG, "calling add_address_cb()\n");
    tc_h->add_address_cb (tc_h->cb_cls,
                          tc_h,
                          tc_h->c_address,
                          GNUNET_TIME_relative_ntoh (msg->expiration),
                          msg->aid,
                          ntohl (msg->nt));
  }
  GNUNET_SERVICE_client_continue (client->client);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::add_address_cb, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_address, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cb_cls, MyClient::client, GNUNET_ERROR_TYPE_DEBUG, GNUNET_SERVICE_client_continue(), GNUNET_strdup, GNUNET_TIME_relative_ntoh(), LOG, msg, GNUNET_MessageHeader::size, size, and MyClient::tc.

Here is the call graph for this function:

check_incoming_msg()

static int check_incoming_msg ( void *  cls, const struct GNUNET_TRANSPORT_IncomingMessage *  msg  )

static

Incoming message.

Test message is well-formed.

Parameters

cls	the client
msg	the send message that was sent

Returns

GNUNET_OK if message is well-formed

Definition at line 347 of file transport-testing-communicator.c.

{
  // struct TransportClient *tc = cls;
 
  // if (CT_COMMUNICATOR != tc->type)
  // {
  //  GNUNET_break (0);
  //  return GNUNET_SYSERR;
  // }
  GNUNET_MQ_check_boxed_message (msg);
  return GNUNET_OK;
}

References GNUNET_MQ_check_boxed_message, GNUNET_OK, and msg.

handle_incoming_msg()

static void handle_incoming_msg ( void *  cls, const struct GNUNET_TRANSPORT_IncomingMessage *  inc_msg  )

static

Receive an incoming message.

Pass the message to the client.

Parameters

cls	Closure - communicator handle
inc_msg	Message

Definition at line 371 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
  struct GNUNET_MessageHeader *msg;
  msg = (struct GNUNET_MessageHeader *) &inc_msg[1];
  size_t payload_len = ntohs (msg->size) - sizeof (struct
                                                   GNUNET_MessageHeader);
  if (NULL != tc_h->incoming_msg_cb)
  {
    tc_h->incoming_msg_cb (tc_h->cb_cls,
                           tc_h,
                           (char*) &msg[1],
                           payload_len);
  }
  else
  {
    LOG (GNUNET_ERROR_TYPE_WARNING,
         "Incoming message from communicator but no handler!\n");
  }
  if (GNUNET_YES == ntohl (inc_msg->fc_on))
  {
    /* send ACK when done to communicator for flow control! */
    struct GNUNET_MQ_Envelope *env;
    struct GNUNET_TRANSPORT_IncomingMessageAck *ack;
 
    env = GNUNET_MQ_msg (ack, GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG_ACK);
    GNUNET_assert (NULL != env);
    ack->reserved = htonl (0);
    ack->fc_id = inc_msg->fc_id;
    ack->sender = inc_msg->sender;
    GNUNET_MQ_send (tc_h->c_mq, env);
  }
 
  GNUNET_SERVICE_client_continue (client->client);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_mq, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cb_cls, MyClient::client, env, GNUNET_assert, GNUNET_ERROR_TYPE_WARNING, GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG_ACK, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), GNUNET_YES, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::incoming_msg_cb, LOG, msg, GNUNET_MessageHeader::size, and MyClient::tc.

Here is the call graph for this function:

handle_queue_create_ok()

static void handle_queue_create_ok ( void *  cls, const struct GNUNET_TRANSPORT_CreateQueueResponse *  msg  )

static

Communicator informs that it tries to establish requested queue.

Parameters

cls	Closure - communicator handle
msg	Message

Definition at line 418 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
 
  if (NULL != tc_h->queue_create_reply_cb)
  {
    tc_h->queue_create_reply_cb (tc_h->cb_cls, tc_h, GNUNET_YES);
  }
  GNUNET_SERVICE_client_continue (client->client);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cb_cls, MyClient::client, GNUNET_SERVICE_client_continue(), GNUNET_YES, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_create_reply_cb, and MyClient::tc.

Here is the call graph for this function:

handle_queue_create_fail()

static void handle_queue_create_fail ( void *  cls, const struct GNUNET_TRANSPORT_CreateQueueResponse *  msg  )

static

Communicator informs that it won't try establishing requested queue.

It will not do so probably because the address is bougus (see comment to GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL)

Parameters

cls	Closure - communicator handle
msg	Message

Definition at line 443 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
 
  if (NULL != tc_h->queue_create_reply_cb)
  {
    tc_h->queue_create_reply_cb (tc_h->cb_cls, tc_h, GNUNET_NO);
  }
  GNUNET_SERVICE_client_continue (client->client);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cb_cls, MyClient::client, GNUNET_NO, GNUNET_SERVICE_client_continue(), GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_create_reply_cb, and MyClient::tc.

Here is the call graph for this function:

check_add_queue_message()

static int check_add_queue_message ( void *  cls, const struct GNUNET_TRANSPORT_AddQueueMessage *  aqm  )

static

New queue became available.

Check message.

Parameters

cls	the client
aqm	the send message that was sent

Definition at line 466 of file transport-testing-communicator.c.

{
  GNUNET_MQ_check_zero_termination (aqm);
  return GNUNET_OK;
}

References GNUNET_MQ_check_zero_termination, and GNUNET_OK.

handle_add_queue_message()

static void handle_add_queue_message ( void *  cls, const struct GNUNET_TRANSPORT_AddQueueMessage *  msg  )

static

Handle new queue.

Store context and call client callback.

Parameters

cls	Closure - communicator handle
msg	Message struct

Definition at line 483 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Got queue with ID %u\n", msg->qid);
  for (tc_queue = tc_h->queue_head; NULL != tc_queue; tc_queue = tc_queue->next)
  {
    if (tc_queue->qid == msg->qid)
      break;
  }
  if (NULL == tc_queue)
  {
    tc_queue =
      GNUNET_new (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue);
    tc_queue->tc_h = tc_h;
    tc_queue->qid = msg->qid;
    tc_queue->peer_id = msg->receiver;
    GNUNET_CONTAINER_DLL_insert (tc_h->queue_head, tc_h->queue_tail, tc_queue);
  }
  GNUNET_assert (tc_queue->qid == msg->qid);
  GNUNET_assert (0 == GNUNET_memcmp (&tc_queue->peer_id, &msg->receiver));
  tc_queue->nt = msg->nt;
  tc_queue->mtu = ntohl (msg->mtu);
  tc_queue->cs = msg->cs;
  tc_queue->priority = ntohl (msg->priority);
  tc_queue->q_len = GNUNET_ntohll (msg->q_len);
  if (NULL != tc_h->add_queue_cb)
  {
    tc_h->add_queue_cb (tc_h->cb_cls, tc_h, tc_queue, tc_queue->mtu);
  }
  GNUNET_SERVICE_client_continue (client->client);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::add_queue_cb, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cb_cls, MyClient::client, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::cs, GNUNET_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_memcmp, GNUNET_new, GNUNET_ntohll(), GNUNET_SERVICE_client_continue(), LOG, msg, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::mtu, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::next, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::nt, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::peer_id, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::priority, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::q_len, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::qid, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_head, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_tail, MyClient::tc, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::tc_h.

Here is the call graph for this function:

handle_update_queue_message()

static void handle_update_queue_message ( void *  cls, const struct GNUNET_TRANSPORT_UpdateQueueMessage *  msg  )

static

Handle new queue.

Store context and call client callback.

Parameters

cls	Closure - communicator handle
msg	Message struct

Definition at line 531 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Received queue update message for %u with q_len %" PRIu64 "\n",
       msg->qid, GNUNET_ntohll (msg->q_len));
  tc_queue = tc_h->queue_head;
  if (NULL != tc_queue)
  {
    while (tc_queue->qid != msg->qid)
    {
      tc_queue = tc_queue->next;
    }
  }
  if (NULL == tc_queue)
  {
    GNUNET_SERVICE_client_continue (client->client);
    return;
  }
  GNUNET_assert (tc_queue->qid == msg->qid);
  GNUNET_assert (0 == GNUNET_memcmp (&tc_queue->peer_id, &msg->receiver));
  tc_queue->nt = msg->nt;
  tc_queue->mtu = ntohl (msg->mtu);
  tc_queue->cs = msg->cs;
  tc_queue->priority = ntohl (msg->priority);
  // Uncomment this for alternativ 1 of backchannel functionality
  tc_queue->q_len += GNUNET_ntohll (msg->q_len);
  // Until here for alternativ 1
  // Uncomment this for alternativ 2 of backchannel functionality
  // tc_queue->q_len = GNUNET_ntohll (msg->q_len);
  // Until here for alternativ 2
  GNUNET_SERVICE_client_continue (client->client);
}

References MyClient::client, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::cs, GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_memcmp, GNUNET_ntohll(), GNUNET_SERVICE_client_continue(), LOG, msg, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::mtu, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::next, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::nt, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::peer_id, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::priority, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::q_len, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::qid, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_head, MyClient::tc, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::tc_h.

Here is the call graph for this function:

shutdown_service()

static void shutdown_service ( void *  cls )

static

Shut down the service.

Parameters

cls	Closure - Handle to the service

Definition at line 578 of file transport-testing-communicator.c.

{
  struct GNUNET_SERVICE_Handle *h = cls;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Shutting down service!\n");
 
  GNUNET_SERVICE_stop (h);
}

References GNUNET_ERROR_TYPE_DEBUG, GNUNET_SERVICE_stop(), h, and LOG.

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

connect_cb()

static void* connect_cb ( void *  cls, struct GNUNET_SERVICE_Client *  client, struct GNUNET_MQ_Handle *  mq  )

static

Callback called when new Client (Communicator) connects.

Parameters

cls	Closure - TransporCommmunicator Handle
client	Client
mq	Messagequeue

Returns

TransportCommunicator Handle

Definition at line 599 of file transport-testing-communicator.c.

{
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h = cls;
  struct MyClient *new_c;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG, "Client %p connected to %p.\n",
       client, tc_h);
  new_c = GNUNET_new (struct MyClient);
  new_c->client = client;
  new_c->c_mq = mq;
  new_c->tc = tc_h;
  GNUNET_CONTAINER_DLL_insert (tc_h->client_head,
                               tc_h->client_tail,
                               new_c);
 
  if (NULL == tc_h->queue_head)
    return new_c;
  /* Iterate over queues. They are yet to be opened. Request opening. */
  for (struct
       GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue_iter =
         tc_h->queue_head;
       NULL != tc_queue_iter;
       tc_queue_iter = tc_queue_iter->next)
  {
    if (NULL == tc_queue_iter->open_queue_env)
      continue;
    /* Send the previously created mq envelope to request the creation of the
     * queue. */
    GNUNET_MQ_send (tc_h->c_mq,
                    tc_queue_iter->open_queue_env);
    tc_queue_iter->open_queue_env = NULL;
  }
  return new_c;
}

References MyClient::c_mq, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_mq, MyClient::client, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::client_head, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::client_tail, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_MQ_send(), GNUNET_new, LOG, mq, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::next, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_head, and MyClient::tc.

Referenced by transport_communicator_start().

Here is the call graph for this function:

Here is the caller graph for this function:

disconnect_cb()

static void disconnect_cb ( void *  cls, struct GNUNET_SERVICE_Client *  client, void *  internal_cls  )

static

Callback called when Client disconnects.

Parameters

cls	Closure - TransportCommunicator Handle
client	Client
internal_cls	TransporCommmunicator Handle

Definition at line 645 of file transport-testing-communicator.c.

{
  struct MyClient *cl = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h = cls;
 
  for (cl = tc_h->client_head; NULL != cl; cl = cl->next)
  {
    if (cl->client != client)
      continue;
    GNUNET_CONTAINER_DLL_remove (tc_h->client_head,
                                 tc_h->client_tail,
                                 cl);
    if (cl->c_mq == tc_h->c_mq)
      tc_h->c_mq = NULL;
    GNUNET_free (cl);
    break;
  }
  LOG (GNUNET_ERROR_TYPE_DEBUG, "Client disconnected.\n");
}

References MyClient::c_mq, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_mq, MyClient::client, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::client_head, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::client_tail, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, LOG, and MyClient::next.

Referenced by transport_communicator_start().

Here is the caller graph for this function:

handle_send_message_ack()

static void handle_send_message_ack ( void *  cls, const struct GNUNET_TRANSPORT_SendMessageToAck *  sma  )

static

Message was transmitted.

Process the request.

Parameters

cls	the client
sma	the send message that was sent

Definition at line 675 of file transport-testing-communicator.c.

{
  struct MyClient *client = cls;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h =
    client->tc;
  static int mtr = 0;
  mtr++;
  if (tc_h->cont != NULL)
    tc_h->cont (tc_h->cont_cls);
  GNUNET_SERVICE_client_continue (client->client);
}

References MyClient::client, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cont, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cont_cls, GNUNET_SERVICE_client_continue(), and MyClient::tc.

Here is the call graph for this function:

transport_communicator_start()

static void transport_communicator_start ( struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *  tc_h )

static

Start the communicator part of the transport service.

Parameters

communicator_available	Callback to be called when a new communicator becomes available
cfg	Configuration

Definition at line 697 of file transport-testing-communicator.c.

{
  struct GNUNET_MQ_MessageHandler mh[] = {
    GNUNET_MQ_hd_var_size (communicator_available,
                           GNUNET_MESSAGE_TYPE_TRANSPORT_NEW_COMMUNICATOR,
                           struct GNUNET_TRANSPORT_CommunicatorAvailableMessage,
                           tc_h),
    GNUNET_MQ_hd_var_size (communicator_backchannel,
                           GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL,
                           struct GNUNET_TRANSPORT_CommunicatorBackchannel,
                           tc_h),
    GNUNET_MQ_hd_var_size (add_address,
                           GNUNET_MESSAGE_TYPE_TRANSPORT_ADD_ADDRESS,
                           struct GNUNET_TRANSPORT_AddAddressMessage,
                           tc_h),
    // GNUNET_MQ_hd_fixed_size (del_address,
    //                         GNUNET_MESSAGE_TYPE_TRANSPORT_DEL_ADDRESS,
    //                         struct GNUNET_TRANSPORT_DelAddressMessage,
    //                         NULL),
    GNUNET_MQ_hd_var_size (incoming_msg,
                           GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG,
                           struct GNUNET_TRANSPORT_IncomingMessage,
                           tc_h),
    GNUNET_MQ_hd_fixed_size (queue_create_ok,
                             GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_OK,
                             struct GNUNET_TRANSPORT_CreateQueueResponse,
                             tc_h),
    GNUNET_MQ_hd_fixed_size (queue_create_fail,
                             GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL,
                             struct GNUNET_TRANSPORT_CreateQueueResponse,
                             tc_h),
    GNUNET_MQ_hd_var_size (add_queue_message,
                           GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_SETUP,
                           struct GNUNET_TRANSPORT_AddQueueMessage,
                           tc_h),
    GNUNET_MQ_hd_fixed_size (update_queue_message,
                             GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_UPDATE,
                             struct GNUNET_TRANSPORT_UpdateQueueMessage,
                             tc_h),
    // GNUNET_MQ_hd_fixed_size (del_queue_message,
    //                         GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_TEARDOWN,
    //                         struct GNUNET_TRANSPORT_DelQueueMessage,
    //                         NULL),
    GNUNET_MQ_hd_fixed_size (send_message_ack,
                             GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG_ACK,
                             struct GNUNET_TRANSPORT_SendMessageToAck,
                             tc_h),
    GNUNET_MQ_handler_end ()
  };
 
 
  tc_h->sh = GNUNET_SERVICE_start ("transport",
                                   tc_h->cfg,
                                   &connect_cb,
                                   &disconnect_cb,
                                   tc_h,
                                   mh);
  GNUNET_assert (NULL != tc_h->sh);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg, connect_cb(), disconnect_cb(), GNUNET_assert, GNUNET_MESSAGE_TYPE_TRANSPORT_ADD_ADDRESS, GNUNET_MESSAGE_TYPE_TRANSPORT_COMMUNICATOR_BACKCHANNEL, GNUNET_MESSAGE_TYPE_TRANSPORT_INCOMING_MSG, GNUNET_MESSAGE_TYPE_TRANSPORT_NEW_COMMUNICATOR, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_OK, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_SETUP, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_UPDATE, GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG_ACK, GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_hd_var_size, GNUNET_SERVICE_start(), mh, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::sh.

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_start().

Here is the call graph for this function:

Here is the caller graph for this function:

shutdown_process()

static void shutdown_process ( struct GNUNET_OS_Process *  proc )

static

Task run at shutdown to kill communicator and clean up.

Parameters

cls	Closure - Process of communicator

Definition at line 765 of file transport-testing-communicator.c.

{
  if (0 != GNUNET_OS_process_kill (proc, SIGTERM))
  {
    LOG (GNUNET_ERROR_TYPE_WARNING,
         "Error shutting down process with SIGERM, trying SIGKILL\n");
    if (0 != GNUNET_OS_process_kill (proc, SIGKILL))
    {
      LOG (GNUNET_ERROR_TYPE_ERROR,
           "Error shutting down process with SIGERM and SIGKILL\n");
    }
  }
  GNUNET_OS_process_destroy (proc);
}

References GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_WARNING, GNUNET_OS_process_destroy(), GNUNET_OS_process_kill(), and LOG.

Referenced by shutdown_communicator(), shutdown_nat(), shutdown_peerstore(), shutdown_resolver(), and shutdown_statistics().

Here is the call graph for this function:

Here is the caller graph for this function:

shutdown_statistics()

static void shutdown_statistics ( void *  cls )

static

Task run at shutdown to kill the statistics process.

Parameters

cls	Closure - Process of communicator

Definition at line 787 of file transport-testing-communicator.c.

{
  struct GNUNET_OS_Process *proc = cls;
  shutdown_process (proc);
}

References shutdown_process().

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

shutdown_peerstore()

static void shutdown_peerstore ( void *  cls )

static

Task run at shutdown to kill the peerstore process.

Parameters

cls	Closure - Process of communicator

Definition at line 800 of file transport-testing-communicator.c.

{
  struct GNUNET_OS_Process *proc = cls;
  shutdown_process (proc);
}

References shutdown_process().

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

shutdown_communicator()

static void shutdown_communicator ( void *  cls )

static

Task run at shutdown to kill a communicator process.

Parameters

cls	Closure - Process of communicator

Definition at line 813 of file transport-testing-communicator.c.

{
  struct GNUNET_OS_Process *proc = cls;
  shutdown_process (proc);
}

References shutdown_process().

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

communicator_start()

static void communicator_start ( struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *  tc_h, const char *  binary_name  )

static

Start the communicator.

Parameters

cfgname

Name of the communicator

Definition at line 826 of file transport-testing-communicator.c.

{
  char *binary;
  char *loprefix;
  char *section_name;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG, "communicator_start\n");
 
  section_name = strchr (binary_name, '-');
  section_name++;
 
  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_string (tc_h->cfg,
                                                          section_name,
                                                          "PREFIX",
                                                          &loprefix))
    loprefix = GNUNET_strdup ("");
 
 
  binary = GNUNET_OS_get_libexec_binary_path (binary_name);
  tc_h->c_proc = GNUNET_OS_start_process_s (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                            NULL,
                                            loprefix,
                                            binary,
                                            binary_name,
                                            "-c",
                                            tc_h->cfg_filename,
                                            NULL);
  if (NULL == tc_h->c_proc)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start communicator!");
    return;
  }
  LOG (GNUNET_ERROR_TYPE_INFO, "started communicator\n");
  GNUNET_free (binary);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_proc, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg_filename, GNUNET_CONFIGURATION_get_value_string(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OK, GNUNET_OS_get_libexec_binary_path(), GNUNET_OS_INHERIT_STD_OUT_AND_ERR, GNUNET_OS_start_process_s(), GNUNET_strdup, LOG, and section_name.

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_start().

Here is the call graph for this function:

Here is the caller graph for this function:

shutdown_nat()

static void shutdown_nat ( void *  cls )

static

Task run at shutdown to kill communicator and clean up.

Parameters

cls	Closure - Process of communicator

Definition at line 871 of file transport-testing-communicator.c.

{
  struct GNUNET_OS_Process *proc = cls;
  shutdown_process (proc);
}

References shutdown_process().

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

shutdown_resolver()

static void shutdown_resolver ( void *  cls )

static

Task run at shutdown to kill the resolver process.

Parameters

cls	Closure - Process of communicator

Definition at line 884 of file transport-testing-communicator.c.

{
  struct GNUNET_OS_Process *proc = cls;
  shutdown_process (proc);
}

References shutdown_process().

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

resolver_start()

static void resolver_start ( struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *  tc_h )

static

Start Resolver.

Definition at line 896 of file transport-testing-communicator.c.

{
  char *binary;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG, "resolver_start\n");
  binary = GNUNET_OS_get_libexec_binary_path ("gnunet-service-resolver");
  tc_h->resolver_proc = GNUNET_OS_start_process (
    GNUNET_OS_INHERIT_STD_OUT_AND_ERR
    | GNUNET_OS_USE_PIPE_CONTROL,
    NULL,
    NULL,
    NULL,
    binary,
    "gnunet-service-resolver",
    "-c",
    tc_h->cfg_filename,
    NULL);
  if (NULL == tc_h->resolver_proc)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start resolver service!");
    return;
  }
  LOG (GNUNET_ERROR_TYPE_INFO, "started resolver service\n");
  GNUNET_free (binary);
 
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg_filename, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OS_get_libexec_binary_path(), GNUNET_OS_INHERIT_STD_OUT_AND_ERR, GNUNET_OS_start_process(), GNUNET_OS_USE_PIPE_CONTROL, LOG, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::resolver_proc.

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_start().

Here is the call graph for this function:

Here is the caller graph for this function:

statistics_start()

static void statistics_start ( struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *  tc_h )

static

Start Statistics.

Definition at line 930 of file transport-testing-communicator.c.

{
  char *binary;
 
  binary = GNUNET_OS_get_libexec_binary_path ("gnunet-service-statistics");
  tc_h->stat_proc = GNUNET_OS_start_process (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                             NULL,
                                             NULL,
                                             NULL,
                                             binary,
                                             "gnunet-service-statistics",
                                             "-c",
                                             tc_h->cfg_filename,
                                             NULL);
  if (NULL == tc_h->stat_proc)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start Statistics!");
    return;
  }
  LOG (GNUNET_ERROR_TYPE_INFO, "started Statistics\n");
  GNUNET_free (binary);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg_filename, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OS_get_libexec_binary_path(), GNUNET_OS_INHERIT_STD_OUT_AND_ERR, GNUNET_OS_start_process(), LOG, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::stat_proc.

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_start().

Here is the call graph for this function:

Here is the caller graph for this function:

peerstore_start()

static void peerstore_start ( struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *  tc_h )

static

Start Peerstore.

Definition at line 960 of file transport-testing-communicator.c.

{
  char *binary;
 
  binary = GNUNET_OS_get_libexec_binary_path ("gnunet-service-peerstore");
  tc_h->ps_proc = GNUNET_OS_start_process (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                           NULL,
                                           NULL,
                                           NULL,
                                           binary,
                                           "gnunet-service-peerstore",
                                           "-c",
                                           tc_h->cfg_filename,
                                           NULL);
  if (NULL == tc_h->ps_proc)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start Peerstore!");
    return;
  }
  LOG (GNUNET_ERROR_TYPE_INFO, "started Peerstore\n");
  GNUNET_free (binary);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg_filename, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OS_get_libexec_binary_path(), GNUNET_OS_INHERIT_STD_OUT_AND_ERR, GNUNET_OS_start_process(), LOG, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::ps_proc.

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_start().

Here is the call graph for this function:

Here is the caller graph for this function:

nat_start()

static void nat_start ( struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *  tc_h )

static

Start NAT.

Definition at line 990 of file transport-testing-communicator.c.

{
  char *binary;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG, "nat_start\n");
  binary = GNUNET_OS_get_libexec_binary_path ("gnunet-service-nat");
  tc_h->nat_proc = GNUNET_OS_start_process (GNUNET_OS_INHERIT_STD_OUT_AND_ERR
                                            | GNUNET_OS_USE_PIPE_CONTROL,
                                            NULL,
                                            NULL,
                                            NULL,
                                            binary,
                                            "gnunet-service-nat",
                                            "-c",
                                            tc_h->cfg_filename,
                                            NULL);
  if (NULL == tc_h->nat_proc)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to start NAT!");
    return;
  }
  LOG (GNUNET_ERROR_TYPE_INFO, "started NAT\n");
  GNUNET_free (binary);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg_filename, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log, GNUNET_OS_get_libexec_binary_path(), GNUNET_OS_INHERIT_STD_OUT_AND_ERR, GNUNET_OS_start_process(), GNUNET_OS_USE_PIPE_CONTROL, LOG, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::nat_proc.

Referenced by GNUNET_TRANSPORT_TESTING_transport_communicator_service_start().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TRANSPORT_TESTING_transport_communicator_service_start()

struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle* GNUNET_TRANSPORT_TESTING_transport_communicator_service_start	(	const char *	service_name,
		const char *	binary_name,
		const char *	cfg_filename,
		const struct GNUNET_PeerIdentity *	peer_id,
		GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback	communicator_available_cb,
		GNUNET_TRANSPORT_TESTING_AddAddressCallback	add_address_cb,
		GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback	queue_create_reply_cb,
		GNUNET_TRANSPORT_TESTING_AddQueueCallback	add_queue_cb,
		GNUNET_TRANSPORT_TESTING_IncomingMessageCallback	incoming_message_cb,
		GNUNET_TRANSPORT_TESTING_BackchannelCallback	bc_cb,
		void *	cb_cls
	)

Start communicator part of transport service and communicator.

Parameters

service_name	Name of the service
cfg	Configuration handle
communicator_available_cb	Callback that is called when a new
add_address_cb	Callback that is called when a new communicator becomes available
cb_cls	Closure to communicator_available_cb and

Returns

Handle to the communicator duo

Definition at line 1030 of file transport-testing-communicator.c.

{
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Starting new transport/communicator combo with config %s\n",
       cfg_filename);
  tc_h =
    GNUNET_new (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle);
  tc_h->cfg_filename = GNUNET_strdup (cfg_filename);
  tc_h->cfg = GNUNET_CONFIGURATION_create ();
  if ((GNUNET_SYSERR == GNUNET_CONFIGURATION_load (tc_h->cfg, cfg_filename)))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                _ ("Malformed configuration file `%s', exit ...\n"),
                cfg_filename);
    GNUNET_free (tc_h->cfg_filename);
    GNUNET_CONFIGURATION_destroy (tc_h->cfg);
    GNUNET_free (tc_h);
    return NULL;
  }
  tc_h->bc_enabled = GNUNET_CONFIGURATION_get_value_yesno (tc_h->cfg,
                                                           "communicator-test",
                                                           "BACKCHANNEL_ENABLED");
  tc_h->communicator_available_cb = communicator_available_cb;
  tc_h->add_address_cb = add_address_cb;
  tc_h->queue_create_reply_cb = queue_create_reply_cb;
  tc_h->add_queue_cb = add_queue_cb;
  tc_h->incoming_msg_cb = incoming_message_cb;
  tc_h->bc_cb = bc_cb;
  tc_h->peer_id = *peer_id;
  tc_h->cb_cls = cb_cls;
 
  /* Start communicator part of service */
  transport_communicator_start (tc_h);
  /* Start NAT */
  nat_start (tc_h);
  /* Start resolver service */
  resolver_start (tc_h);
  /* Start peerstore service */
  peerstore_start (tc_h);
  /* Start statistic service */
  statistics_start (tc_h);
  /* Schedule start communicator */
  communicator_start (tc_h,
                      binary_name);
  return tc_h;
}

References _, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::add_address_cb, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::add_queue_cb, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::bc_cb, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::bc_enabled, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cb_cls, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg, cfg_filename, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg_filename, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::communicator_available_cb, communicator_start(), GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_destroy(), GNUNET_CONFIGURATION_get_value_yesno(), GNUNET_CONFIGURATION_load(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, GNUNET_new, GNUNET_strdup, GNUNET_SYSERR, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::incoming_msg_cb, LOG, nat_start(), peer_id, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::peer_id, peerstore_start(), GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_create_reply_cb, resolver_start(), statistics_start(), and transport_communicator_start().

Here is the call graph for this function:

GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop()

void GNUNET_TRANSPORT_TESTING_transport_communicator_service_stop

(

struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *

tc_h

)

Definition at line 1093 of file transport-testing-communicator.c.

{
  shutdown_communicator (tc_h->c_proc);
  shutdown_service (tc_h->sh);
  shutdown_nat (tc_h->nat_proc);
  shutdown_resolver (tc_h->resolver_proc);
  shutdown_peerstore (tc_h->ps_proc);
  shutdown_statistics (tc_h->stat_proc);
  GNUNET_CONFIGURATION_destroy (tc_h->cfg);
  GNUNET_free (tc_h);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_proc, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg, GNUNET_CONFIGURATION_destroy(), GNUNET_free, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::nat_proc, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::ps_proc, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::resolver_proc, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::sh, shutdown_communicator(), shutdown_nat(), shutdown_peerstore(), shutdown_resolver(), shutdown_service(), shutdown_statistics(), and GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::stat_proc.

Here is the call graph for this function:

GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue()

void GNUNET_TRANSPORT_TESTING_transport_communicator_open_queue	(	struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *	tc_h,
		const struct GNUNET_PeerIdentity *	peer_id,
		const char *	address
	)

Instruct communicator to open a queue.

Parameters

tc_h	Handle to communicator which shall open queue
peer_id	Towards which peer
address	For which address

Definition at line 1115 of file transport-testing-communicator.c.

{
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue;
  static uint32_t idgen;
  char *prefix;
  struct GNUNET_TRANSPORT_CreateQueue *msg;
  struct GNUNET_MQ_Envelope *env;
  size_t alen;
 
  tc_queue =
    GNUNET_new (struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue);
  tc_queue->tc_h = tc_h;
  prefix = GNUNET_HELLO_address_to_prefix (address);
  if (NULL == prefix)
  {
    GNUNET_break (0);  /* We got an invalid address!? */
    GNUNET_free (tc_queue);
    return;
  }
  GNUNET_free (prefix);
  alen = strlen (address) + 1;
  env =
    GNUNET_MQ_msg_extra (msg, alen, GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE);
  msg->request_id = htonl (idgen++);
  tc_queue->qid = msg->request_id;
  msg->receiver = *peer_id;
  tc_queue->peer_id = *peer_id;
  memcpy (&msg[1], address, alen);
  if (NULL != tc_h->c_mq)
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "Sending queue create immediately\n");
    GNUNET_MQ_send (tc_h->c_mq, env);
  }
  else
  {
    tc_queue->open_queue_env = env;
  }
  GNUNET_CONTAINER_DLL_insert (tc_h->queue_head, tc_h->queue_tail, tc_queue);
}

References address, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_mq, env, GNUNET_break, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_HELLO_address_to_prefix(), GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_new, LOG, msg, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::open_queue_env, peer_id, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::peer_id, prefix, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::qid, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_head, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_tail, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::tc_h.

Here is the call graph for this function:

GNUNET_TRANSPORT_TESTING_transport_communicator_send()

void GNUNET_TRANSPORT_TESTING_transport_communicator_send	(	struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *	tc_h,
		GNUNET_SCHEDULER_TaskCallback	cont,
		void *	cont_cls,
		const void *	payload,
		size_t	payload_size
	)

Instruct communicator to send data.

Parameters

tc_queue	The queue to use for sending
cont	function to call when done sending
cont_cls	closure for cont
payload	Data to send
payload_size	Size of the payload

Definition at line 1161 of file transport-testing-communicator.c.

{
  struct GNUNET_MessageHeader *mh;
  struct GNUNET_TRANSPORT_SendMessageTo *msg;
  struct GNUNET_MQ_Envelope *env;
  size_t inbox_size;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue;
  struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue_tmp;
  static struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *last_queue;
  tc_queue = NULL;
 
  for (tc_queue_tmp = tc_h->queue_head;
       NULL != tc_queue_tmp;
       tc_queue_tmp = tc_queue_tmp->next)
  {
    if (tc_queue_tmp->q_len <= 0)
      continue;
    if (NULL == tc_queue)
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Selecting queue with prio %u, len %" PRIu64 " and MTU %u\n",
           tc_queue_tmp->priority,
           tc_queue_tmp->q_len,
           tc_queue_tmp->mtu);
      tc_queue = tc_queue_tmp;
      continue;
    }
    if (tc_queue->priority < tc_queue_tmp->priority)
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Selecting queue with prio %u, len %" PRIu64 " and MTU %u\n",
           tc_queue_tmp->priority,
           tc_queue_tmp->q_len,
           tc_queue_tmp->mtu);
      tc_queue = tc_queue_tmp;
    }
  }
  if (last_queue != tc_queue)
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Selected sending queue changed to %u with length %lu and MTU %u\n",
                ntohl (tc_queue->qid), tc_queue->q_len, tc_queue->mtu);
  GNUNET_assert (NULL != tc_queue);
  last_queue = tc_queue;
  // Uncomment this for alternativ 1 of backchannel functionality
  if (tc_queue->q_len != GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED)
    tc_queue->q_len--;
  // Until here for alternativ 1
  static int msg_count = 0;
  msg_count++;
  if (msg_count % 100 == 0)
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Sending %u-th (%lu-th for queue) message on queue %u\n",
                msg_count, tc_queue->mid, ntohl (tc_queue->qid));
  inbox_size = sizeof (struct GNUNET_MessageHeader) + payload_size;
  env = GNUNET_MQ_msg_extra (msg,
                             inbox_size,
                             GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG);
  GNUNET_assert (NULL != env);
  msg->qid = tc_queue->qid;
  msg->mid = tc_queue->mid++;
  msg->receiver = tc_queue->peer_id;
  mh = (struct GNUNET_MessageHeader *) &msg[1];
  mh->size = htons (inbox_size);
  mh->type = GNUNET_MESSAGE_TYPE_DUMMY;
  memcpy (&mh[1],
          payload,
          payload_size);
  if (NULL != cont)
    GNUNET_MQ_notify_sent (env,
                           cont,
                           cont_cls);
  GNUNET_MQ_send (tc_queue->tc_h->c_mq,
                  env);
}

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_mq, env, GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_MESSAGE_TYPE_DUMMY, GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG, GNUNET_MQ_msg_extra, GNUNET_MQ_notify_sent(), GNUNET_MQ_send(), GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED, LOG, mh, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::mid, msg, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::mtu, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::next, payload, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::peer_id, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::priority, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::q_len, GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::qid, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_head, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::tc_h.

Here is the call graph for this function: