GNUnet 0.21.1
transport_api_cmd_connecting_peers.c File Reference
Include dependency graph for transport_api_cmd_connecting_peers.c:

Go to the source code of this file.


#define LOG(kind, ...)   GNUNET_log (kind, __VA_ARGS__)
 Generic logging shortcut. More...


static void connect_peers_run (void *cls, struct GNUNET_TESTING_Interpreter *is)
 The run method of this cmd will connect to peers. More...
static void * notify_connect (struct GNUNET_TESTING_Interpreter *is, const struct GNUNET_PeerIdentity *peer)
 Callback from start peer cmd for signaling a peer got connected. More...
static void connect_peers_cleanup (void *cls)
 The cleanup function of this cmd frees resources the cmd allocated. More...
enum GNUNET_GenericReturnValue connect_peers_traits (void *cls, const void **ret, const char *trait, unsigned int index)
 This function prepares an array with traits. More...
struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_connect_peers (const char *label, const char *start_peer_label, const char *create_label, uint32_t num, struct GNUNET_TESTING_NetjailTopology *topology, unsigned int additional_connects, unsigned int wait_for_connect)
 Create command. More...

Macro Definition Documentation


#define LOG (   kind,
)    GNUNET_log (kind, __VA_ARGS__)

Generic logging shortcut.

Definition at line 36 of file transport_api_cmd_connecting_peers.c.

Function Documentation

◆ connect_peers_run()

static void connect_peers_run ( void *  cls,
struct GNUNET_TESTING_Interpreter is 

The run method of this cmd will connect to peers.

Definition at line 43 of file transport_api_cmd_connecting_peers.c.

46 struct ConnectPeersState *cps = cls;
47 const struct GNUNET_TESTING_Command *system_cmd;
48 const struct GNUNET_TESTING_System *tl_system;
51 const struct GNUNET_TESTING_Command *peer1_cmd;
53 struct GNUNET_PeerIdentity *peer;
54 char *addr;
55 char *addr_and_port;
56 enum GNUNET_NetworkType nt = 0;
57 uint32_t num;
58 struct GNUNET_TESTING_NodeConnection *pos_connection;
59 struct GNUNET_TESTING_AddressPrefix *pos_prefix;
60 unsigned int con_num = 0;
61 const enum GNUNET_GenericReturnValue *broadcast;
63 cps->is = is;
65 cps->start_peer_label);
66 if (GNUNET_YES == cps->wait_for_connect)
67 {
69 "Wait for connect.\n");
71 &ah);
72 }
73 else
74 {
76 "Not waiting for connect.\n");
78 &ah);
79 }
82 &broadcast);
85 cps->create_label);
87 &tl_system);
89 cps->tl_system = tl_system;
92 "cps->num: %u \n",
93 cps->num);
96 cps->topology);
98 for (pos_connection = cps->node_connections_head; NULL != pos_connection;
99 pos_connection = pos_connection->next)
100 {
101 con_num++;
102 num = GNUNET_TESTING_calculate_num (pos_connection, cps->topology);
103 for (pos_prefix = pos_connection->address_prefixes_head; NULL != pos_prefix;
104 pos_prefix =
105 pos_prefix->next)
106 {
107 addr = GNUNET_TESTING_get_address (pos_connection,
108 pos_prefix->address_prefix);
109 if (NULL != addr)
110 {
111 char *natted_p = strstr (pos_prefix->address_prefix, "_");
114 "0 validating peer number %s %s %s\n",
115 natted_p,
116 pos_prefix->address_prefix,
117 addr);
118 if (0 == GNUNET_memcmp (pos_prefix->address_prefix, "udp"))
120 "validating memcmp\n");
121 if (GNUNET_YES == *broadcast)
123 "validating broadcast\n");
124 if ((0 == GNUNET_memcmp (pos_prefix->address_prefix, "udp")) &&
125 (GNUNET_YES == *broadcast) )
126 GNUNET_asprintf (&addr_and_port,
127 "%s:2086",
128 addr);
129 else if (NULL == natted_p)
130 GNUNET_asprintf (&addr_and_port,
131 "%s:60002",
132 addr);
133 else if (NULL != natted_p)
134 {
135 char *prefix;
136 char *rest;
137 char *address;
139 prefix = strtok (addr, "_");
140 rest = strtok (NULL, "_");
141 strtok (rest, "-");
142 address = strtok (NULL, "-");
144 GNUNET_asprintf (&addr_and_port,
145 "%s-%s:0",
146 prefix,
147 address);
149 }
150 peer = GNUNET_TESTING_get_peer (num, tl_system);
152 "validating peer number %u with identity %s and address %s %u %s and handle %p\n",
153 num,
154 GNUNET_i2s (peer),
155 addr_and_port,
156 *broadcast,
157 pos_prefix->address_prefix,
158 ah);
161 *) ah,
162 peer,
163 nt,
164 addr_and_port);
165 GNUNET_free (peer);
166 GNUNET_free (addr);
167 GNUNET_free (addr_and_port);
168 }
169 }
170 }
171 cps->con_num = con_num;
struct GNUNET_TESTING_Interpreter * is
static int prefix
If printing the value of PREFIX has been requested.
Definition: gnunet-config.c:59
static char * address
GNS address for this phone.
static struct GNUNET_NAT_AUTO_AutoHandle * ah
Handle to ongoing autoconfiguration.
static struct GNUNET_NAT_AUTO_Test * nt
Handle to a NAT test operation.
const struct GNUNET_TESTING_Command * GNUNET_TESTING_interpreter_lookup_command(struct GNUNET_TESTING_Interpreter *is, const char *label)
Lookup command by label.
struct GNUNET_TESTING_NodeConnection * GNUNET_TESTING_get_connections(unsigned int num, const struct GNUNET_TESTING_NetjailTopology *topology)
Get the connections to other nodes for a specific node.
Definition: testing.c:2251
unsigned int GNUNET_TESTING_calculate_num(struct GNUNET_TESTING_NodeConnection *node_connection, struct GNUNET_TESTING_NetjailTopology *topology)
Calculate the unique id identifying a node from a given connection.
Definition: testing.c:2361
char * GNUNET_TESTING_get_address(struct GNUNET_TESTING_NodeConnection *connection, const char *prefix)
Get the address for a specific communicator from a connection.
Definition: testing.c:2387
enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait_test_system(const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_TESTING_System **ret)
enum GNUNET_GenericReturnValue GNUNET_TRANSPORT_TESTING_get_trait_broadcast(const struct GNUNET_TESTING_Command *cmd, const enum GNUNET_GenericReturnValue **ret)
struct GNUNET_PeerIdentity * GNUNET_TESTING_get_peer(unsigned int num, const struct GNUNET_TESTING_System *tl_system)
Retrieve peer identity from the test system with the unique node id.
Definition: testing.c:2276
enum GNUNET_GenericReturnValue GNUNET_TRANSPORT_TESTING_get_trait_application_handle(const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_TRANSPORT_ApplicationHandle **ret)
void GNUNET_TRANSPORT_application_validate(struct GNUNET_TRANSPORT_ApplicationHandle *ch, const struct GNUNET_PeerIdentity *peer, enum GNUNET_NetworkType nt, const char *addr)
An application (or a communicator) has received a HELLO (or other address data of another peer) and w...
#define GNUNET_log(kind,...)
#define GNUNET_memcmp(a, b)
Compare memory in a and b, where both must be of the same pointer type.
Named constants for return values.
const char * GNUNET_i2s(const struct GNUNET_PeerIdentity *pid)
Convert a peer identity to a string (for printing debug messages).
int int GNUNET_asprintf(char **buf, const char *format,...) __attribute__((format(printf
Like asprintf, just portable.
#define GNUNET_free(ptr)
Wrapper around free.
Types of networks (with separate quotas) we support.
Definition: gnunet_nt_lib.h:44
Struct to store information needed in callbacks.
unsigned int con_num
Number of connections.
uint32_t num
Number globally identifying the node.
struct GNUNET_TESTING_Interpreter * is
struct GNUNET_TESTING_NodeConnection * node_connections_head
Connections to other peers.
struct GNUNET_TESTING_NetjailTopology * topology
The topology of the test setup.
const struct GNUNET_TESTING_System * tl_system
The testing system of this node.
unsigned int wait_for_connect
Flag indicating, whether the command is waiting for peers to connect that are configured to connect.
const char * start_peer_label
Label of the cmd to start a peer.
The identity of the host (wraps the signing key of the peer).
Protocol address prefix für a connection between nodes.
struct GNUNET_TESTING_AddressPrefix * next
Pointer to the next prefix in the DLL.
char * address_prefix
The address prefix.
A command to be run by the interpreter.
struct GNUNET_TESTING_NodeConnection * next
Pointer to the next connection in the DLL.
struct GNUNET_TESTING_AddressPrefix * address_prefixes_head
Head of the DLL with the address prefixes for the protocolls this node is reachable.
Handle for a system on which GNUnet peers are executed; a system is used for reserving unique paths a...
Definition: testing.c:122
Handle to the TRANSPORT subsystem for application management.
#define LOG(kind,...)
Generic logging shortcut.

References address, GNUNET_TESTING_AddressPrefix::address_prefix, GNUNET_TESTING_NodeConnection::address_prefixes_head, ah, ConnectPeersState::con_num, ConnectPeersState::create_label, GNUNET_asprintf(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_i2s(), GNUNET_log, GNUNET_memcmp, GNUNET_TESTING_calculate_num(), GNUNET_TESTING_get_address(), GNUNET_TESTING_get_connections(), GNUNET_TESTING_get_peer(), GNUNET_TESTING_get_trait_test_system(), GNUNET_TESTING_interpreter_lookup_command(), GNUNET_TRANSPORT_application_validate(), GNUNET_TRANSPORT_TESTING_get_trait_application_handle(), GNUNET_TRANSPORT_TESTING_get_trait_broadcast(), GNUNET_YES, is, ConnectPeersState::is, LOG, GNUNET_TESTING_AddressPrefix::next, GNUNET_TESTING_NodeConnection::next, ConnectPeersState::node_connections_head, nt, ConnectPeersState::num, prefix, ConnectPeersState::start_peer_label, ConnectPeersState::tl_system, ConnectPeersState::topology, and ConnectPeersState::wait_for_connect.

Referenced by GNUNET_TRANSPORT_cmd_connect_peers().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ notify_connect()

static void * notify_connect ( struct GNUNET_TESTING_Interpreter is,
const struct GNUNET_PeerIdentity peer 

Callback from start peer cmd for signaling a peer got connected.

Definition at line 180 of file transport_api_cmd_connecting_peers.c.

183 const struct GNUNET_TESTING_Command *cmd;
184 struct ConnectPeersState *cps;
185 struct GNUNET_PeerIdentity *peer_connection;
186 unsigned int num;
187 unsigned int con_num;
188 void *ret = NULL;
191 "connect-peers");
192 cps = cmd->cls; // WTF? Never go directly into cls of another command! FIXME!
193 con_num = cps->con_num_notified;
194 for (struct GNUNET_TESTING_NodeConnection *pos_connection =
196 NULL != pos_connection;
197 pos_connection = pos_connection->next)
198 {
199 num = GNUNET_TESTING_calculate_num (pos_connection,
200 cps->topology);
201 peer_connection = GNUNET_TESTING_get_peer (num,
202 cps->tl_system);
203 if (0 == GNUNET_memcmp (peer,
204 peer_connection))
205 cps->con_num_notified++;
206 GNUNET_free (peer_connection);
207 }
208 if (cps->con_num_notified == con_num)
212 "con_num: %u add: %u num_notified: %u add_notified: %u peer: %s\n",
213 cps->con_num,
215 cps->con_num_notified,
217 GNUNET_i2s (peer));
218 if ((cps->con_num == cps->con_num_notified) &&
220 {
222 }
223 return ret;
static int ret
Final status code.
Definition: gnunet-arm.c:94
void GNUNET_TESTING_async_finish(struct GNUNET_TESTING_AsyncContext *ac)
The asynchronous command of ac has finished.
const struct GNUNET_TESTING_Command * GNUNET_TESTING_interpreter_lookup_command_all(struct GNUNET_TESTING_Interpreter *is, const char *label)
Lookup command by label.
struct GNUNET_TESTING_AsyncContext ac
Context for our asynchronous completion.
unsigned int additional_connects_notified
Number of additional connects this cmd will wait for not triggered by this cmd we already have a noti...
unsigned int con_num_notified
Number of connections we already have a notification for.
unsigned int additional_connects
Number of additional connects this cmd will wait for not triggered by this cmd.
void * cls
Closure for all commands with command-specific context information.

References ConnectPeersState::ac, ConnectPeersState::additional_connects, ConnectPeersState::additional_connects_notified, GNUNET_TESTING_Command::cls, ConnectPeersState::con_num, ConnectPeersState::con_num_notified, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_i2s(), GNUNET_log, GNUNET_memcmp, GNUNET_TESTING_async_finish(), GNUNET_TESTING_calculate_num(), GNUNET_TESTING_get_peer(), GNUNET_TESTING_interpreter_lookup_command_all(), is, GNUNET_TESTING_NodeConnection::next, ConnectPeersState::node_connections_head, ret, ConnectPeersState::tl_system, and ConnectPeersState::topology.

Referenced by GNUNET_TRANSPORT_cmd_connect_peers().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ connect_peers_cleanup()

static void connect_peers_cleanup ( void *  cls)

The cleanup function of this cmd frees resources the cmd allocated.

Definition at line 232 of file transport_api_cmd_connecting_peers.c.

234 struct ConnectPeersState *cps = cls;
236 GNUNET_free (cps);

References GNUNET_free.

Referenced by GNUNET_TRANSPORT_cmd_connect_peers().

Here is the caller graph for this function:

◆ connect_peers_traits()

enum GNUNET_GenericReturnValue connect_peers_traits ( void *  cls,
const void **  ret,
const char *  trait,
unsigned int  index 

This function prepares an array with traits.

Definition at line 245 of file transport_api_cmd_connecting_peers.c.

250 struct ConnectPeersState *cps = cls;
251 struct GNUNET_TESTING_Trait traits[] = {
252 GNUNET_TRANSPORT_TESTING_make_trait_connect_peer_state ((const void *) cps),
254 };
255 return GNUNET_TESTING_get_trait (traits,
256 ret,
257 trait,
258 index);
struct GNUNET_TESTING_Trait GNUNET_TESTING_trait_end(void)
"end" of traits array.
enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait(const struct GNUNET_TESTING_Trait *traits, const void **ret, const char *trait, unsigned int index)
Obtain value of a trait from a command.
A struct GNUNET_TESTING_Trait can be used to exchange data between cmds.
unsigned int index
Index number associated with the trait.

References GNUNET_TESTING_get_trait(), GNUNET_TESTING_trait_end(), GNUNET_TESTING_Trait::index, and ret.

Referenced by GNUNET_TRANSPORT_cmd_connect_peers().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ GNUNET_TRANSPORT_cmd_connect_peers()

struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_connect_peers ( const char *  label,
const char *  start_peer_label,
const char *  create_label,
uint32_t  num,
struct GNUNET_TESTING_NetjailTopology topology,
unsigned int  additional_connects,
unsigned int  wait_for_connect 

Create command.

labelname for command
start_peer_labelLabel of the cmd to start a peer.
create_labelLabel of the cmd which started the test system.
numNumber globally identifying the node.
topologyThe topology for the test setup.
additional_connectsNumber of additional connects this cmd will wait for not triggered by this cmd.

Definition at line 263 of file transport_api_cmd_connecting_peers.c.

272 struct ConnectPeersState *cps;
273 unsigned int node_additional_connects;
275 node_additional_connects = GNUNET_TESTING_get_additional_connects (num,
276 topology);
279 "global: %u and local: %u additional_connects\n",
281 node_additional_connects);
283 if (0 != node_additional_connects)
284 additional_connects = node_additional_connects;
286 cps = GNUNET_new (struct ConnectPeersState);
288 cps->num = num;
290 cps->topology = topology;
296 return GNUNET_TESTING_command_new (cps,
297 label,
301 &cps->ac);
302 else
303 return GNUNET_TESTING_command_new (cps,
304 label,
308 NULL);
struct GNUNET_TESTING_Command GNUNET_TESTING_command_new(void *cls, const char *label, GNUNET_TESTING_CommandRunRoutine run, GNUNET_TESTING_CommandCleanupRoutine cleanup, GNUNET_TESTING_CommandGetTraits traits, struct GNUNET_TESTING_AsyncContext *ac)
Create a new command.
unsigned int GNUNET_TESTING_get_additional_connects(unsigned int num, struct GNUNET_TESTING_NetjailTopology *topology)
Get the number of unintentional additional connections the node waits for.
Definition: testing.c:2447
#define GNUNET_new(type)
Allocate a struct or union of the given type.
GNUNET_TESTING_notify_connect_cb notify_connect
static void connect_peers_run(void *cls, struct GNUNET_TESTING_Interpreter *is)
The run method of this cmd will connect to peers.
static void * notify_connect(struct GNUNET_TESTING_Interpreter *is, const struct GNUNET_PeerIdentity *peer)
Callback from start peer cmd for signaling a peer got connected.
static void connect_peers_cleanup(void *cls)
The cleanup function of this cmd frees resources the cmd allocated.
enum GNUNET_GenericReturnValue connect_peers_traits(void *cls, const void **ret, const char *trait, unsigned int index)
This function prepares an array with traits.

References ConnectPeersState::ac, ConnectPeersState::additional_connects, connect_peers_cleanup(), connect_peers_run(), connect_peers_traits(), ConnectPeersState::create_label, GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_TESTING_command_new(), GNUNET_TESTING_get_additional_connects(), GNUNET_YES, LOG, ConnectPeersState::notify_connect, notify_connect(), ConnectPeersState::num, ConnectPeersState::start_peer_label, ConnectPeersState::topology, and ConnectPeersState::wait_for_connect.

Here is the call graph for this function: