dht_test_lib.c File Reference

library for writing DHT tests More...

#include "platform.h"
#include "dht_test_lib.h"

Include dependency graph for dht_test_lib.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_DHT_TEST_Context
	Test context for a DHT Test. More...

Functions
static void *	dht_connect_adapter (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg)
	Adapter function called to establish a connection to the DHT service. More...
static void	dht_disconnect_adapter (void *cls, void *op_result)
	Adapter function called to destroy a connection to the DHT service. More...
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. More...
void	GNUNET_DHT_TEST_cleanup (struct GNUNET_DHT_TEST_Context *ctx)
	Clean up the testbed. More...
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)
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. More...

Detailed Description

library for writing DHT tests

Author

Christian Grothoff

Definition in file dht_test_lib.c.

Function Documentation

dht_connect_adapter()

static void* dht_connect_adapter ( void *  cls, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Adapter function called to establish a connection to the DHT service.

Parameters

cls	closure
cfg	configuration of the peer to connect to; will be available until GNUNET_TESTBED_operation_done() is called on the operation returned from GNUNET_TESTBED_service_connect()

Returns

service handle to return in 'op_result', NULL on error

Definition at line 76 of file dht_test_lib.c.

{
  return GNUNET_DHT_connect (cfg, 16);
}

References cfg, and GNUNET_DHT_connect().

Referenced by dht_test_run().

Here is the call graph for this function:

Here is the caller graph for this function:

dht_disconnect_adapter()

static void dht_disconnect_adapter ( void *  cls, void *  op_result  )

static

Adapter function called to destroy a connection to the DHT service.

Parameters

cls	closure
op_result	service handle returned from the connect adapter

Definition at line 91 of file dht_test_lib.c.

{
  struct GNUNET_DHT_Handle *dht = op_result;
 
  GNUNET_DHT_disconnect (dht);
}

References dht, GNUNET_DHT_disconnect(), and op_result().

Referenced by dht_test_run().

Here is the call graph for this function:

Here is the caller graph for this function:

dht_connect_cb()

static void dht_connect_cb ( void *  cls, struct GNUNET_TESTBED_Operation *  op, void *  ca_result, const char *  emsg  )

static

Callback to be called when a service connect operation is completed.

Parameters

cls	the callback closure from functions generating an operation
op	the operation that has been finished
ca_result	the service handle returned from GNUNET_TESTBED_ConnectAdapter()
emsg	error message in case the operation has failed; will be NULL if operation has executed successfully.

Definition at line 110 of file dht_test_lib.c.

{
  struct GNUNET_DHT_TEST_Context *ctx = cls;
 
  if (NULL != emsg)
  {
    fprintf (stderr,
             "Failed to connect to DHT service: %s\n",
             emsg);
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  for (unsigned int i = 0; i < ctx->num_peers; i++)
    if (op == ctx->ops[i])
      ctx->dhts[i] = ca_result;
  for (unsigned int i = 0; i < ctx->num_peers; i++)
    if (NULL == ctx->dhts[i])
      return;
  /* still some DHT connections missing */
  /* all DHT connections ready! */
  ctx->app_main (ctx->app_main_cls,
                 ctx,
                 ctx->num_peers,
                 ctx->peers,
                 ctx->dhts);
}

References ctx, GNUNET_SCHEDULER_shutdown(), and op.

Referenced by dht_test_run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_DHT_TEST_cleanup()

void GNUNET_DHT_TEST_cleanup

(

struct GNUNET_DHT_TEST_Context *

ctx

)

Clean up the testbed.

Parameters

ctx	handle for the testbed

Definition at line 142 of file dht_test_lib.c.

{
  for (unsigned int i = 0; i < ctx->num_peers; i++)
    GNUNET_TESTBED_operation_done (ctx->ops[i]);
  GNUNET_free (ctx->ops);
  GNUNET_free (ctx->dhts);
  GNUNET_free (ctx);
  GNUNET_SCHEDULER_shutdown ();
}

References ctx, GNUNET_free, GNUNET_SCHEDULER_shutdown(), and GNUNET_TESTBED_operation_done().

Here is the call graph for this function:

dht_test_run()

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  )

static

Definition at line 154 of file dht_test_lib.c.

{
  struct GNUNET_DHT_TEST_Context *ctx = cls;
 
  GNUNET_assert (num_peers == ctx->num_peers);
  ctx->peers = peers;
  for (unsigned int i = 0; i < num_peers; i++)
    ctx->ops[i] = GNUNET_TESTBED_service_connect (ctx,
                                                  peers[i],
                                                  "dht",
                                                  &dht_connect_cb,
                                                  ctx,
                                                  &dht_connect_adapter,
                                                  &dht_disconnect_adapter,
                                                  ctx);
}

References ctx, dht_connect_adapter(), dht_connect_cb(), dht_disconnect_adapter(), GNUNET_assert, GNUNET_TESTBED_service_connect(), num_peers, and peers.

Referenced by GNUNET_DHT_TEST_run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_DHT_TEST_run()

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.

Parameters

testname	name of the test (for logging)
cfgname	name of the configuration file
num_peers	number of peers to start
tmain	main function to run once the testbed is ready
tmain_cls	closure for 'tmain'

Definition at line 178 of file dht_test_lib.c.

{
  struct GNUNET_DHT_TEST_Context *ctx;
 
  ctx = GNUNET_new (struct GNUNET_DHT_TEST_Context);
  ctx->num_peers = num_peers;
  ctx->ops = GNUNET_new_array (num_peers,
                               struct GNUNET_TESTBED_Operation *);
  ctx->dhts = GNUNET_new_array (num_peers,
                                struct GNUNET_DHT_Handle *);
  ctx->app_main = tmain;
  ctx->app_main_cls = tmain_cls;
  (void) GNUNET_TESTBED_test_run (testname,
                                  cfgname,
                                  num_peers,
                                  0LL, NULL, NULL,
                                  &dht_test_run, ctx);
}

References ctx, dht_test_run(), GNUNET_new, GNUNET_new_array, GNUNET_TESTBED_test_run(), num_peers, and tmain().

Here is the call graph for this function: