GNUnet  0.11.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 
86 {
90  struct Context *ctx;
91 
96 
101 
106 
111 
117 
122 
126  unsigned int put_count;
127 
131  uint16_t nrefs;
132 };
133 
134 
138 static struct Context *a_ctx;
139 
143 static struct ActiveContext *a_ac;
144 
149 
154 
159 
164 
168 static unsigned int num_peers;
169 
173 static unsigned int n_active;
174 
178 static unsigned int n_dht;
179 
183 static unsigned long long n_puts;
184 
188 static unsigned int num_puts_per_peer = 1;
189 
193 static unsigned long long n_puts_ok;
194 
198 static unsigned int n_gets;
199 
203 static unsigned int n_gets_ok;
204 
208 static unsigned int n_gets_fail;
209 
213 static unsigned int replication;
214 
219 
224 
228 static uint64_t outgoing_bandwidth;
229 
233 static uint64_t incoming_bandwidth;
234 
239 
244 
248 static unsigned int total_put_path_length;
249 
253 static unsigned int total_get_path_length;
254 
258 static int peers_started = 0;
259 
263 static enum
264 {
265  MODE_PUT = 0,
266 
268 } mode;
269 
270 
274 static int in_shutdown = 0;
275 
276 
280 static void
281 start_profiling (void);
282 
283 
289 static void
290 do_shutdown (void *cls)
291 {
292  struct ActiveContext *ac;
293 
295  if (NULL != a_ctx)
296  {
297  for (unsigned int cnt = 0; cnt < num_peers; cnt++)
298  {
299  /* Cleanup active context if this peer is an active peer */
300  ac = a_ctx[cnt].ac;
301  if (NULL != ac)
302  {
303  if (NULL != ac->delay_task)
305  if (NULL != ac->hash)
306  free (ac->hash);
307  if (NULL != ac->dht_put)
309  if (NULL != ac->dht_get)
311  }
312  /* Cleanup testbed operation handle at the last as this operation may
313  contain service connection to DHT */
314  if (NULL != a_ctx[cnt].op)
315  GNUNET_TESTBED_operation_done (a_ctx[cnt].op);
316  }
317  GNUNET_free (a_ctx);
318  a_ctx = NULL;
319  }
320  // FIXME: Should we collect stats only for put/get not for other messages.
321  if (NULL != bandwidth_stats_op)
322  {
323  GNUNET_TESTBED_operation_done (bandwidth_stats_op);
324  bandwidth_stats_op = NULL;
325  }
326  GNUNET_free_non_null (a_ac);
327 }
328 
329 
339 static void
342  const char *emsg)
343 {
344  MESSAGE ("# Outgoing (core) bandwidth: %llu bytes\n",
345  (unsigned long long) outgoing_bandwidth);
346  MESSAGE ("# Incoming (core) bandwidth: %llu bytes\n",
347  (unsigned long long) incoming_bandwidth);
348  fprintf (stderr,
349  "Benchmark done. Collect data via gnunet-statistics, then press ENTER to exit.\n");
350  (void) getchar ();
352 }
353 
354 
366 static int
368  const struct GNUNET_TESTBED_Peer *peer,
369  const char *subsystem,
370  const char *name,
371  uint64_t value,
372  int is_persistent)
373 {
374  static const char *s_sent = "# bytes encrypted";
375  static const char *s_recv = "# bytes decrypted";
376 
377  if (0 == strncmp (s_sent, name, strlen (s_sent)))
379  else if (0 == strncmp (s_recv, name, strlen (s_recv)))
381  return GNUNET_OK;
382 }
383 
384 
385 static void
387 {
388  MESSAGE ("# PUTS started: %llu\n",
389  n_puts);
390  MESSAGE ("# PUTS succeeded: %llu\n",
391  n_puts_ok);
392  MESSAGE ("# GETS made: %u\n",
393  n_gets);
394  MESSAGE ("# GETS succeeded: %u\n",
395  n_gets_ok);
396  MESSAGE ("# GETS failed: %u\n",
397  n_gets_fail);
398  MESSAGE ("# average_put_path_length: %f\n",
400  MESSAGE ("# average_get_path_length: %f\n",
402 
403  if (NULL == testbed_handles)
404  {
405  MESSAGE ("No peers found\n");
406  return;
407  }
408  /* Collect Stats*/
409  bandwidth_stats_op = GNUNET_TESTBED_get_statistics (n_active,
410  testbed_handles,
411  "core",
412  NULL,
415  NULL);
416 }
417 
418 
424 static void
425 cancel_get (void *cls)
426 {
427  struct ActiveContext *ac = cls;
428  struct Context *ctx = ac->ctx;
429 
430  ac->delay_task = NULL;
431  GNUNET_assert (NULL != ac->dht_get);
433  ac->dht_get = NULL;
434  n_gets_fail++;
435  GNUNET_assert (NULL != ctx->op);
437  ctx->op = NULL;
438 
439  /* If profiling is complete, summarize */
440  if (n_active == n_gets_fail + n_gets_ok)
441  {
443  / (double) n_active;
445  / (double ) n_gets_ok;
446  summarize ();
447  }
448 }
449 
450 
468 static void
469 get_iter (void *cls,
470  struct GNUNET_TIME_Absolute exp,
471  const struct GNUNET_HashCode *key,
472  const struct GNUNET_PeerIdentity *get_path,
473  unsigned int get_path_length,
474  const struct GNUNET_PeerIdentity *put_path,
475  unsigned int put_path_length,
476  enum GNUNET_BLOCK_Type type,
477  size_t size, const void *data)
478 {
479  struct ActiveContext *ac = cls;
480  struct ActiveContext *get_ac = ac->get_ac;
481  struct Context *ctx = ac->ctx;
482 
483  /* we found the data we are looking for */
484  DEBUG ("We found a GET request; %u remaining\n",
485  n_gets - (n_gets_fail + n_gets_ok)); // FIXME: It always prints 1.
486  n_gets_ok++;
487  get_ac->nrefs--;
489  ac->dht_get = NULL;
490  if (ac->delay_task != NULL)
492  ac->delay_task = NULL;
493  GNUNET_assert (NULL != ctx->op);
495  ctx->op = NULL;
496 
497  total_put_path_length = total_put_path_length + (double) put_path_length;
498  total_get_path_length = total_get_path_length + (double) get_path_length;
499  DEBUG ("total_put_path_length = %u,put_path \n",
501  /* Summarize if profiling is complete */
502  if (n_active == n_gets_fail + n_gets_ok)
503  {
505  / (double) n_active;
506  average_get_path_length = (double) total_get_path_length
507  / (double ) n_gets_ok;
508  summarize ();
509  }
510 }
511 
512 
518 static void
519 delayed_get (void *cls)
520 {
521  struct ActiveContext *ac = cls;
522  struct ActiveContext *get_ac;
523  unsigned int r;
524 
525  ac->delay_task = NULL;
526  get_ac = NULL;
527  while (1)
528  {
530  n_active);
531  get_ac = &a_ac[r];
532  if (NULL != get_ac->hash)
533  break;
534  }
535  get_ac->nrefs++;
536  ac->get_ac = get_ac;
539  DEBUG ("GET_REQUEST_START key %s \n",
540  GNUNET_h2s (&get_ac->hash[r]));
541  ac->dht_get = GNUNET_DHT_get_start (ac->dht,
543  &get_ac->hash[r],
544  1, /* replication level */
546  NULL,
547  0, /* extended query and size */
548  &get_iter,
549  ac); /* GET iterator and closure */
550  n_gets++;
551 
552  /* schedule the timeout task for GET */
554  &cancel_get,
555  ac);
556 }
557 
558 
566 static void
567 delayed_put (void *cls);
568 
569 
576 static void
577 put_cont (void *cls)
578 {
579  struct ActiveContext *ac = cls;
580 
581  ac->dht_put = NULL;
582  n_puts_ok++;
584  ac);
585 }
586 
587 
595 static void
596 delayed_put (void *cls)
597 {
598  struct ActiveContext *ac = cls;
599  char block[65536];
600  size_t block_size;
601 
602  ac->delay_task = NULL;
603  if (0 == ac->put_count)
604  {
605  struct Context *ctx = ac->ctx;
607 
608  GNUNET_assert (NULL != ctx);
609  op = ctx->op;
610  ctx->op = NULL;
612  return;
613  }
614 
615 
616  /* Generate and DHT PUT some random data */
617  block_size = 16; /* minimum */
618  /* make random payload, reserve 512 - 16 bytes for DHT headers */
621  - 512);
623  block,
624  block_size);
625  ac->put_count--;
626  GNUNET_CRYPTO_hash (block,
627  block_size,
628  &ac->hash[ac->put_count]);
629  DEBUG ("PUT_REQUEST_START key %s\n",
630  GNUNET_h2s (&ac->hash[ac->put_count]));
631  ac->dht_put = GNUNET_DHT_put (ac->dht,
632  &ac->hash[ac->put_count],
633  replication,
636  block_size,
637  block,
638  GNUNET_TIME_UNIT_FOREVER_ABS, /* expiration time */
639  &put_cont,
640  ac); /* continuation and its closure */
641  n_puts++;
642 }
643 
644 
654 static void
655 dht_connected (void *cls,
657  void *ca_result,
658  const char *emsg)
659 {
660  struct ActiveContext *ac = cls;
661  struct Context *ctx = ac->ctx;
662 
663  GNUNET_assert (NULL != ctx); // FIXME: Fails
664  GNUNET_assert (NULL != ctx->op);
665  GNUNET_assert (ctx->op == op);
666  ac->dht = (struct GNUNET_DHT_Handle *) ca_result;
667  if (NULL != emsg)
668  {
670  "Connection to DHT service failed: %s\n",
671  emsg);
672  GNUNET_TESTBED_operation_done (ctx->op); /* Calls dht_disconnect() */
673  ctx->op = NULL;
674  return;
675  }
676  switch (mode)
677  {
678  case MODE_PUT:
679  {
680  struct GNUNET_TIME_Relative peer_delay_put;
681 
682  peer_delay_put.rel_value_us =
686  ac->hash = calloc (ac->put_count,
687  sizeof(struct GNUNET_HashCode));
688  if (NULL == ac->hash)
689  {
691  "calloc");
693  return;
694  }
695  ac->delay_task = GNUNET_SCHEDULER_add_delayed (peer_delay_put,
696  &delayed_put,
697  ac);
698  break;
699  }
700 
701  case MODE_GET:
702  {
703  struct GNUNET_TIME_Relative peer_delay_get;
704 
705  peer_delay_get.rel_value_us =
709  ac->delay_task = GNUNET_SCHEDULER_add_delayed (peer_delay_get,
710  &delayed_get,
711  ac);
712  break;
713  }
714  }
715 }
716 
717 
727 static void *
728 dht_connect (void *cls,
729  const struct GNUNET_CONFIGURATION_Handle *cfg)
730 {
731  n_dht++;
732  return GNUNET_DHT_connect (cfg,
733  10);
734 }
735 
736 
744 static void
745 dht_disconnect (void *cls,
746  void *op_result)
747 {
748  struct ActiveContext *ac = cls;
749 
750  GNUNET_assert (NULL != ac->dht);
751  GNUNET_assert (ac->dht == op_result);
753  ac->dht = NULL;
754  n_dht--;
755  if (0 != n_dht)
756  return;
757  if (GNUNET_YES == in_shutdown)
758  return;
759  switch (mode)
760  {
761  case MODE_PUT:
762  if (n_puts_ok != ((unsigned long long) n_active) * num_puts_per_peer)
763  return;
764  /* Start GETs if all PUTs have been made */
765  mode = MODE_GET;
766  start_profiling ();
767  return;
768 
769  case MODE_GET:
770  if ((n_gets_ok + n_gets_fail) != n_active)
771  return;
772  break;
773  }
774 }
775 
776 
780 static void
782 {
783  struct Context *ctx;
784 
785  DEBUG ("GNUNET_TESTBED_service_connect\n");
787  for (unsigned int i = 0; i < n_active; i++)
788  {
789  struct ActiveContext *ac = &a_ac[i];
790  GNUNET_assert (NULL != (ctx = ac->ctx));
791  GNUNET_assert (NULL == ctx->op);
793  ctx->peer,
794  "dht",
795  &dht_connected, ac,
796  &dht_connect,
798  ac);
799  }
800 }
801 
802 
811 static void
812 service_started (void *cls,
814  const char *emsg)
815 {
816  struct Context *ctx = cls;
817 
818  GNUNET_assert (NULL != ctx);
819  GNUNET_assert (NULL != ctx->op);
821  ctx->op = NULL;
822  peers_started++;
823  DEBUG ("Peers Started = %d; num_peers = %d \n",
825  num_peers);
826  if (peers_started == num_peers)
827  start_profiling ();
828 }
829 
830 
842 static void
843 test_run (void *cls,
844  struct GNUNET_TESTBED_RunHandle *h,
845  unsigned int num_peers,
846  struct GNUNET_TESTBED_Peer **peers,
847  unsigned int links_succeeded,
848  unsigned int links_failed)
849 {
850  unsigned int ac_cnt;
851 
852  testbed_handles = peers;
853  if (NULL == peers)
854  {
855  /* exit */
856  GNUNET_assert (0);
857  }
858  MESSAGE ("%u peers started, %u/%u links up\n",
859  num_peers,
860  links_succeeded,
861  links_succeeded + links_failed);
862  a_ctx = GNUNET_new_array (num_peers,
863  struct Context);
864  /* select the peers which actively participate in profiling */
865  n_active = num_peers * put_probability / 100;
866  if (0 == n_active)
867  {
869  GNUNET_free (a_ctx);
870  a_ctx = NULL;
871  return;
872  }
873 
874  a_ac = GNUNET_new_array (n_active,
875  struct ActiveContext);
876  ac_cnt = 0;
877  for (unsigned int cnt = 0; cnt < num_peers && ac_cnt < n_active; cnt++)
878  {
880  100) >= put_probability)
881  continue;
882 
883  a_ctx[cnt].ac = &a_ac[ac_cnt];
884  a_ac[ac_cnt].ctx = &a_ctx[cnt];
885  ac_cnt++;
886  }
887  n_active = ac_cnt;
888 
889  /* start DHT service on all peers */
890  for (unsigned int cnt = 0; cnt < num_peers; cnt++)
891  {
892  a_ctx[cnt].peer = peers[cnt];
893  a_ctx[cnt].op = GNUNET_TESTBED_peer_manage_service (&a_ctx[cnt],
894  peers[cnt],
895  "dht",
897  &a_ctx[cnt],
898  1);
899  }
900 }
901 
902 
911 static void
912 run (void *cls,
913  char *const *args,
914  const char *cfgfile,
915  const struct GNUNET_CONFIGURATION_Handle *config)
916 {
917  uint64_t event_mask;
918 
919  if (0 == num_peers)
920  {
922  _ ("Exiting as the number of peers is %u\n"),
923  num_peers);
924  return;
925  }
926  cfg = config;
927  event_mask = 0;
929  cfg,
930  num_peers,
931  event_mask,
932  NULL,
933  NULL,
934  &test_run,
935  NULL);
937  NULL);
938 }
939 
940 
946 int
947 main (int argc,
948  char *const *argv)
949 {
950  int rc;
951  struct GNUNET_GETOPT_CommandLineOption options[] = {
953  "peers",
954  "COUNT",
955  gettext_noop ("number of peers to start"),
956  &num_peers),
958  "peer-put-count",
959  "COUNT",
960  gettext_noop (
961  "number of PUTs to perform per peer"),
964  "hosts",
965  "FILENAME",
966  gettext_noop (
967  "name of the file with the login information for the testbed"),
968  &hosts_file),
970  "delay",
971  "DELAY",
972  gettext_noop (
973  "delay between rounds for collecting statistics (default: 30 sec)"),
974  &delay_stats),
976  "PUT-delay",
977  "DELAY",
978  gettext_noop (
979  "delay to start doing PUTs (default: 1 sec)"),
980  &delay_put),
982  "GET-delay",
983  "DELAY",
984  gettext_noop (
985  "delay to start doing GETs (default: 5 min)"),
986  &delay_get),
988  "replication",
989  "DEGREE",
990  gettext_noop ("replication degree for DHT PUTs"),
991  &replication),
993  "random-chance",
994  "PROBABILITY",
995  gettext_noop (
996  "chance that a peer is selected at random for PUTs"),
997  &put_probability),
999  "timeout",
1000  "TIMEOUT",
1001  gettext_noop (
1002  "timeout for DHT PUT and GET requests (default: 1 min)"),
1003  &timeout),
1005  };
1006 
1007  if (GNUNET_OK !=
1008  GNUNET_STRINGS_get_utf8_args (argc, argv,
1009  &argc, &argv))
1010  return 2;
1011  /* set default delays */
1016  replication = 1; /* default replication */
1017  rc = 0;
1018  if (GNUNET_OK !=
1019  GNUNET_PROGRAM_run (argc,
1020  argv,
1021  "gnunet-dht-profiler",
1022  gettext_noop (
1023  "Measure quality and performance of the DHT service."),
1024  options,
1025  &run,
1026  NULL))
1027  rc = 1;
1028  return rc;
1029 }
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:1035
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:1300
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:1438
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:245
#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:75
#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 enum @8 mode
Should we do a PUT (mode = 0) or GET (mode = 1);.
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:526
#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:99
static struct GNUNET_DNSSTUB_Context * ctx
Context for DNS resolution.
Connection to the DHT service.
Definition: dht_api.c:201
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:181
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:1253
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:48
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:1280
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:442
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:2044
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:1155
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:966
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:890
static unsigned long long n_puts
Number of DHT PUTs made.
void GNUNET_DHT_disconnect(struct GNUNET_DHT_Handle *handle)
Shutdown connection with the DHT service.
Definition: dht_api.c:918
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:79
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.
const char * name
#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:1067
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:367
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:77
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).
#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:966