GNUnet  0.10.x
gnunet_dht_profiler.c
Go to the documentation of this file.
1 /*
2  This file is part of GNUnet.
3  Copyright (C) 2014, 2018 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 
27 #include "platform.h"
28 #include "gnunet_util_lib.h"
29 #include "gnunet_testbed_service.h"
30 #include "gnunet_dht_service.h"
31 #include "gnunet_constants.h"
32 
33 
34 #define MESSAGE(...) \
35  GNUNET_log (GNUNET_ERROR_TYPE_MESSAGE, __VA_ARGS__)
36 
37 #define DEBUG(...) \
38  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__)
39 
43 static unsigned int put_probability = 100;
44 
48 static const struct GNUNET_CONFIGURATION_Handle *cfg;
49 
53 static char *hosts_file;
54 
58 struct ActiveContext;
59 
63 struct Context
64 {
69 
74 
78  struct ActiveContext *ac;
79 
80 };
81 
82 
87 {
91  struct Context *ctx;
92 
97 
102 
107 
112 
118 
123 
127  unsigned int put_count;
128 
132  uint16_t nrefs;
133 };
134 
135 
139 static struct Context *a_ctx;
140 
144 static struct ActiveContext *a_ac;
145 
150 
155 
160 
165 
169 static unsigned int num_peers;
170 
174 static unsigned int n_active;
175 
179 static unsigned int n_dht;
180 
184 static unsigned long long n_puts;
185 
189 static unsigned int num_puts_per_peer = 1;
190 
194 static unsigned long long n_puts_ok;
195 
199 static unsigned int n_gets;
200 
204 static unsigned int n_gets_ok;
205 
209 static unsigned int n_gets_fail;
210 
214 static unsigned int replication;
215 
220 
225 
229 static uint64_t outgoing_bandwidth;
230 
234 static uint64_t incoming_bandwidth;
235 
240 
245 
249 static unsigned int total_put_path_length;
250 
254 static unsigned int total_get_path_length;
255 
259 static int peers_started = 0;
260 
264 static enum
265 {
266  MODE_PUT = 0,
267 
269 } mode;
270 
271 
275 static int in_shutdown = 0;
276 
277 
281 static void
282 start_profiling (void);
283 
284 
290 static void
291 do_shutdown (void *cls)
292 {
293  struct ActiveContext *ac;
294 
296  if (NULL != a_ctx)
297  {
298  for (unsigned int cnt=0; cnt < num_peers; cnt++)
299  {
300  /* Cleanup active context if this peer is an active peer */
301  ac = a_ctx[cnt].ac;
302  if (NULL != ac)
303  {
304  if (NULL != ac->delay_task)
306  if (NULL != ac->hash)
307  free (ac->hash);
308  if (NULL != ac->dht_put)
310  if (NULL != ac->dht_get)
312  }
313  /* Cleanup testbed operation handle at the last as this operation may
314  contain service connection to DHT */
315  if (NULL != a_ctx[cnt].op)
316  GNUNET_TESTBED_operation_done (a_ctx[cnt].op);
317  }
318  GNUNET_free (a_ctx);
319  a_ctx = NULL;
320  }
321  //FIXME: Should we collect stats only for put/get not for other messages.
322  if (NULL != bandwidth_stats_op)
323  {
324  GNUNET_TESTBED_operation_done (bandwidth_stats_op);
325  bandwidth_stats_op = NULL;
326  }
327  GNUNET_free_non_null (a_ac);
328 }
329 
330 
340 static void
343  const char *emsg)
344 {
345  MESSAGE ("# Outgoing (core) bandwidth: %llu bytes\n",
346  (unsigned long long) outgoing_bandwidth);
347  MESSAGE ("# Incoming (core) bandwidth: %llu bytes\n",
348  (unsigned long long) incoming_bandwidth);
349  fprintf (stderr,
350  "Benchmark done. Collect data via gnunet-statistics, then press ENTER to exit.\n");
351  (void) getchar ();
353 }
354 
355 
367 static int
369  const struct GNUNET_TESTBED_Peer *peer,
370  const char *subsystem,
371  const char *name,
372  uint64_t value,
373  int is_persistent)
374 {
375  static const char *s_sent = "# bytes encrypted";
376  static const char *s_recv = "# bytes decrypted";
377 
378  if (0 == strncmp (s_sent, name, strlen (s_sent)))
380  else if (0 == strncmp(s_recv, name, strlen (s_recv)))
382  return GNUNET_OK;
383 }
384 
385 
386 static void
388 {
389  MESSAGE ("# PUTS started: %llu\n",
390  n_puts);
391  MESSAGE ("# PUTS succeeded: %llu\n",
392  n_puts_ok);
393  MESSAGE ("# GETS made: %u\n",
394  n_gets);
395  MESSAGE ("# GETS succeeded: %u\n",
396  n_gets_ok);
397  MESSAGE ("# GETS failed: %u\n",
398  n_gets_fail);
399  MESSAGE ("# average_put_path_length: %f\n",
401  MESSAGE ("# average_get_path_length: %f\n",
403 
404  if (NULL == testbed_handles)
405  {
406  MESSAGE ("No peers found\n");
407  return;
408  }
409  /* Collect Stats*/
410  bandwidth_stats_op = GNUNET_TESTBED_get_statistics (n_active,
411  testbed_handles,
412  "core",
413  NULL,
416  NULL);
417 }
418 
419 
425 static void
426 cancel_get (void *cls)
427 {
428  struct ActiveContext *ac = cls;
429  struct Context *ctx = ac->ctx;
430 
431  ac->delay_task = NULL;
432  GNUNET_assert (NULL != ac->dht_get);
434  ac->dht_get = NULL;
435  n_gets_fail++;
436  GNUNET_assert (NULL != ctx->op);
438  ctx->op = NULL;
439 
440  /* If profiling is complete, summarize */
441  if (n_active == n_gets_fail + n_gets_ok)
442  {
445  summarize ();
446  }
447 }
448 
449 
467 static void
468 get_iter (void *cls,
469  struct GNUNET_TIME_Absolute exp,
470  const struct GNUNET_HashCode *key,
471  const struct GNUNET_PeerIdentity *get_path,
472  unsigned int get_path_length,
473  const struct GNUNET_PeerIdentity *put_path,
474  unsigned int put_path_length,
475  enum GNUNET_BLOCK_Type type,
476  size_t size, const void *data)
477 {
478  struct ActiveContext *ac = cls;
479  struct ActiveContext *get_ac = ac->get_ac;
480  struct Context *ctx = ac->ctx;
481 
482  /* we found the data we are looking for */
483  DEBUG ("We found a GET request; %u remaining\n",
484  n_gets - (n_gets_fail + n_gets_ok)); //FIXME: It always prints 1.
485  n_gets_ok++;
486  get_ac->nrefs--;
488  ac->dht_get = NULL;
489  if (ac->delay_task != NULL)
491  ac->delay_task = NULL;
492  GNUNET_assert (NULL != ctx->op);
494  ctx->op = NULL;
495 
496  total_put_path_length = total_put_path_length + (double)put_path_length;
497  total_get_path_length = total_get_path_length + (double)get_path_length;
498  DEBUG ("total_put_path_length = %u,put_path \n",
500  /* Summarize if profiling is complete */
501  if (n_active == n_gets_fail + n_gets_ok)
502  {
504  average_get_path_length = (double)total_get_path_length/(double )n_gets_ok;
505  summarize ();
506  }
507 }
508 
509 
515 static void
516 delayed_get (void *cls)
517 {
518  struct ActiveContext *ac = cls;
519  struct ActiveContext *get_ac;
520  unsigned int r;
521 
522  ac->delay_task = NULL;
523  get_ac = NULL;
524  while (1)
525  {
527  n_active);
528  get_ac = &a_ac[r];
529  if (NULL != get_ac->hash)
530  break;
531  }
532  get_ac->nrefs++;
533  ac->get_ac = get_ac;
536  DEBUG ("GET_REQUEST_START key %s \n",
537  GNUNET_h2s(&get_ac->hash[r]));
538  ac->dht_get = GNUNET_DHT_get_start (ac->dht,
540  &get_ac->hash[r],
541  1, /* replication level */
543  NULL,
544  0, /* extended query and size */
545  &get_iter,
546  ac); /* GET iterator and closure */
547  n_gets++;
548 
549  /* schedule the timeout task for GET */
551  &cancel_get,
552  ac);
553 }
554 
555 
563 static void
564 delayed_put (void *cls);
565 
566 
573 static void
574 put_cont (void *cls)
575 {
576  struct ActiveContext *ac = cls;
577 
578  ac->dht_put = NULL;
579  n_puts_ok++;
581  ac);
582 }
583 
584 
592 static void
593 delayed_put (void *cls)
594 {
595  struct ActiveContext *ac = cls;
596  char block[65536];
597  size_t block_size;
598 
599  ac->delay_task = NULL;
600  if (0 == ac->put_count)
601  {
602  struct Context *ctx = ac->ctx;
604 
605  GNUNET_assert (NULL != ctx);
606  op = ctx->op;
607  ctx->op = NULL;
609  return;
610  }
611 
612 
613  /* Generate and DHT PUT some random data */
614  block_size = 16; /* minimum */
615  /* make random payload, reserve 512 - 16 bytes for DHT headers */
619  block,
620  block_size);
621  ac->put_count--;
622  GNUNET_CRYPTO_hash (block,
623  block_size,
624  &ac->hash[ac->put_count]);
625  DEBUG ("PUT_REQUEST_START key %s\n",
626  GNUNET_h2s (&ac->hash[ac->put_count]));
627  ac->dht_put = GNUNET_DHT_put (ac->dht,
628  &ac->hash[ac->put_count],
629  replication,
632  block_size,
633  block,
634  GNUNET_TIME_UNIT_FOREVER_ABS, /* expiration time */
635  &put_cont,
636  ac); /* continuation and its closure */
637  n_puts++;
638 }
639 
640 
650 static void
651 dht_connected (void *cls,
653  void *ca_result,
654  const char *emsg)
655 {
656  struct ActiveContext *ac = cls;
657  struct Context *ctx = ac->ctx;
658 
659  GNUNET_assert (NULL != ctx); //FIXME: Fails
660  GNUNET_assert (NULL != ctx->op);
661  GNUNET_assert (ctx->op == op);
662  ac->dht = (struct GNUNET_DHT_Handle *) ca_result;
663  if (NULL != emsg)
664  {
666  "Connection to DHT service failed: %s\n",
667  emsg);
668  GNUNET_TESTBED_operation_done (ctx->op); /* Calls dht_disconnect() */
669  ctx->op = NULL;
670  return;
671  }
672  switch (mode)
673  {
674  case MODE_PUT:
675  {
676  struct GNUNET_TIME_Relative peer_delay_put;
677 
678  peer_delay_put.rel_value_us =
682  ac->hash = calloc (ac->put_count,
683  sizeof (struct GNUNET_HashCode));
684  if (NULL == ac->hash)
685  {
687  "calloc");
689  return;
690  }
691  ac->delay_task = GNUNET_SCHEDULER_add_delayed (peer_delay_put,
692  &delayed_put,
693  ac);
694  break;
695  }
696  case MODE_GET:
697  {
698  struct GNUNET_TIME_Relative peer_delay_get;
699 
700  peer_delay_get.rel_value_us =
704  ac->delay_task = GNUNET_SCHEDULER_add_delayed (peer_delay_get,
705  &delayed_get,
706  ac);
707  break;
708  }
709  }
710 }
711 
712 
722 static void *
723 dht_connect (void *cls,
724  const struct GNUNET_CONFIGURATION_Handle *cfg)
725 {
726  n_dht++;
727  return GNUNET_DHT_connect (cfg,
728  10);
729 }
730 
731 
739 static void
740 dht_disconnect (void *cls,
741  void *op_result)
742 {
743  struct ActiveContext *ac = cls;
744 
745  GNUNET_assert (NULL != ac->dht);
746  GNUNET_assert (ac->dht == op_result);
748  ac->dht = NULL;
749  n_dht--;
750  if (0 != n_dht)
751  return;
752  if (GNUNET_YES == in_shutdown)
753  return;
754  switch (mode)
755  {
756  case MODE_PUT:
757  if (n_puts_ok != ((unsigned long long) n_active) * num_puts_per_peer)
758  return;
759  /* Start GETs if all PUTs have been made */
760  mode = MODE_GET;
761  start_profiling ();
762  return;
763  case MODE_GET:
764  if ((n_gets_ok + n_gets_fail) != n_active)
765  return;
766  break;
767  }
768 }
769 
770 
774 static void
776 {
777  struct Context *ctx;
778 
779  DEBUG ("GNUNET_TESTBED_service_connect\n");
781  for (unsigned int i = 0; i < n_active; i++)
782  {
783  struct ActiveContext *ac = &a_ac[i];
784  GNUNET_assert (NULL != (ctx = ac->ctx));
785  GNUNET_assert (NULL == ctx->op);
787  ctx->peer,
788  "dht",
789  &dht_connected, ac,
790  &dht_connect,
792  ac);
793  }
794 }
795 
796 
805 static void
806 service_started (void *cls,
808  const char *emsg)
809 {
810  struct Context *ctx = cls;
811 
812  GNUNET_assert (NULL != ctx);
813  GNUNET_assert (NULL != ctx->op);
815  ctx->op = NULL;
816  peers_started++;
817  DEBUG ("Peers Started = %d; num_peers = %d \n",
819  num_peers);
820  if (peers_started == num_peers)
821  start_profiling ();
822 }
823 
824 
836 static void
837 test_run (void *cls,
838  struct GNUNET_TESTBED_RunHandle *h,
839  unsigned int num_peers,
840  struct GNUNET_TESTBED_Peer **peers,
841  unsigned int links_succeeded,
842  unsigned int links_failed)
843 {
844  unsigned int ac_cnt;
845 
846  testbed_handles = peers;
847  if (NULL == peers)
848  {
849  /* exit */
850  GNUNET_assert (0);
851  }
852  MESSAGE ("%u peers started, %u/%u links up\n",
853  num_peers,
854  links_succeeded,
855  links_succeeded + links_failed);
856  a_ctx = GNUNET_new_array (num_peers,
857  struct Context);
858  /* select the peers which actively participate in profiling */
859  n_active = num_peers * put_probability / 100;
860  if (0 == n_active)
861  {
863  GNUNET_free (a_ctx);
864  a_ctx = NULL;
865  return;
866  }
867 
868  a_ac = GNUNET_new_array (n_active,
869  struct ActiveContext);
870  ac_cnt = 0;
871  for (unsigned int cnt = 0; cnt < num_peers && ac_cnt < n_active; cnt++)
872  {
874  100) >= put_probability)
875  continue;
876 
877  a_ctx[cnt].ac = &a_ac[ac_cnt];
878  a_ac[ac_cnt].ctx = &a_ctx[cnt];
879  ac_cnt++;
880  }
881  n_active = ac_cnt;
882 
883  /* start DHT service on all peers */
884  for (unsigned int cnt = 0; cnt < num_peers; cnt++)
885  {
886  a_ctx[cnt].peer = peers[cnt];
887  a_ctx[cnt].op = GNUNET_TESTBED_peer_manage_service (&a_ctx[cnt],
888  peers[cnt],
889  "dht",
891  &a_ctx[cnt],
892  1);
893  }
894 }
895 
896 
905 static void
906 run (void *cls,
907  char *const *args,
908  const char *cfgfile,
909  const struct GNUNET_CONFIGURATION_Handle *config)
910 {
911  uint64_t event_mask;
912 
913  if (0 == num_peers)
914  {
916  _("Exiting as the number of peers is %u\n"),
917  num_peers);
918  return;
919  }
920  cfg = config;
921  event_mask = 0;
923  cfg,
924  num_peers,
925  event_mask,
926  NULL,
927  NULL,
928  &test_run,
929  NULL);
931  NULL);
932 }
933 
934 
940 int
941 main (int argc,
942  char *const *argv)
943 {
944  int rc;
945  struct GNUNET_GETOPT_CommandLineOption options[] = {
947  "peers",
948  "COUNT",
949  gettext_noop ("number of peers to start"),
950  &num_peers),
952  "peer-put-count",
953  "COUNT",
954  gettext_noop ("number of PUTs to perform per peer"),
957  "hosts",
958  "FILENAME",
959  gettext_noop ("name of the file with the login information for the testbed"),
960  &hosts_file),
962  "delay",
963  "DELAY",
964  gettext_noop ("delay between rounds for collecting statistics (default: 30 sec)"),
965  &delay_stats),
967  "PUT-delay",
968  "DELAY",
969  gettext_noop ("delay to start doing PUTs (default: 1 sec)"),
970  &delay_put),
972  "GET-delay",
973  "DELAY",
974  gettext_noop ("delay to start doing GETs (default: 5 min)"),
975  &delay_get),
977  "replication",
978  "DEGREE",
979  gettext_noop ("replication degree for DHT PUTs"),
980  &replication),
982  "random-chance",
983  "PROBABILITY",
984  gettext_noop ("chance that a peer is selected at random for PUTs"),
985  &put_probability),
987  "timeout",
988  "TIMEOUT",
989  gettext_noop ("timeout for DHT PUT and GET requests (default: 1 min)"),
990  &timeout),
992  };
993 
994  if (GNUNET_OK !=
995  GNUNET_STRINGS_get_utf8_args (argc, argv,
996  &argc, &argv))
997  return 2;
998  /* set default delays */
1003  replication = 1; /* default replication */
1004  rc = 0;
1005  if (GNUNET_OK !=
1006  GNUNET_PROGRAM_run (argc,
1007  argv,
1008  "gnunet-dht-profiler",
1009  gettext_noop ("Measure quality and performance of the DHT service."),
1010  options,
1011  &run,
1012  NULL))
1013  rc = 1;
1014  return rc;
1015 }
struct GNUNET_GETOPT_CommandLineOption GNUNET_GETOPT_option_relative_time(char shortName, const char *name, const char *argumentHelp, const char *description, struct GNUNET_TIME_Relative *val)
Allow user to specify a struct GNUNET_TIME_Relative (using human-readable "fancy" time)...
Context to hold data of peer.
static void delayed_put(void *cls)
Task to do DHT PUTs.
static void dht_disconnect(void *cls, void *op_result)
Adapter function called to destroy a connection to a service.
We should keep track of the route that the message took in the P2P network.
struct GNUNET_TESTBED_Operation * GNUNET_TESTBED_get_statistics(unsigned int num_peers, struct GNUNET_TESTBED_Peer **peers, const char *subsystem, const char *name, GNUNET_TESTBED_StatisticsIterator proc, GNUNET_TESTBED_OperationCompletionCallback cont, void *cls)
Convenience method that iterates over all (running) peers and retrieves all statistics from each peer...
static char * subsystem
Set to subsystem that we&#39;re going to get stats for (or NULL for all).
static unsigned int put_probability
Number of peers which should perform a PUT out of 100 peers.
uint64_t rel_value_us
The actual value.
void GNUNET_DHT_put_cancel(struct GNUNET_DHT_PutHandle *ph)
Cancels a DHT PUT operation.
Definition: dht_api.c:1040
static uint64_t incoming_bandwidth
Total number of messages received by peer.
static unsigned int n_gets_ok
Number of DHT GETs succeeded.
static unsigned int num_peers
Number of peers.
GNUNET_BLOCK_Type
Blocks in the datastore and the datacache must have a unique type.
static void bandwidth_stats_cont(void *cls, struct GNUNET_TESTBED_Operation *op, const char *emsg)
Stats callback.
uint64_t GNUNET_CRYPTO_random_u64(enum GNUNET_CRYPTO_Quality mode, uint64_t max)
Random on unsigned 64-bit values.
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_shutdown(GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run on shutdown, that is when a CTRL-C signal is received, or when GNUNET_SCHEDULER_shutdown() is being invoked.
Definition: scheduler.c:1293
static void * dht_connect(void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg)
Connect to DHT service and return the DHT client handler.
int GNUNET_STRINGS_get_utf8_args(int argc, char *const *argv, int *u8argc, char *const **u8argv)
Returns utf-8 encoded arguments.
Definition: strings.c:1521
uint32_t GNUNET_CRYPTO_random_u32(enum GNUNET_CRYPTO_Quality mode, uint32_t i)
Produce a random value.
struct GNUNET_HashCode * hash
The hashes of the values stored via this activity context.
static unsigned int n_dht
Number of DHT service connections we currently have.
unsigned int put_count
How many puts should we still issue?
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
Context for a peer which actively does DHT PUT/GET.
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:244
#define GNUNET_TIME_UNIT_SECONDS
One second.
static unsigned int num_puts_per_peer
Number of DHT PUTs to be made per peer.
static void get_iter(void *cls, struct GNUNET_TIME_Absolute exp, const struct GNUNET_HashCode *key, const struct GNUNET_PeerIdentity *get_path, unsigned int get_path_length, const struct GNUNET_PeerIdentity *put_path, unsigned int put_path_length, enum GNUNET_BLOCK_Type type, size_t size, const void *data)
Iterator called on each result obtained for a DHT operation that expects a reply. ...
static struct Context * a_ctx
An array of contexts.
const char * GNUNET_h2s(const struct GNUNET_HashCode *hc)
Convert a hash value to a string (for printing debug messages).
#define GNUNET_OK
Named constants for return values.
Definition: gnunet_common.h:78
#define DEBUG(...)
#define GNUNET_free_non_null(ptr)
Free the memory pointed to by ptr if ptr is not NULL.
Definition of a command line option.
static int bandwidth_stats_iterator(void *cls, const struct GNUNET_TESTBED_Peer *peer, const char *subsystem, const char *name, uint64_t value, int is_persistent)
Process statistic values.
static void delayed_get(void *cls)
Task to do DHT GETs.
static void put_cont(void *cls)
Conclude individual PUT operation, schedule the next one.
void GNUNET_SCHEDULER_shutdown(void)
Request the shutdown of a scheduler.
Definition: scheduler.c:524
#define GNUNET_CONSTANTS_MAX_ENCRYPTED_MESSAGE_SIZE
What is the maximum size for encrypted messages? Note that this number imposes a clear limit on the m...
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur...
static void service_started(void *cls, struct GNUNET_TESTBED_Operation *op, const char *emsg)
Callback called when DHT service on the peer is started.
struct GNUNET_GETOPT_CommandLineOption GNUNET_GETOPT_OPTION_END
Definition: 002.c:13
static struct GNUNET_ARM_Handle * h
Connection with ARM.
Definition: gnunet-arm.c:94
static struct GNUNET_DNSSTUB_Context * ctx
Context for DNS resolution.
Connection to the DHT service.
Definition: dht_api.c:205
Opaque handle to an abstract operation to be executed by the testing framework.
struct GNUNET_GETOPT_CommandLineOption GNUNET_GETOPT_option_string(char shortName, const char *name, const char *argumentHelp, const char *description, char **str)
Allow user to specify a string.
#define GNUNET_TIME_UNIT_FOREVER_ABS
Constant used to specify "forever".
#define _(String)
GNU gettext support macro.
Definition: platform.h:208
struct GNUNET_DHT_Handle * dht
Handler to the DHT service.
static unsigned int total_put_path_length
Total put path length across all peers.
static unsigned int replication
Replication degree.
#define GNUNET_log_strerror(level, cmd)
Log an error message at log-level &#39;level&#39; that indicates a failure of the command &#39;cmd&#39; with the mess...
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 unsigned int n_active
Number of active peers.
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_delayed(struct GNUNET_TIME_Relative delay, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay.
Definition: scheduler.c:1246
static char * value
Value of the record to add/remove.
void GNUNET_CRYPTO_hash(const void *block, size_t size, struct GNUNET_HashCode *ret)
Compute hash of a given block.
Definition: crypto_hash.c:44
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_now(GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run as soon as possible.
Definition: scheduler.c:1273
static struct GNUNET_TIME_Relative delay_get
The delay to start puts.
static void summarize()
#define GNUNET_new_array(n, type)
Allocate a size n array with structs or unions of the given type.
static struct GNUNET_TIME_Relative delay_put
The delay to start puts.
static const struct GNUNET_CONFIGURATION_Handle * config
struct GNUNET_TIME_Relative GNUNET_TIME_relative_multiply(struct GNUNET_TIME_Relative rel, unsigned long long factor)
Multiply relative time by a given factor.
Definition: time.c:439
static double average_put_path_length
Average number of hops taken to do put.
static void dht_connected(void *cls, struct GNUNET_TESTBED_Operation *op, void *ca_result, const char *emsg)
Connection to DHT has been established.
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:2020
A 512-bit hashcode.
void GNUNET_TESTBED_run(const char *host_filename, const struct GNUNET_CONFIGURATION_Handle *cfg, 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 testbed with a single call.
struct ActiveContext * ac
Active context; NULL if this peer is not an active peer.
struct GNUNET_TESTBED_Peer * peer
The testbed peer this context belongs to.
void GNUNET_DHT_get_stop(struct GNUNET_DHT_GetHandle *get_handle)
Stop async DHT-get.
Definition: dht_api.c:1160
static uint64_t outgoing_bandwidth
Total number of messages sent by peer.
struct Context * ctx
The linked peer context.
static unsigned int n_gets
Number of DHT GETs made.
uint64_t event_mask
Global event mask for all testbed events.
static struct GNUNET_TESTBED_Operation * bandwidth_stats_op
Testbed Operation (to get stats).
struct GNUNET_HashCode key
The key used in the DHT.
struct GNUNET_DHT_PutHandle * GNUNET_DHT_put(struct GNUNET_DHT_Handle *handle, const struct GNUNET_HashCode *key, uint32_t desired_replication_level, enum GNUNET_DHT_RouteOption options, enum GNUNET_BLOCK_Type type, size_t size, const void *data, struct GNUNET_TIME_Absolute exp, GNUNET_SCHEDULER_TaskCallback cont, void *cont_cls)
Perform a PUT operation storing data in the DHT.
Definition: dht_api.c:971
static unsigned int size
Size of the "table".
Definition: peer.c:67
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:895
static unsigned long long n_puts
Number of DHT PUTs made.
const char * name
void GNUNET_DHT_disconnect(struct GNUNET_DHT_Handle *handle)
Shutdown connection with the DHT service.
Definition: dht_api.c:923
static struct GNUNET_TESTBED_Peer ** testbed_handles
Testbed peer handles.
static struct GNUNET_TIME_Relative timeout
The timeout for GET and PUT.
Handle to a GET request.
Definition: dht_api.c:80
static int in_shutdown
Are we shutting down.
static const struct GNUNET_CONFIGURATION_Handle * cfg
Configuration.
static void start_profiling(void)
Connect to DHT services of active peers.
The identity of the host (wraps the signing key of the peer).
Handle to a PUT request.
Definition: dht_api.c:43
static char * hosts_file
Name of the file with the hosts to run the test over.
configuration data
Definition: configuration.c:85
Block for testing.
uint16_t nrefs
The number of peers currently doing GET on our data.
#define MESSAGE(...)
struct GNUNET_DHT_GetHandle * GNUNET_DHT_get_start(struct GNUNET_DHT_Handle *handle, enum GNUNET_BLOCK_Type type, const struct GNUNET_HashCode *key, uint32_t desired_replication_level, enum GNUNET_DHT_RouteOption options, const void *xquery, size_t xquery_size, GNUNET_DHT_GetIterator iter, void *iter_cls)
Perform an asynchronous GET operation on the DHT identified.
Definition: dht_api.c:1072
struct ActiveContext * get_ac
The active context used for our DHT GET.
static struct CadetPeer * peers
Operation to get peer ids.
struct GNUNET_DHT_GetHandle * dht_get
The get handle.
#define GNUNET_log(kind,...)
static void do_shutdown(void *cls)
Shutdown task.
Entry in list of pending tasks.
Definition: scheduler.c:134
static int peers_started
Counter to keep track of peers added to peer_context lists.
static void cancel_get(void *cls)
Task to cancel DHT GET.
static unsigned long long n_puts_ok
Number of DHT PUTs succeeded.
int main(int argc, char *const *argv)
Main function.
void GNUNET_CRYPTO_random_block(enum GNUNET_CRYPTO_Quality mode, void *buffer, size_t length)
Fill block with a random values.
static struct GNUNET_TIME_Relative delay_stats
The delay between rounds for collecting statistics.
int GNUNET_PROGRAM_run(int argc, char *const *argv, const char *binaryName, const char *binaryHelp, const struct GNUNET_GETOPT_CommandLineOption *options, GNUNET_PROGRAM_Main task, void *task_cls)
Run a standard GNUnet command startup sequence (initialize loggers and configuration, parse options).
Definition: program.c:361
static double average_get_path_length
Average number of hops taken to do get.
enum GNUNET_TESTBED_UnderlayLinkModelType type
the type of this model
Time for absolute times used by GNUnet, in microseconds.
#define GNUNET_YES
Definition: gnunet_common.h:80
static void run(void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *config)
Main function that will be run by the scheduler.
struct GNUNET_SCHEDULER_Task * delay_task
Delay task.
struct GNUNET_TESTBED_Operation * op
Testbed operation acting on this peer.
struct GNUNET_GETOPT_CommandLineOption GNUNET_GETOPT_option_uint(char shortName, const char *name, const char *argumentHelp, const char *description, unsigned int *val)
Allow user to specify an unsigned int.
struct GNUNET_DHT_PutHandle * dht_put
The put handle.
A peer controlled by the testing framework.
struct GNUNET_TESTBED_Operation * GNUNET_TESTBED_peer_manage_service(void *op_cls, struct GNUNET_TESTBED_Peer *peer, const char *service_name, GNUNET_TESTBED_OperationCompletionCallback cb, void *cb_cls, unsigned int start)
Start or stop given service at a peer.
static unsigned int n_gets_fail
Number of DHT GETs succeeded.
uint32_t data
The data value.
static struct ActiveContext * a_ac
Array of active peers.
static unsigned int total_get_path_length
Total get path length across all peers.
No good quality of the operation is needed (i.e., random numbers can be pseudo-random).
static enum @11 mode
Should we do a PUT (mode = 0) or GET (mode = 1);.
#define GNUNET_free(ptr)
Wrapper around free.
Time for relative time used by GNUnet, in microseconds.
#define gettext_noop(String)
Definition: gettext.h:69
static void 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)
Signature of a main function for a testcase.
void * GNUNET_SCHEDULER_cancel(struct GNUNET_SCHEDULER_Task *task)
Cancel the task with the specified identifier.
Definition: scheduler.c:965