GNUnet  0.19.5
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 with mq %p\n",
94  mq);
95 
96  env = GNUNET_MQ_msg_extra (test,
97  1000 - sizeof(*test),
99  test->num = htonl (sss->num);
100  memset (&test[1],
101  sss->num,
102  1000 - sizeof(*test));
104  env);
105  return GNUNET_OK;
106 }
107 
108 
113 static void
114 send_simple_run (void *cls,
116 {
117  struct SendSimpleState *sss = cls;
118  const struct GNUNET_CONTAINER_MultiShortmap *connected_peers_map;
119  const struct GNUNET_TESTING_Command *peer1_cmd;
120  const struct GNUNET_TESTING_Command *system_cmd;
121  const struct GNUNET_TESTING_System *tl_system;
122 
124  sss->start_peer_label);
126  &connected_peers_map);
127 
129  sss->create_label);
131  &tl_system);
132 
135  connected_peers_map, send_simple_cb,
136  sss);
137 }
138 
139 
142  const char *start_peer_label,
143  const char *create_label,
144  uint32_t num,
146  topology)
147 {
148  struct SendSimpleState *sss;
149 
150  sss = GNUNET_new (struct SendSimpleState);
151  sss->num = num;
153  sss->create_label = create_label;
154  sss->topology = topology;
155 
156  return GNUNET_TESTING_command_new (sss,
157  label,
160  NULL,
161  NULL);
162 }
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.
struct GNUNET_TESTING_Interpreter * is
struct GNUNET_HashCode key
The key used in the DHT.
static char * value
Value of the record to add/remove.
enum GNUNET_GenericReturnValue GNUNET_TESTING_get_trait_test_system(const struct GNUNET_TESTING_Command *cmd, const struct GNUNET_TESTING_System **ret)
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.
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_OK
@ 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:304
#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
Internal representation of the hash map.
Handle to a message queue.
Definition: mq.c:87
A 256-bit hashcode.
A command to be run by the interpreter.
char label[127+1]
Label for the command.
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:122
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.
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)