GNUnet  0.17.6
dht_test_lib.c
Go to the documentation of this file.
1 /*
2  This file is part of GNUnet.
3  Copyright (C) 2012 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  */
25 #include "platform.h"
26 #include "dht_test_lib.h"
27 
32 {
37 
42 
47 
52 
56  void *app_main_cls;
57 
61  unsigned int num_peers;
62 };
63 
64 
75 static void *
77  const struct GNUNET_CONFIGURATION_Handle *cfg)
78 {
79  return GNUNET_DHT_connect (cfg, 16);
80 }
81 
82 
90 static void
92  void *op_result)
93 {
95 
97 }
98 
99 
109 static void
110 dht_connect_cb (void *cls,
112  void *ca_result,
113  const char *emsg)
114 {
115  struct GNUNET_DHT_TEST_Context *ctx = cls;
116 
117  if (NULL != emsg)
118  {
119  fprintf (stderr,
120  "Failed to connect to DHT service: %s\n",
121  emsg);
123  return;
124  }
125  for (unsigned int i = 0; i < ctx->num_peers; i++)
126  if (op == ctx->ops[i])
127  ctx->dhts[i] = ca_result;
128  for (unsigned int i = 0; i < ctx->num_peers; i++)
129  if (NULL == ctx->dhts[i])
130  return;
131  /* still some DHT connections missing */
132  /* all DHT connections ready! */
133  ctx->app_main (ctx->app_main_cls,
134  ctx,
135  ctx->num_peers,
136  ctx->peers,
137  ctx->dhts);
138 }
139 
140 
141 void
143 {
144  for (unsigned int i = 0; i < ctx->num_peers; i++)
146  GNUNET_free (ctx->ops);
147  GNUNET_free (ctx->dhts);
148  GNUNET_free (ctx);
150 }
151 
152 
153 static void
154 dht_test_run (void *cls,
155  struct GNUNET_TESTBED_RunHandle *h,
156  unsigned int num_peers,
157  struct GNUNET_TESTBED_Peer **peers,
158  unsigned int links_succeeded,
159  unsigned int links_failed)
160 {
161  struct GNUNET_DHT_TEST_Context *ctx = cls;
162 
163  GNUNET_assert (num_peers == ctx->num_peers);
164  ctx->peers = peers;
165  for (unsigned int i = 0; i < num_peers; i++)
167  peers[i],
168  "dht",
170  ctx,
173  ctx);
174 }
175 
176 
177 void
178 GNUNET_DHT_TEST_run (const char *testname,
179  const char *cfgname,
180  unsigned int num_peers,
182  void *tmain_cls)
183 {
185 
187  ctx->num_peers = num_peers;
189  struct GNUNET_TESTBED_Operation *);
190  ctx->dhts = GNUNET_new_array (num_peers,
191  struct GNUNET_DHT_Handle *);
192  ctx->app_main = tmain;
193  ctx->app_main_cls = tmain_cls;
194  (void) GNUNET_TESTBED_test_run (testname,
195  cfgname,
196  num_peers,
197  0LL, NULL, NULL,
198  &dht_test_run, ctx);
199 }
200 
201 
202 /* end of dht_test_lib.c */
static void * dht_connect_adapter(void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg)
Adapter function called to establish a connection to the DHT service.
Definition: dht_test_lib.c:76
static void dht_test_run(void *cls, struct GNUNET_TESTBED_RunHandle *h, unsigned int num_peers, struct GNUNET_TESTBED_Peer **peers, unsigned int links_succeeded, unsigned int links_failed)
Definition: dht_test_lib.c:154
static void dht_disconnect_adapter(void *cls, void *op_result)
Adapter function called to destroy a connection to the DHT service.
Definition: dht_test_lib.c:91
void GNUNET_DHT_TEST_cleanup(struct GNUNET_DHT_TEST_Context *ctx)
Clean up the testbed.
Definition: dht_test_lib.c:142
static void dht_connect_cb(void *cls, struct GNUNET_TESTBED_Operation *op, void *ca_result, const char *emsg)
Callback to be called when a service connect operation is completed.
Definition: dht_test_lib.c:110
void GNUNET_DHT_TEST_run(const char *testname, const char *cfgname, unsigned int num_peers, GNUNET_DHT_TEST_AppMain tmain, void *tmain_cls)
Run a test using the given name, configuration file and number of peers.
Definition: dht_test_lib.c:178
library for writing DHT tests
void(* GNUNET_DHT_TEST_AppMain)(void *cls, struct GNUNET_DHT_TEST_Context *ctx, unsigned int num_peers, struct GNUNET_TESTBED_Peer **peers, struct GNUNET_DHT_Handle **dhts)
Main function of a DHT test.
Definition: dht_test_lib.h:54
static const struct GNUNET_CONFIGURATION_Handle * cfg
Configuration we are using.
Definition: gnunet-abd.c:36
static struct GNUNET_ARM_Operation * op
Current operation.
Definition: gnunet-arm.c:144
static struct GNUNET_ARM_Handle * h
Connection with ARM.
Definition: gnunet-arm.c:99
static void tmain(void *cls, struct GNUNET_CADET_TEST_Context *ctx, unsigned int num_peers, struct GNUNET_TESTBED_Peer **testbed_peers, struct GNUNET_CADET_Handle **cadetes)
test main: start test when all peers are connected
static struct CadetPeer * peers
Operation to get peer ids.
static unsigned int num_peers
static struct GNUNET_DHT_Handle * dht
Handle to the DHT.
static struct GNUNET_DNSSTUB_Context * ctx
Context for DNS resolution.
struct GNUNET_DHT_Handle * GNUNET_DHT_connect(const struct GNUNET_CONFIGURATION_Handle *cfg, unsigned int ht_len)
Initialize the connection with the DHT service.
Definition: dht_api.c:1039
void GNUNET_DHT_disconnect(struct GNUNET_DHT_Handle *handle)
Shutdown connection with the DHT service.
Definition: dht_api.c:1062
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
#define GNUNET_new(type)
Allocate a struct or union of the given type.
#define GNUNET_new_array(n, type)
Allocate a size n array with structs or unions of the given type.
#define GNUNET_free(ptr)
Wrapper around free.
void GNUNET_SCHEDULER_shutdown(void)
Request the shutdown of a scheduler.
Definition: scheduler.c:533
void GNUNET_TESTBED_operation_done(struct GNUNET_TESTBED_Operation *operation)
This function is used to signal that the event information (struct GNUNET_TESTBED_EventInformation) f...
Definition: testbed_api.c:2045
int GNUNET_TESTBED_test_run(const char *testname, const char *cfg_filename, unsigned int num_peers, uint64_t event_mask, GNUNET_TESTBED_ControllerCallback cc, void *cc_cls, GNUNET_TESTBED_TestMaster test_master, void *test_master_cls)
Convenience method for running a "simple" test on the local system with a single call from 'main'.
struct GNUNET_TESTBED_Operation * GNUNET_TESTBED_service_connect(void *op_cls, struct GNUNET_TESTBED_Peer *peer, const char *service_name, GNUNET_TESTBED_ServiceConnectCompletionCallback cb, void *cb_cls, GNUNET_TESTBED_ConnectAdapter ca, GNUNET_TESTBED_DisconnectAdapter da, void *cada_cls)
Connect to a service offered by the given peer.
static int op_result(struct GNUNET_OP_Handle *h, uint64_t op_id, int64_t result_code, const void *data, uint16_t data_size, void **ctx, uint8_t cancel)
Remove an operation, and call its result callback (unless it was cancelled).
Definition: op.c:245
Connection to the DHT service.
Definition: dht_api.c:237
Test context for a DHT Test.
Definition: dht_test_lib.c:32
struct GNUNET_TESTBED_Operation ** ops
Operation associated with the connection to the DHT.
Definition: dht_test_lib.c:46
GNUNET_DHT_TEST_AppMain app_main
Main function of the test to run once all DHTs are available.
Definition: dht_test_lib.c:51
struct GNUNET_DHT_Handle ** dhts
Array of handles to the DHT for each peer.
Definition: dht_test_lib.c:41
void * app_main_cls
Closure for 'app_main'.
Definition: dht_test_lib.c:56
unsigned int num_peers
Number of peers running, size of the arrays above.
Definition: dht_test_lib.c:61
struct GNUNET_TESTBED_Peer ** peers
Array of running peers.
Definition: dht_test_lib.c:36
Opaque handle to an abstract operation to be executed by the testing framework.
A peer controlled by the testing framework.