GNUnet 0.22.0
transport-testing-communicator.h File Reference

functions and structures related to testing-tng More...

Include dependency graph for transport-testing-communicator.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle
 Handle to a transport communicator. More...
 

Typedefs

typedef struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *(* GNUNET_TRANSPORT_TESTING_BackchannelCallback) (void *cls, struct GNUNET_MessageHeader *msg, struct GNUNET_PeerIdentity *pid)
 Function signature for callbacks that are called when new backchannel message arrived. More...
 
typedef void(* GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, enum GNUNET_TRANSPORT_CommunicatorCharacteristics cc, char *address_prefix)
 Function signature for callbacks that are called when new communicators become available. More...
 
typedef void(* GNUNET_TRANSPORT_TESTING_AddAddressCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *address, struct GNUNET_TIME_Relative expiration, uint32_t aid, enum GNUNET_NetworkType nt)
 Receive information about the address of a communicator. More...
 
typedef void(* GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, int will_try)
 Get informed about the success of a queue request. More...
 
typedef void(* GNUNET_TRANSPORT_TESTING_AddQueueCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue, size_t mtu)
 Handle opening of queue. More...
 
typedef void(* GNUNET_TRANSPORT_TESTING_IncomingMessageCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *payload, size_t payload_len)
 Handle an incoming message. More...
 

Functions

struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandleGNUNET_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 and structures related to testing-tng

Author
Christian Grothoff
Julius Bünger

Definition in file transport-testing-communicator.h.

Typedef Documentation

◆ GNUNET_TRANSPORT_TESTING_BackchannelCallback

typedef struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *(* GNUNET_TRANSPORT_TESTING_BackchannelCallback) (void *cls, struct GNUNET_MessageHeader *msg, struct GNUNET_PeerIdentity *pid)

Function signature for callbacks that are called when new backchannel message arrived.

Parameters
clsClosure
msgBackchannel message
pidTarget peer

Definition at line 1 of file transport-testing-communicator.h.

◆ GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback

typedef void(* GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, enum GNUNET_TRANSPORT_CommunicatorCharacteristics cc, char *address_prefix)

Function signature for callbacks that are called when new communicators become available.

Parameters
clsClosure
tc_hCommunicator handle
ccCharacteristics of communicator
address_prefixPrefix of the address

Definition at line 66 of file transport-testing-communicator.h.

◆ GNUNET_TRANSPORT_TESTING_AddAddressCallback

typedef void(* GNUNET_TRANSPORT_TESTING_AddAddressCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *address, struct GNUNET_TIME_Relative expiration, uint32_t aid, enum GNUNET_NetworkType nt)

Receive information about the address of a communicator.

Parameters
clsClosure
tc_hCommunicator handle
addressAddress represented as string
expirationExpiration
aidAid
ntNetwork Type

Definition at line 87 of file transport-testing-communicator.h.

◆ GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback

typedef void(* GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, int will_try)

Get informed about the success of a queue request.

Parameters
clsClosure
tc_hCommunicator handle
will_tryGNUNET_YES if communicator will try to create queue

Definition at line 106 of file transport-testing-communicator.h.

◆ GNUNET_TRANSPORT_TESTING_AddQueueCallback

typedef void(* GNUNET_TRANSPORT_TESTING_AddQueueCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue *tc_queue, size_t mtu)

Handle opening of queue.

Parameters
clsClosure
tc_hCommunicator handle
tc_queueHandle to newly opened queue

Definition at line 121 of file transport-testing-communicator.h.

◆ GNUNET_TRANSPORT_TESTING_IncomingMessageCallback

typedef void(* GNUNET_TRANSPORT_TESTING_IncomingMessageCallback) (void *cls, struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *payload, size_t payload_len)

Handle an incoming message.

Parameters
clsClosure
tc_hHandle to the receiving communicator
msgReceived message

Definition at line 139 of file transport-testing-communicator.h.

Function Documentation

◆ 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_nameName of the service
cfgConfiguration handle
communicator_availableCallback that is called when a new communicator becomes available
add_address_cbCallback handling new addresses
queue_create_reply_cbCallback handling success of queue requests
add_queue_cbCallback handling freshly created queues
incoming_message_cbCallback handling incoming messages
cb_clsClosure to communicator_available
Returns
Handle to the communicator duo
Parameters
service_nameName of the service
cfgConfiguration handle
communicator_available_cbCallback that is called when a new
add_address_cbCallback that is called when a new communicator becomes available
cb_clsClosure to communicator_available_cb and
Returns
Handle to the communicator duo

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

1044{
1046
1048 "Starting new transport/communicator combo with config %s\n",
1049 cfg_filename);
1050 tc_h =
1055 {
1057 _ ("Malformed configuration file `%s', exit ...\n"),
1058 cfg_filename);
1059 GNUNET_free (tc_h->cfg_filename);
1061 GNUNET_free (tc_h);
1062 return NULL;
1063 }
1065 "communicator-test",
1066 "BACKCHANNEL_ENABLED");
1070 tc_h->add_queue_cb = add_queue_cb;
1071 tc_h->incoming_msg_cb = incoming_message_cb;
1072 tc_h->bc_cb = bc_cb;
1073 tc_h->peer_id = *peer_id;
1074 tc_h->cb_cls = cb_cls;
1075
1076 /* Start communicator part of service */
1078 /* Start NAT */
1079 nat_start (tc_h);
1080 /* Start resolver service */
1081 resolver_start (tc_h);
1082 /* Start peerstore service */
1083 peerstore_start (tc_h);
1084 /* Start statistic service */
1085 statistics_start (tc_h);
1086 /* Schedule start communicator */
1087 communicator_start (tc_h,
1088 binary_name);
1089 return tc_h;
1090}
static char * cfg_filename
Name of the configuration file.
static char * peer_id
Option –peer.
Definition: gnunet-cadet.c:42
void GNUNET_CONFIGURATION_destroy(struct GNUNET_CONFIGURATION_Handle *cfg)
Destroy configuration object.
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_yesno(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option)
Get a configuration value that should be in a set of "YES" or "NO".
struct GNUNET_CONFIGURATION_Handle * GNUNET_CONFIGURATION_create(void)
Create a new configuration object.
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_load(struct GNUNET_CONFIGURATION_Handle *cfg, const char *filename)
Load configuration.
#define GNUNET_log(kind,...)
@ GNUNET_SYSERR
@ GNUNET_ERROR_TYPE_ERROR
@ GNUNET_ERROR_TYPE_DEBUG
#define GNUNET_strdup(a)
Wrapper around GNUNET_xstrdup_.
#define GNUNET_new(type)
Allocate a struct or union of the given type.
#define GNUNET_free(ptr)
Wrapper around free.
#define _(String)
GNU gettext support macro.
Definition: platform.h:178
GNUNET_TRANSPORT_TESTING_BackchannelCallback bc_cb
Backchannel callback.
GNUNET_TRANSPORT_TESTING_QueueCreateReplyCallback queue_create_reply_cb
Callback called when a new communicator connects.
GNUNET_TRANSPORT_TESTING_AddAddressCallback add_address_cb
Callback called when a new communicator connects.
struct GNUNET_CONFIGURATION_Handle * cfg
Handle to the configuration.
GNUNET_TRANSPORT_TESTING_CommunicatorAvailableCallback communicator_available_cb
Callback called when a new communicator connects.
GNUNET_TRANSPORT_TESTING_AddQueueCallback add_queue_cb
Callback called when a new communicator connects.
GNUNET_TRANSPORT_TESTING_IncomingMessageCallback incoming_msg_cb
Callback called when a new communicator connects.
static void nat_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start NAT.
static void resolver_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start Resolver.
static void transport_communicator_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start the communicator part of the transport service.
static void statistics_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start Statistics.
static void communicator_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h, const char *binary_name)
Start the communicator.
static void peerstore_start(struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle *tc_h)
Start Peerstore.
#define LOG(kind,...)

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 1094 of file transport-testing-communicator.c.

1096{
1105 while (NULL != (queue = tc_h->queue_head))
1106 {
1109 }
1113 GNUNET_free (tc_h);
1114}
static void queue(const char *hostname)
Add hostname to the list of requests to be made.
#define GNUNET_CONTAINER_DLL_remove(head, tail, element)
Remove an element from a DLL.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue * queue_head
Head of the DLL of queues associated with this communicator.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue * queue_tail
Tail of the DLL of queues associated with this communicator.
struct GNUNET_SERVICE_Handle * sh
Our service handle.
struct GNUNET_OS_Process * stat_proc
statistics service process
struct GNUNET_OS_Process * resolver_proc
resolver service process
struct GNUNET_OS_Process * ps_proc
peerstore service process
struct GNUNET_OS_Process * c_proc
Process of the communicator.
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle * tc_h
Handle to the TransportCommunicator.
static void shutdown_peerstore(void *cls)
Task run at shutdown to kill the peerstore process.
static void shutdown_communicator(void *cls)
Task run at shutdown to kill a communicator process.
static void shutdown_statistics(void *cls)
Task run at shutdown to kill the statistics process.
static void shutdown_resolver(void *cls)
Task run at shutdown to kill the resolver process.
static void shutdown_nat(void *cls)
Task run at shutdown to kill communicator and clean up.
static void shutdown_service(void *cls)
Shut down the service.

References GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_addr_prefix, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_address, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::c_proc, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::cfg_filename, GNUNET_CONFIGURATION_destroy(), GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::nat_proc, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::ps_proc, queue(), GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_head, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::queue_tail, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::resolver_proc, GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::sh, shutdown_communicator(), shutdown_nat(), shutdown_peerstore(), shutdown_resolver(), shutdown_service(), shutdown_statistics(), GNUNET_TRANSPORT_TESTING_TransportCommunicatorHandle::stat_proc, and GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue::tc_h.

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_hHandle to communicator which shall open queue
peer_idTowards which peer
addressFor which address

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

1129{
1131 static uint32_t idgen;
1132 char *prefix;
1134 struct GNUNET_MQ_Envelope *env;
1135 size_t alen;
1136
1137 tc_queue =
1139 tc_queue->tc_h = tc_h;
1141 if (NULL == prefix)
1142 {
1143 GNUNET_break (0); /* We got an invalid address!? */
1144 GNUNET_free (tc_queue);
1145 return;
1146 }
1148 alen = strlen (address) + 1;
1149 env =
1151 msg->request_id = htonl (idgen++);
1152 tc_queue->qid = msg->request_id;
1153 msg->receiver = *peer_id;
1154 tc_queue->peer_id = *peer_id;
1155 memcpy (&msg[1], address, alen);
1156 if (NULL != tc_h->c_mq)
1157 {
1159 "Sending queue create immediately\n");
1160 GNUNET_MQ_send (tc_h->c_mq, env);
1161 }
1162 else
1163 {
1164 tc_queue->open_queue_env = env;
1165 }
1166 GNUNET_CONTAINER_DLL_insert (tc_h->queue_head, tc_h->queue_tail, tc_queue);
1167}
struct GNUNET_MessageHeader * msg
Definition: 005.c:2
struct GNUNET_MQ_Envelope * env
Definition: 005.c:1
static int prefix
If printing the value of PREFIX has been requested.
Definition: gnunet-config.c:66
static char * address
GNS address for this phone.
#define GNUNET_CONTAINER_DLL_insert(head, tail, element)
Insert an element at the head of a DLL.
char * GNUNET_HELLO_address_to_prefix(const char *address)
Given an address as a string, extract the prefix that identifies the communicator offering transmissi...
Definition: hello-ng.c:190
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur.
void GNUNET_MQ_send(struct GNUNET_MQ_Handle *mq, struct GNUNET_MQ_Envelope *ev)
Send a message with the given message queue.
Definition: mq.c:305
#define GNUNET_MQ_msg_extra(mvar, esize, type)
Allocate an envelope, with extra space allocated after the space needed by the message struct.
Definition: gnunet_mq_lib.h:63
#define GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE
transport tells communicator it wants a queue
Transport tells communicator that it wants a new queue.
Definition: transport.h:521
struct GNUNET_MQ_Handle * c_mq
Handle to the client.
struct GNUNET_MQ_Envelope * open_queue_env
Envelope to a message that requests the opening of the queue.
struct GNUNET_PeerIdentity peer_id
Peer ID of the peer on the other side of the 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_queueThe queue to use for sending
contfunction to call when done sending
cont_clsclosure for cont
payloadData to send
payload_sizeSize of the payload

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

1177{
1178 struct GNUNET_MessageHeader *mh;
1180 struct GNUNET_MQ_Envelope *env;
1181 size_t inbox_size;
1185 tc_queue = NULL;
1186
1187 for (tc_queue_tmp = tc_h->queue_head;
1188 NULL != tc_queue_tmp;
1189 tc_queue_tmp = tc_queue_tmp->next)
1190 {
1191 if (tc_queue_tmp->q_len <= 0)
1192 continue;
1193 if (NULL == tc_queue)
1194 {
1196 "Selecting queue with prio %u, len %" PRIu64 " and MTU %u\n",
1197 tc_queue_tmp->priority,
1198 tc_queue_tmp->q_len,
1199 tc_queue_tmp->mtu);
1200 tc_queue = tc_queue_tmp;
1201 continue;
1202 }
1203 if (tc_queue->priority < tc_queue_tmp->priority)
1204 {
1206 "Selecting queue with prio %u, len %" PRIu64 " and MTU %u\n",
1207 tc_queue_tmp->priority,
1208 tc_queue_tmp->q_len,
1209 tc_queue_tmp->mtu);
1210 tc_queue = tc_queue_tmp;
1211 }
1212 }
1213 if (last_queue != tc_queue)
1215 "Selected sending queue changed to %u with length %lu and MTU %u\n",
1216 ntohl (tc_queue->qid), (unsigned long) tc_queue->q_len, tc_queue->mtu);
1217 GNUNET_assert (NULL != tc_queue);
1218 last_queue = tc_queue;
1219 // Uncomment this for alternative 1 of backchannel functionality
1221 tc_queue->q_len--;
1222 // Until here for alternative 1
1223 static int msg_count = 0;
1224 msg_count++;
1225 if (msg_count % 100 == 0)
1227 "Sending %u-th (%lu-th for queue) message on queue %u\n",
1228 msg_count, (unsigned long) tc_queue->mid, ntohl (tc_queue->qid));
1229 inbox_size = sizeof (struct GNUNET_MessageHeader) + payload_size;
1231 inbox_size,
1233 GNUNET_assert (NULL != env);
1234 msg->qid = tc_queue->qid;
1235 msg->mid = tc_queue->mid++;
1236 msg->receiver = tc_queue->peer_id;
1237 mh = (struct GNUNET_MessageHeader *) &msg[1];
1238 mh->size = htons (inbox_size);
1240 memcpy (&mh[1],
1241 payload,
1242 payload_size);
1243 if (NULL != cont)
1245 cont,
1246 cont_cls);
1247 GNUNET_MQ_send (tc_queue->tc_h->c_mq,
1248 env);
1249}
static struct GNUNET_CADET_Handle * mh
Cadet handle.
Definition: gnunet-cadet.c:92
static unsigned long long payload
How much data are we currently storing in the database?
#define GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED
Queue length.
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
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.
Definition: mq.c:655
#define GNUNET_MESSAGE_TYPE_DUMMY
Dummy messages for testing / benchmarking.
#define GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_MSG
transport tells communicator it wants to transmit
Header for all communications.
Inform communicator about transport's desire to send a message.
Definition: transport.h:563
struct GNUNET_TRANSPORT_TESTING_TransportCommunicatorQueue * next
Next element inside a DLL.

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: