GNUnet  0.11.x
transport_api_cmd_send_simple.c
Go to the documentation of this file.
1 /*
2  This file is part of GNUnet
3  Copyright (C) 2021 GNUnet e.V.
4 
5  GNUnet is free software: you can redistribute it and/or modify it
6  under the terms of the GNU Affero General Public License as published
7  by the Free Software Foundation, either version 3 of the License,
8  or (at your option) any later version.
9 
10  GNUnet is distributed in the hope that it will be useful, but
11  WITHOUT ANY WARRANTY; without even the implied warranty of
12  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13  Affero General Public License for more details.
14 
15  You should have received a copy of the GNU Affero General Public License
16  along with this program. If not, see <http://www.gnu.org/licenses/>.
17 
18  SPDX-License-Identifier: AGPL3.0-or-later
19  */
20 
26 #include "platform.h"
27 #include "gnunet_util_lib.h"
28 #include "gnunet_testing_ng_lib.h"
30 #include "transport-testing2.h"
31 #include "transport-testing-cmds.h"
32 
36 #define LOG(kind, ...) GNUNET_log (kind, __VA_ARGS__)
37 
43 {
48  uint32_t num;
49 
54  const char *start_peer_label;
55 
60  const char *create_label;
61 
66 };
67 
68 
73 static void
75 {
76  struct SendSimpleState *sss = cls;
77 
78  GNUNET_free (sss);
79 }
80 
81 
82 static int
83 send_simple_cb (void *cls,
84  const struct GNUNET_ShortHashCode *key,
85  void *value)
86 {
87  struct SendSimpleState *sss = cls;
88  struct GNUNET_MQ_Handle *mq = value;
89  struct GNUNET_MQ_Envelope *env;
91 
93  "Sending simple test message\n");
94 
95  env = GNUNET_MQ_msg_extra (test,
96  1000 - sizeof(*test),
98  test->num = htonl (sss->num);
99  memset (&test[1],
100  sss->num,
101  1000 - sizeof(*test));
103  env);
104  return GNUNET_OK;
105 }
106 
107 
112 static void
113 send_simple_run (void *cls,
115 {
116  struct SendSimpleState *sss = cls;
117  const struct GNUNET_CONTAINER_MultiShortmap *connected_peers_map;
118  const struct GNUNET_TESTING_Command *peer1_cmd;
119  // struct GNUNET_ShortHashCode *key = GNUNET_new (struct GNUNET_ShortHashCode);
120  struct GNUNET_HashCode hc;
121  struct GNUNET_TESTING_NodeConnection *node_connections_head;
122  struct GNUNET_PeerIdentity *peer;
123  struct GNUNET_CRYPTO_EddsaPublicKey public_key;
124  uint32_t num;
125  struct GNUNET_TESTING_NodeConnection *pos_connection;
126  const struct GNUNET_TESTING_Command *system_cmd;
127  const struct GNUNET_TESTING_System *tl_system;
128 
130  sss->start_peer_label);
132  &connected_peers_map);
133 
135  sss->create_label);
137  &tl_system);
138 
139  node_connections_head = GNUNET_TESTING_get_connections (sss->num,
140  sss->topology);
141 
144  connected_peers_map, send_simple_cb,
145  sss);
146  /*for (int i = 0; i < 1; i++)
147  {
148  for (pos_connection = node_connections_head; NULL != pos_connection;
149  pos_connection = pos_connection->next)
150  {
151  num = GNUNET_TESTING_calculate_num (pos_connection, sss->topology);
152  peer = GNUNET_TESTING_get_pub_key (num, tl_system);
153  public_key = peer->public_key;
154  GNUNET_CRYPTO_hash (&public_key, sizeof(public_key), &hc);
155 
156  memcpy (key,
157  &hc,
158  sizeof (*key));
159  mq = GNUNET_CONTAINER_multishortmap_get (connected_peers_map,
160  key);
161  env = GNUNET_MQ_msg_extra (test,
162  1000 - sizeof(*test),
163  GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE);
164  test->num = htonl (sss->num);
165  memset (&test[1],
166  sss->num,
167  1000 - sizeof(*test));
168  GNUNET_MQ_send (mq,
169  env);
170  }
171  }*/
172 
173  // GNUNET_free (key);
174 
175 }
176 
177 
190  const char *start_peer_label,
191  const char *create_label,
192  uint32_t num,
194  topology)
195 {
196  struct SendSimpleState *sss;
197 
198  sss = GNUNET_new (struct SendSimpleState);
199  sss->num = num;
201  sss->create_label = create_label;
202  sss->topology = topology;
203 
204  struct GNUNET_TESTING_Command cmd = {
205  .cls = sss,
206  .label = label,
207  .run = &send_simple_run,
208  .cleanup = &send_simple_cleanup
209  };
210 
211  return cmd;
212 }
struct GNUNET_MQ_Handle * mq
Definition: 003.c:5
struct GNUNET_MQ_Envelope * env
Definition: 005.c:1
enum GNUNET_TESTBED_TopologyOption topology
The topology to generate.
static struct GNUNET_NT_InterfaceScanner * is
Network scanner to determine network types.
struct GNUNET_HashCode key
The key used in the DHT.
static char * value
Value of the record to add/remove.
@ GNUNET_OK
Definition: gnunet_common.h:95
struct GNUNET_TESTING_NodeConnection * GNUNET_TESTING_get_connections(unsigned int num, struct GNUNET_TESTING_NetjailTopology *topology)
Get the connections to other nodes for a specific node.
Definition: testing.c:2097
enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait_test_system(const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_TESTING_System **ret)
const struct GNUNET_TESTING_Command * GNUNET_TESTING_interpreter_lookup_command(struct GNUNET_TESTING_Interpreter *is, const char *label)
Lookup command by label.
int GNUNET_CONTAINER_multishortmap_iterate(struct GNUNET_CONTAINER_MultiShortmap *map, GNUNET_CONTAINER_ShortmapIterator it, void *it_cls)
Iterate over all entries in the map.
@ GNUNET_ERROR_TYPE_DEBUG
#define GNUNET_new(type)
Allocate a struct or union of the given type.
#define GNUNET_free(ptr)
Wrapper around free.
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:355
#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:52
Internal representation of the hash map.
Public ECC key (always for curve Ed25519) encoded in a format suitable for network transmission and E...
A 512-bit hashcode.
Handle to a message queue.
Definition: mq.c:86
The identity of the host (wraps the signing key of the peer).
A 256-bit hashcode.
A command to be run by the interpreter.
const char * label
Label for the command.
void * cls
Closure for all commands with command-specific context information.
Global state of the interpreter, used by a command to access information about other commands.
Handle for a system on which GNUnet peers are executed; a system is used for reserving unique paths a...
Definition: testing.c:103
uint32_t num
Monotonically increasing counter throughout the test.
Struct to hold information for callbacks.
const char * create_label
Label of the cmd which started the test system.
uint32_t num
Number globally identifying the node.
struct GNUNET_TESTING_NetjailTopology * topology
The topology we get the connected nodes from.
const char * start_peer_label
Label of the cmd to start a peer.
struct GNUNET_TESTBED_Peer * peer
The peer associated with this model.
enum GNUNET_GenericReturnValue GNUNET_TRANSPORT_get_trait_connected_peers_map(const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_CONTAINER_MultiShortmap **ret)
#define GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE
Message type used by GNUNET_TRANSPORT_TESTING_simple_send().
static void send_simple_run(void *cls, struct GNUNET_TESTING_Interpreter *is)
The run method of this cmd will send a simple message to the connected peers.
static void send_simple_cleanup(void *cls)
The cleanup function of this cmd frees resources the cmd allocated.
struct GNUNET_TESTING_Command GNUNET_TRANSPORT_cmd_send_simple(const char *label, const char *start_peer_label, const char *create_label, uint32_t num, struct GNUNET_TESTING_NetjailTopology *topology)
Create command.
#define LOG(kind,...)
Generic logging shortcut.
static int send_simple_cb(void *cls, const struct GNUNET_ShortHashCode *key, void *value)