gnunet-dht-tvg.c File Reference

#include "gnunet_common.h"
#include "gnunet_constants.h"
#include "gnunet_dht_block_types.h"
#include "gnunet_dht_service.h"
#include "gnunet_pils_service.h"
#include "gnunet_time_lib.h"
#include "gnunet_util_lib.h"
#include "dht_helper.h"
#include <inttypes.h>
#include <string.h>

Include dependency graph for gnunet-dht-tvg.c:

Go to the source code of this file.

Data Structures
struct	TVG_CallbackData

Macros
#define	NUM_PEERS   5

Functions
static void	print_put_message (struct TVG_CallbackData *tvg)
static bool	cb_print_put_message (void *cls, size_t msize, struct PeerPutMessage *ppm)
static void	run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg)
	Main function that will be run.
int	main (int argc, char *const *argv)
	The main function of the test vector generation tool.

Variables
struct GNUNET_PILS_Handle *	GDS_pils
	Handle for the pils service.
static const char *	peers_str [5]

Macro Definition Documentation

NUM_PEERS

#define NUM_PEERS   5

Definition at line 42 of file gnunet-dht-tvg.c.

Function Documentation

print_put_message()

static void print_put_message ( struct TVG_CallbackData *  tvg )

static

Definition at line 112 of file gnunet-dht-tvg.c.

{
  struct GNUNET_PeerIdentity *peers;
  struct GNUNET_CRYPTO_EddsaPrivateKey *peers_sk;
  struct GNUNET_HashCode *peers_hash;
  struct GNUNET_DHT_PathElement *pp;
  struct GNUNET_PeerIdentity trunc_peer_out;
  bool truncated;
  enum GNUNET_GenericReturnValue ret;
  size_t msize;
  int i;
 
  peers = tvg->peers;
  peers_sk = tvg->peers_sk;
  peers_hash = tvg->peers_hash;
  pp = tvg->pp;
 
  i = tvg->index;
  if (i >= NUM_PEERS - 1)
    return;
 
  ret = GDS_helper_put_message_get_size (
    &msize, &peers[i], tvg->ro, &tvg->ro, GNUNET_TIME_UNIT_FOREVER_ABS,
    tvg->block_data, tvg->block_len, pp,
    tvg->put_path_len, &tvg->put_path_len,
    NULL, &trunc_peer_out, &truncated);
  GNUNET_assert (GNUNET_OK == ret);
  {
    uint8_t buf[msize];
    struct PeerPutMessage *ppm;
    ppm = (struct PeerPutMessage*) buf;
    GNUNET_CONTAINER_bloomfilter_add (tvg->peer_bf,
                                      &peers_hash[i]);
    GNUNET_CONTAINER_bloomfilter_add (tvg->peer_bf,
                                      &peers_hash[i + 1]);
    GDS_helper_make_put_message (ppm, msize,
                                 &peers_sk[i], &peers[i + 1],
                                 &peers_hash[i + 1],
                                 tvg->peer_bf, &tvg->key, tvg->ro,
                                 GNUNET_BLOCK_TYPE_TEST,
                                 GNUNET_TIME_UNIT_FOREVER_ABS,
                                 tvg->block_data,
                                 tvg->block_len,
                                 pp, tvg->put_path_len,
                                 i, 7, NULL,
                                 &cb_print_put_message,
                                 0,
                                 tvg);
  }
}

References TVG_CallbackData::block_data, TVG_CallbackData::block_len, cb_print_put_message(), GDS_helper_make_put_message(), GDS_helper_put_message_get_size(), GNUNET_assert, GNUNET_BLOCK_TYPE_TEST, GNUNET_CONTAINER_bloomfilter_add(), GNUNET_OK, GNUNET_TIME_UNIT_FOREVER_ABS, TVG_CallbackData::index, TVG_CallbackData::key, NUM_PEERS, TVG_CallbackData::peer_bf, peers, TVG_CallbackData::peers, TVG_CallbackData::peers_hash, TVG_CallbackData::peers_sk, TVG_CallbackData::pp, TVG_CallbackData::put_path_len, ret, and TVG_CallbackData::ro.

Referenced by cb_print_put_message(), and run().

Here is the call graph for this function:

Here is the caller graph for this function:

cb_print_put_message()

static bool cb_print_put_message ( void *  cls, size_t  msize, struct PeerPutMessage *  ppm  )

static

Definition at line 73 of file gnunet-dht-tvg.c.

{
  struct TVG_CallbackData *tvg = cls;
  struct GNUNET_PeerIdentity *peers;
  struct GNUNET_DHT_PathElement *pp;
 
  peers = tvg->peers;
  pp = tvg->pp;
 
  if (ppm)
  {
    size_t putlen;
    struct GNUNET_DHT_PathElement *put_path;
    struct GNUNET_CRYPTO_EddsaSignature *last_sig;
 
    printf ("Peer %d sends to peer %d PUT Message:\n",
            tvg->index, tvg->index + 1);
    GNUNET_print_bytes (ppm, msize, 8, 0);
    putlen = ntohs (ppm->put_path_length);
    put_path = (struct GNUNET_DHT_PathElement*) &ppm[1];
    last_sig = (struct GNUNET_CRYPTO_EddsaSignature*) &put_path[putlen];
    memcpy (pp, put_path, putlen * sizeof (struct GNUNET_DHT_PathElement));
    pp[putlen].pred = peers[tvg->index];
    pp[putlen].sig = *last_sig;
    tvg->put_path_len++;
    printf ("\n");
    // printf ("Put path (len = %u):\n", put_path_len);
    // GNUNET_print_bytes (pp, put_path_len * sizeof (*pp), 8, 0);
  }
 
  tvg->index++;
  print_put_message (tvg);
  return false;
}

References GNUNET_print_bytes(), TVG_CallbackData::index, peers, TVG_CallbackData::peers, TVG_CallbackData::pp, GNUNET_DHT_PathElement::pred, print_put_message(), TVG_CallbackData::put_path_len, PeerPutMessage::put_path_length, and GNUNET_DHT_PathElement::sig.

Referenced by print_put_message().

Here is the call graph for this function:

Here is the caller graph for this function:

run()

static void run ( void *  cls, char *const *  args, const char *  cfgfile, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Main function that will be run.

Parameters

cls	closure
args	remaining command-line arguments
cfgfile	name of the configuration file used (for saving, can be NULL!)
cfg	configuration

Definition at line 173 of file gnunet-dht-tvg.c.

{
  struct TVG_CallbackData tvg;
  struct GNUNET_PeerIdentity *peers;
  struct GNUNET_CRYPTO_EddsaPrivateKey *peers_sk;
  struct GNUNET_HashCode *peers_hash;
  uint64_t data_num = 23;
 
  GDS_pils = NULL;
 
  GNUNET_CRYPTO_hash ("testvector", strlen ("testvector"), &tvg.key);
 
  memset (&tvg, 0, sizeof (tvg));
  tvg.ro = GNUNET_DHT_RO_RECORD_ROUTE;
  tvg.put_path_len = 0;
  tvg.block_data = (uint8_t*) &data_num;
  tvg.block_len = sizeof (data_num);
 
  peers = tvg.peers;
  peers_sk = tvg.peers_sk;
  peers_hash = tvg.peers_hash;
 
  for (int i = 0; i < NUM_PEERS; i++)
  {
    GNUNET_hex2b (peers_str[i], &peers_sk[i], sizeof peers_sk[i], 0);
    GNUNET_CRYPTO_eddsa_key_get_public (&peers_sk[i],
                                        &peers[i].public_key);
    GNUNET_CRYPTO_hash (&peers[i], sizeof (struct GNUNET_PeerIdentity), &
                        peers_hash[i]);
    printf ("Peer %d sk:\n", i);
    GNUNET_print_bytes (&peers_sk[i], sizeof peers_sk[i], 8, 0);
    printf ("\nPeer %d pk:\n", i);
    GNUNET_print_bytes (&peers[i], sizeof peers[i], 8, 0);
    printf ("\nPeer %d SHA512(pk):\n", i);
    GNUNET_print_bytes (&peers_hash[i], sizeof peers_hash[i], 8, 0);
    printf ("\n");
  }
 
  tvg.peer_bf
    = GNUNET_CONTAINER_bloomfilter_init (NULL,
                                         DHT_BLOOM_SIZE,
                                         GNUNET_CONSTANTS_BLOOMFILTER_K);
  tvg.index = 0;
  print_put_message (&tvg);
 
  GDS_helper_cleanup_operations ();
  GDS_pils = NULL;
}

References TVG_CallbackData::block_data, TVG_CallbackData::block_len, DHT_BLOOM_SIZE, GDS_helper_cleanup_operations(), GDS_pils, GNUNET_CONSTANTS_BLOOMFILTER_K, GNUNET_CONTAINER_bloomfilter_init(), GNUNET_CRYPTO_eddsa_key_get_public(), GNUNET_CRYPTO_hash(), GNUNET_DHT_RO_RECORD_ROUTE, GNUNET_hex2b(), GNUNET_print_bytes(), TVG_CallbackData::index, TVG_CallbackData::key, NUM_PEERS, TVG_CallbackData::peer_bf, peers, TVG_CallbackData::peers, TVG_CallbackData::peers_hash, TVG_CallbackData::peers_sk, peers_str, print_put_message(), TVG_CallbackData::put_path_len, and TVG_CallbackData::ro.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main	(	int	argc,
		char *const *	argv
	)

The main function of the test vector generation tool.

Parameters

argc	number of arguments from the command line
argv	command line arguments

Returns

0 ok, 1 on error

Definition at line 234 of file gnunet-dht-tvg.c.

{
  const struct GNUNET_GETOPT_CommandLineOption options[] = {
    GNUNET_GETOPT_OPTION_END
  };
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_log_setup ("gnunet-dht-tvg",
                                   "INFO",
                                   NULL));
  // gcry_control (GCRYCTL_SET_DEBUG_FLAGS, 1u, 0);
  // gcry_control (GCRYCTL_SET_VERBOSITY, 99);
  if (GNUNET_OK !=
      GNUNET_PROGRAM_run (GNUNET_OS_project_data_gnunet (),
                          argc, argv,
                          "gnunet-dht-tvg",
                          "Generate test vectors for R5N",
                          options,
                          &run, NULL))
    return 1;
  return 0;
}

References GNUNET_assert, GNUNET_GETOPT_OPTION_END, GNUNET_log_setup(), GNUNET_OK, GNUNET_OS_project_data_gnunet(), GNUNET_PROGRAM_run(), options, and run().

Here is the call graph for this function:

Variable Documentation

GDS_pils

struct GNUNET_PILS_Handle* GDS_pils

Handle for the pils service.

(may be NULL but needed for linking)

Definition at line 40 of file gnunet-dht-tvg.c.

Referenced by run().

peers_str

const char* peers_str[5]

static

Initial value:

= {
  "a4bba7746dfd3432da2a11c57b248b2d6b14eafb3ad54401c44bd37f232d1ce5",
  "02163d1dde228f9796c5327c781b4e5880ebf356204d3c4cceb9a77ae32157d7",
  "859836011003dc5d0cd84418812e381f3989797fb994464a52e3b7ad954c2695",
  "276881c5c18af46c2ad8ee5235c62c4d9d1df4bb2795d6f0ce190d51aa8b9ce0",
  "56045fd5e9d91426c6a4ec9c8c230ea4ee56fb5c0ad3b77000d863142ceb3b9b"
}

Definition at line 44 of file gnunet-dht-tvg.c.

                                         {
  "a4bba7746dfd3432da2a11c57b248b2d6b14eafb3ad54401c44bd37f232d1ce5",
  "02163d1dde228f9796c5327c781b4e5880ebf356204d3c4cceb9a77ae32157d7",
  "859836011003dc5d0cd84418812e381f3989797fb994464a52e3b7ad954c2695",
  "276881c5c18af46c2ad8ee5235c62c4d9d1df4bb2795d6f0ce190d51aa8b9ce0",
  "56045fd5e9d91426c6a4ec9c8c230ea4ee56fb5c0ad3b77000d863142ceb3b9b"
};

Referenced by run().