transport-testing-main2.c File Reference

#include "platform.h"
#include "transport-testing2.h"

Include dependency graph for transport-testing-main2.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_TRANSPORT_TESTING_ConnectRequestList
	Closure for connect_cb. More...
struct	GNUNET_TRANSPORT_TESTING_InternalPeerContext
	Internal data structure. More...
struct	ConnectPairInfo
	Information tracked per connected peer. More...

Functions
static void	do_shutdown (void *cls)
	Shutdown function for the test. More...
static void	do_timeout (void *cls)
	Testcase hit timeout, shut it down with error. More...
static void	connect_cb (void *cls)
	Function called when we connected two peers. More...
struct GNUNET_TRANSPORT_TESTING_PeerContext *	GNUNET_TRANSPORT_TESTING_find_peer (struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc, const struct GNUNET_PeerIdentity *peer)
	Find peer by peer ID. More...
static void *	my_nc (void *cls, const struct GNUNET_PeerIdentity *peer, struct GNUNET_MQ_Handle *mq)
	Wrapper around peers connecting. More...
static void	my_nd (void *cls, const struct GNUNET_PeerIdentity *peer, void *custom_cls)
	Wrapper around peers disconnecting. More...
static int	check_test (void *cls, const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
	Wrapper around receiving data. More...
static void	handle_test (void *cls, const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
	Wrapper around receiving data. More...
static int	check_test2 (void *cls, const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
	Wrapper around receiving data. More...
static void	handle_test2 (void *cls, const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
	Wrapper around receiving data. More...
static void	do_connect (void *cls)
	Connect the peers as a clique. More...
static void	start_cb (void *cls)
	Function called once we have successfully launched a peer. More...
static void	connect_check_run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg)
	Function run from GNUNET_TRANSPORT_TESTING_connect_check once the scheduler is up. More...
int	GNUNET_TRANSPORT_TESTING_connect_check (void *cls, struct GNUNET_TRANSPORT_TESTING_Handle *tth_, const char *test_plugin_, const char *test_name_, unsigned int num_peers, char *cfg_files[])
	Common implementation of the GNUNET_TRANSPORT_TESTING_CheckCallback. More...
int	GNUNET_TRANSPORT_TESTING_main_ (const char *argv0, const char *filename, unsigned int num_peers, GNUNET_TRANSPORT_TESTING_CheckCallback check, void *check_cls)
	Setup testcase. More...

Function Documentation

do_shutdown()

static void do_shutdown ( void *  cls )

static

Shutdown function for the test.

Stops all peers.

Parameters

cls	our struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *

Definition at line 72 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = cls;
  struct GNUNET_TRANSPORT_TESTING_ConnectRequestList *crl;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Testcase shutting down\n");
  if (NULL != ccc->shutdown_task)
    ccc->shutdown_task (ccc->shutdown_task_cls);
  if (NULL != ccc->timeout_task)
  {
    GNUNET_SCHEDULER_cancel (ccc->timeout_task);
    ccc->timeout_task = NULL;
  }
  if (NULL != ccc->connect_task)
  {
    GNUNET_SCHEDULER_cancel (ccc->connect_task);
    ccc->connect_task = NULL;
  }
  while (NULL != (crl = ccc->crl_head))
  {
    GNUNET_CONTAINER_DLL_remove (ccc->crl_head,
                                 ccc->crl_tail,
                                 crl);
    GNUNET_TRANSPORT_TESTING_connect_peers_cancel (crl->cr);
    GNUNET_free (crl);
  }
  for (unsigned int i = 0; i < ccc->num_peers; i++)
  {
    if (NULL != ccc->p[i])
    {
      GNUNET_TRANSPORT_TESTING_stop_peer (ccc->p[i]);
      ccc->p[i] = NULL;
    }
  }
}

References GNUNET_TRANSPORT_TESTING_ConnectRequestList::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::connect_task, GNUNET_TRANSPORT_TESTING_ConnectRequestList::cr, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::crl_head, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::crl_tail, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_log, GNUNET_SCHEDULER_cancel(), GNUNET_TRANSPORT_TESTING_connect_peers_cancel(), GNUNET_TRANSPORT_TESTING_stop_peer(), GNUNET_TRANSPORT_TESTING_ConnectCheckContext::num_peers, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::shutdown_task, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::shutdown_task_cls, and GNUNET_TRANSPORT_TESTING_ConnectCheckContext::timeout_task.

Referenced by connect_check_run().

Here is the call graph for this function:

Here is the caller graph for this function:

do_timeout()

static void do_timeout ( void *  cls )

static

Testcase hit timeout, shut it down with error.

Parameters

cls	our struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *

Definition at line 116 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = cls;
 
  ccc->timeout_task = NULL;
  GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
              "Testcase timed out\n");
  ccc->global_ret = GNUNET_SYSERR;
  GNUNET_SCHEDULER_shutdown ();
}

References GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::global_ret, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_SCHEDULER_shutdown(), GNUNET_SYSERR, and GNUNET_TRANSPORT_TESTING_ConnectCheckContext::timeout_task.

Referenced by connect_check_run().

Here is the call graph for this function:

Here is the caller graph for this function:

connect_cb()

static void connect_cb ( void *  cls )

static

Function called when we connected two peers.

Once we have gotten to the clique, launch test-specific logic.

Parameters

cls	our struct GNUNET_TRANSPORT_TESTING_ConnectRequestList *

Definition at line 171 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_ConnectRequestList *crl = cls;
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = crl->ccc;
 
  GNUNET_CONTAINER_DLL_remove (ccc->crl_head,
                               ccc->crl_tail,
                               crl);
  {
    char *p1_c = GNUNET_strdup (GNUNET_i2s (&crl->p1->id));
 
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Peers connected: %u (%s) <-> %u (%s)\n",
                crl->p1->no,
                p1_c,
                crl->p2->no,
                GNUNET_i2s (&crl->p2->id));
    GNUNET_free (p1_c);
    GNUNET_free (crl);
  }
  if (NULL == ccc->crl_head)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "All connections UP, launching custom test logic.\n");
    GNUNET_SCHEDULER_add_now (ccc->connect_continuation,
                              ccc->connect_continuation_cls);
  }
}

References GNUNET_TRANSPORT_TESTING_ConnectRequestList::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::connect_continuation, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::connect_continuation_cls, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::crl_head, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::crl_tail, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_i2s(), GNUNET_log, GNUNET_SCHEDULER_add_now(), GNUNET_strdup, GNUNET_TRANSPORT_TESTING_PeerContext::id, GNUNET_TRANSPORT_TESTING_PeerContext::no, GNUNET_TRANSPORT_TESTING_ConnectRequestList::p1, and GNUNET_TRANSPORT_TESTING_ConnectRequestList::p2.

Referenced by do_connect().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TRANSPORT_TESTING_find_peer()

struct GNUNET_TRANSPORT_TESTING_PeerContext * GNUNET_TRANSPORT_TESTING_find_peer	(	struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *	ccc,
		const struct GNUNET_PeerIdentity *	peer
	)

Find peer by peer ID.

Parameters

ccc	context to search
peer	peer to look for

Returns

NULL if peer was not found

Definition at line 209 of file transport-testing-main2.c.

{
  for (unsigned int i = 0; i < ccc->num_peers; i++)
    if ((NULL != ccc->p[i]) &&
        (0 == memcmp (peer,
                      &ccc->p[i]->id,
                      sizeof(*peer))))
      return ccc->p[i];
  return NULL;
}

References GNUNET_TRANSPORT_TESTING_PeerContext::id, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::num_peers, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, and GNUNET_TRANSPORT_TESTING_PeerContext::peer.

my_nc()

static void * my_nc ( void *  cls, const struct GNUNET_PeerIdentity *  peer, struct GNUNET_MQ_Handle *  mq  )

static

Wrapper around peers connecting.

Calls client's nc function.

Parameters

cls	our struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *
peer	peer we got connected to
mq	message queue for transmissions to peer

Returns

closure for message handlers

Definition at line 233 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cls;
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc;
  struct ConnectPairInfo *cpi;
 
  if (NULL != ccc->nc)
    ccc->nc (ccc->cls,
             ccc->p[ipi->off],
             peer);
  cpi = GNUNET_new (struct ConnectPairInfo);
  cpi->ipi = ipi;
  cpi->sender = peer; /* valid until disconnect */
  return cpi;
}

References GNUNET_TRANSPORT_TESTING_InternalPeerContext::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, GNUNET_new, ConnectPairInfo::ipi, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::nc, GNUNET_TRANSPORT_TESTING_InternalPeerContext::off, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, and ConnectPairInfo::sender.

Referenced by connect_check_run().

Here is the caller graph for this function:

my_nd()

static void my_nd ( void *  cls, const struct GNUNET_PeerIdentity *  peer, void *  custom_cls  )

static

Wrapper around peers disconnecting.

Calls client's nd function.

Parameters

cls	our struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *
peer	peer we got disconnected from
custom_cls	return value from my_nc

Definition at line 260 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cls;
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc;
  struct ConnectPairInfo *cpi = custom_cls;
 
  if (NULL != ccc->nd)
    ccc->nd (ccc->cls,
             ccc->p[ipi->off],
             peer);
  GNUNET_free (cpi);
}

References GNUNET_TRANSPORT_TESTING_InternalPeerContext::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, GNUNET_free, ConnectPairInfo::ipi, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::nd, GNUNET_TRANSPORT_TESTING_InternalPeerContext::off, and GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p.

Referenced by connect_check_run().

Here is the caller graph for this function:

check_test()

static int check_test ( void *  cls, const struct GNUNET_TRANSPORT_TESTING_TestMessage *  message  )

static

Wrapper around receiving data.

Calls client's rec function.

Parameters

cls	our struct ConnectPairInfo *
message	message we received

Returns

GNUNET_OK (all messages are fine)

Definition at line 284 of file transport-testing-main2.c.

{
  return GNUNET_OK;
}

References GNUNET_OK.

handle_test()

static void handle_test ( void *  cls, const struct GNUNET_TRANSPORT_TESTING_TestMessage *  message  )

static

Wrapper around receiving data.

Calls client's rec function.

Parameters

cls	our struct ConnectPairInfo *
message	message we received

Definition at line 298 of file transport-testing-main2.c.

{
  struct ConnectPairInfo *cpi = cls;
  struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cpi->ipi;
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc;
 
  if (NULL != ccc->rec)
    ccc->rec (ccc->cls,
              ccc->p[ipi->off],
              cpi->sender,
              message);
}

References GNUNET_TRANSPORT_TESTING_InternalPeerContext::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, ConnectPairInfo::ipi, GNUNET_TRANSPORT_TESTING_InternalPeerContext::off, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::rec, and ConnectPairInfo::sender.

check_test2()

static int check_test2 ( void *  cls, const struct GNUNET_TRANSPORT_TESTING_TestMessage *  message  )

static

Wrapper around receiving data.

Calls client's rec function.

Parameters

cls	our struct ConnectPairInfo *
message	message we received

Returns

GNUNET_OK (all messages are fine)

Definition at line 321 of file transport-testing-main2.c.

{
  return GNUNET_OK;
}

References GNUNET_OK.

handle_test2()

static void handle_test2 ( void *  cls, const struct GNUNET_TRANSPORT_TESTING_TestMessage *  message  )

static

Wrapper around receiving data.

Calls client's rec function.

Parameters

cls	our struct ConnectPairInfo *
message	message we received

Definition at line 335 of file transport-testing-main2.c.

{
  struct ConnectPairInfo *cpi = cls;
  struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cpi->ipi;
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc;
 
  if (NULL != ccc->rec)
    ccc->rec (ccc->cls,
              ccc->p[ipi->off],
              cpi->sender,
              message);
}

References GNUNET_TRANSPORT_TESTING_InternalPeerContext::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, ConnectPairInfo::ipi, GNUNET_TRANSPORT_TESTING_InternalPeerContext::off, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::rec, and ConnectPairInfo::sender.

do_connect()

static void do_connect ( void *  cls )

static

Connect the peers as a clique.

Parameters

cls	our struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext

Definition at line 356 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = cls;
 
  ccc->connect_task = NULL;
  for (unsigned int i = 0; i < ccc->num_peers; i++)
    for (unsigned int j = (ccc->bi_directional ? 0 : i + 1); j < ccc->num_peers;
         j++)
    {
      struct GNUNET_TRANSPORT_TESTING_ConnectRequestList *crl;
 
      if (i == j)
        continue;
      crl = GNUNET_new (struct GNUNET_TRANSPORT_TESTING_ConnectRequestList);
      GNUNET_CONTAINER_DLL_insert (ccc->crl_head,
                                   ccc->crl_tail,
                                   crl);
      crl->ccc = ccc;
      crl->p1 = ccc->p[i];
      crl->p2 = ccc->p[j];
      {
        char *sender_c = GNUNET_strdup (GNUNET_i2s (&ccc->p[0]->id));
 
        GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                    "Test tries to connect peer %u (`%s') -> peer %u (`%s')\n",
                    ccc->p[0]->no,
                    sender_c,
                    ccc->p[1]->no,
                    GNUNET_i2s (&ccc->p[1]->id));
        GNUNET_free (sender_c);
      }
      crl->cr = GNUNET_TRANSPORT_TESTING_connect_peers (ccc->p[i],
                                                        ccc->p[j],
                                                        &connect_cb,
                                                        crl);
    }
}

References GNUNET_TRANSPORT_TESTING_ConnectCheckContext::bi_directional, GNUNET_TRANSPORT_TESTING_ConnectRequestList::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, connect_cb(), GNUNET_TRANSPORT_TESTING_ConnectCheckContext::connect_task, GNUNET_TRANSPORT_TESTING_ConnectRequestList::cr, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::crl_head, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::crl_tail, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_i2s(), GNUNET_log, GNUNET_new, GNUNET_strdup, GNUNET_TRANSPORT_TESTING_connect_peers(), GNUNET_TRANSPORT_TESTING_PeerContext::id, GNUNET_TRANSPORT_TESTING_PeerContext::no, num_peers, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::num_peers, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, GNUNET_TRANSPORT_TESTING_ConnectRequestList::p1, and GNUNET_TRANSPORT_TESTING_ConnectRequestList::p2.

Referenced by start_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

start_cb()

static void start_cb ( void *  cls )

static

Function called once we have successfully launched a peer.

Once all peers have been launched, we connect all of them in a clique.

Parameters

cls	our struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *

Definition at line 403 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_InternalPeerContext *ipi = cls;
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = ipi->ccc;
  struct GNUNET_TRANSPORT_TESTING_PeerContext *p = ccc->p[ipi->off];
 
  ccc->started++;
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Peer %u (`%s') started\n",
              p->no,
              GNUNET_i2s (&p->id));
  if (ccc->started != ccc->num_peers)
    return;
  if (NULL != ccc->pre_connect_task)
  {
    /* Run the custom per-connect job, then give it a second to
       go into effect before we continue connecting peers. */
    ccc->pre_connect_task (ccc->pre_connect_task_cls);
    ccc->connect_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
                                                      &do_connect,
                                                      ccc);
  }
  else
  {
    do_connect (ccc);
  }
}

References GNUNET_TRANSPORT_TESTING_InternalPeerContext::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::connect_task, do_connect(), GNUNET_ERROR_TYPE_INFO, GNUNET_i2s(), GNUNET_log, GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_UNIT_SECONDS, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::num_peers, GNUNET_TRANSPORT_TESTING_InternalPeerContext::off, p, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::pre_connect_task, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::pre_connect_task_cls, and GNUNET_TRANSPORT_TESTING_ConnectCheckContext::started.

Referenced by connect_check_run(), and GNUNET_TRANSPORT_TESTING_start_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

connect_check_run()

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

static

Function run from GNUNET_TRANSPORT_TESTING_connect_check once the scheduler is up.

Should launch the peers and then in the continuations try to connect them.

Parameters

cls	our struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *
args	ignored
cfgfile	ignored
cfg	configuration

Definition at line 443 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = cls;
  int ok;
 
  ccc->cfg = cfg;
  ccc->timeout_task = GNUNET_SCHEDULER_add_delayed (ccc->timeout,
                                                    &do_timeout,
                                                    ccc);
  GNUNET_SCHEDULER_add_shutdown (&do_shutdown,
                                 ccc);
  ok = GNUNET_OK;
  for (unsigned int i = 0; i < ccc->num_peers; i++)
  {
    struct GNUNET_MQ_MessageHandler handlers[] = {
      GNUNET_MQ_hd_var_size (test,
                             GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE,
                             struct GNUNET_TRANSPORT_TESTING_TestMessage,
                             NULL),
      GNUNET_MQ_hd_var_size (test2,
                             GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE2,
                             struct GNUNET_TRANSPORT_TESTING_TestMessage,
                             NULL),
      GNUNET_MQ_handler_end ()
    };
    ccc->p[i] = GNUNET_TRANSPORT_TESTING_start_peer (ccc->tth,
                                                     ccc->cfg_files[i],
                                                     i + 1,
                                                     handlers,
                                                     &my_nc,
                                                     &my_nd,
                                                     &ccc->ip[i],
                                                     &start_cb,
                                                     &ccc->ip[i]);
    if (NULL == ccc->p[i])
      ok = GNUNET_SYSERR;
  }
  if (GNUNET_OK != ok)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Fail! Could not start peers!\n");
    GNUNET_SCHEDULER_shutdown ();
  }
}

References cfg, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cfg, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cfg_files, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, do_shutdown(), do_timeout(), GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MQ_handler_end, GNUNET_MQ_hd_var_size, GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_add_shutdown(), GNUNET_SCHEDULER_shutdown(), GNUNET_SYSERR, GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE, GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE2, GNUNET_TRANSPORT_TESTING_start_peer(), handlers, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::ip, my_nc(), my_nd(), GNUNET_TRANSPORT_TESTING_ConnectCheckContext::num_peers, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, start_cb(), GNUNET_TRANSPORT_TESTING_ConnectCheckContext::timeout, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::timeout_task, and GNUNET_TRANSPORT_TESTING_ConnectCheckContext::tth.

Referenced by GNUNET_TRANSPORT_TESTING_connect_check().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TRANSPORT_TESTING_connect_check()

int GNUNET_TRANSPORT_TESTING_connect_check	(	void *	cls,
		struct GNUNET_TRANSPORT_TESTING_Handle *	tth_,
		const char *	test_plugin_,
		const char *	test_name_,
		unsigned int	num_peers,
		char *	cfg_files[]
	)

Common implementation of the GNUNET_TRANSPORT_TESTING_CheckCallback.

Starts and connects the two peers, then invokes the connect_continuation from cls. Sets up a timeout to abort the test, and a shutdown handler to clean up properly on exit.

Parameters

cls	closure of type struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext
tth_	initialized testing handle
test_plugin_	name of the plugin
test_name_	name of the test
num_peers	number of entries in the cfg_file array
cfg_files	array of names of configuration files for the peers

Returns

GNUNET_SYSERR on error

Definition at line 508 of file transport-testing-main2.c.

{
  static struct GNUNET_GETOPT_CommandLineOption options[] = {
    GNUNET_GETOPT_OPTION_END
  };
  struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc = cls;
  struct GNUNET_TRANSPORT_TESTING_PeerContext *p[num_peers];
  struct GNUNET_TRANSPORT_TESTING_InternalPeerContext ip[num_peers];
  char *argv[] = {
    (char *) test_name_,
    "-c",
    (char *) ccc->config_file,
    NULL
  };
 
  ccc->num_peers = num_peers;
  ccc->cfg_files = cfg_files;
  ccc->test_plugin = test_plugin_;
  ccc->test_name = test_name_;
  ccc->tth = tth_;
  ccc->global_ret = GNUNET_OK;
  ccc->p = p;
  ccc->ip = ip;
  for (unsigned int i = 0; i < num_peers; i++)
  {
    ip[i].off = i;
    ip[i].ccc = ccc;
  }
  if (GNUNET_OK !=
      GNUNET_PROGRAM_run ((sizeof(argv) / sizeof(char *)) - 1,
                          argv,
                          test_name_,
                          "nohelp",
                          options,
                          &connect_check_run,
                          ccc))
    return GNUNET_SYSERR;
  return ccc->global_ret;
}

References GNUNET_TRANSPORT_TESTING_InternalPeerContext::ccc, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cfg_files, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::cls, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::config_file, connect_check_run(), GNUNET_TRANSPORT_TESTING_ConnectCheckContext::global_ret, GNUNET_GETOPT_OPTION_END, GNUNET_OK, GNUNET_PROGRAM_run(), GNUNET_SYSERR, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::ip, num_peers, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::num_peers, GNUNET_TRANSPORT_TESTING_InternalPeerContext::off, options, p, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::p, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::test_name, GNUNET_TRANSPORT_TESTING_ConnectCheckContext::test_plugin, and GNUNET_TRANSPORT_TESTING_ConnectCheckContext::tth.

Here is the call graph for this function:

GNUNET_TRANSPORT_TESTING_main_()

int GNUNET_TRANSPORT_TESTING_main_	(	const char *	argv0,
		const char *	filename,
		unsigned int	num_peers,
		GNUNET_TRANSPORT_TESTING_CheckCallback	check,
		void *	check_cls
	)

Setup testcase.

Calls check with the data the test needs.

Parameters

argv0	binary name (argv[0])
filename	source file name (FILE)
num_peers	number of peers to start
check	main function to run
check_cls	closure for check

Returns

GNUNET_OK on success

Definition at line 566 of file transport-testing-main2.c.

{
  struct GNUNET_TRANSPORT_TESTING_Handle *tth;
  char *test_name;
  char *test_source;
  char *test_plugin;
  char *cfg_names[num_peers];
  int ret;
 
  ret = GNUNET_OK;
  test_name = GNUNET_TRANSPORT_TESTING_get_test_name (argv0);
  GNUNET_log_setup (test_name,
                    "WARNING",
                    NULL);
  test_source = GNUNET_TRANSPORT_TESTING_get_test_source_name (filename);
  test_plugin = GNUNET_TRANSPORT_TESTING_get_test_plugin_name (argv0,
                                                               test_source);
  for (unsigned int i = 0; i < num_peers; i++)
    cfg_names[i] = GNUNET_TRANSPORT_TESTING_get_config_name (argv0,
                                                             i + 1);
  tth = GNUNET_TRANSPORT_TESTING_init ();
  if (NULL == tth)
  {
    ret = GNUNET_SYSERR;
  }
  else
  {
    ret = check (check_cls,
                 tth,
                 test_plugin,
                 test_name,
                 num_peers,
                 cfg_names);
    GNUNET_TRANSPORT_TESTING_done (tth);
  }
  for (unsigned int i = 0; i < num_peers; i++)
    GNUNET_free (cfg_names[i]);
  GNUNET_free (test_source);
  GNUNET_free (test_plugin);
  GNUNET_free (test_name);
  return ret;
}

References filename, GNUNET_free, GNUNET_log_setup(), GNUNET_OK, GNUNET_SYSERR, GNUNET_TRANSPORT_TESTING_done(), GNUNET_TRANSPORT_TESTING_get_config_name(), GNUNET_TRANSPORT_TESTING_get_test_name(), GNUNET_TRANSPORT_TESTING_get_test_plugin_name(), GNUNET_TRANSPORT_TESTING_get_test_source_name(), GNUNET_TRANSPORT_TESTING_init(), num_peers, and ret.

Here is the call graph for this function: