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

Include dependency graph for transport-testing2.c:

Macros
#define	LOG(kind, ...) GNUNET_log_from (kind, "transport-testing", __VA_ARGS__)

Functions
static struct GNUNET_TRANSPORT_TESTING_PeerContext *	find_peer_context (struct GNUNET_TRANSPORT_TESTING_Handle tth, const struct GNUNET_PeerIdentity peer)

void	GNUNET_TRANSPORT_TESTING_find_connecting_context (struct GNUNET_TRANSPORT_TESTING_PeerContext p1, struct GNUNET_TRANSPORT_TESTING_PeerContext p2, GNUNET_TRANSPORT_TESTING_ConnectContextCallback cb, void *cb_cls)
	Find any connecting context matching the given pair of peers. More...

static void	set_p1c (void cls, struct GNUNET_TRANSPORT_TESTING_ConnectRequest cx)

static void	set_mq (void cls, struct GNUNET_TRANSPORT_TESTING_ConnectRequest cx)

static void	set_p2c (void cls, struct GNUNET_TRANSPORT_TESTING_ConnectRequest cx)

static void	clear_p1c (void cls, struct GNUNET_TRANSPORT_TESTING_ConnectRequest cx)

static void	clear_p2c (void cls, struct GNUNET_TRANSPORT_TESTING_ConnectRequest cx)

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

static void	offer_hello (void *cls)
	Offer the current HELLO of P2 to P1. More...

static void	notify_disconnect (void cls, const struct GNUNET_PeerIdentity peer, void *handler_cls)

static void	retrieve_hello (void *cls)

static void	hello_iter_cb (void cb_cls, const struct GNUNET_PEERSTORE_Record record, const char *emsg)

struct GNUNET_TRANSPORT_TESTING_PeerContext *	GNUNET_TRANSPORT_TESTING_start_peer (struct GNUNET_TRANSPORT_TESTING_Handle tth, const char cfgname, int peer_id, const struct GNUNET_MQ_MessageHandler handlers, GNUNET_TRANSPORT_NotifyConnect nc, GNUNET_TRANSPORT_NotifyDisconnect nd, void cb_cls, GNUNET_SCHEDULER_TaskCallback start_cb, void *start_cb_cls)
	Start a peer with the given configuration. More...

int	GNUNET_TRANSPORT_TESTING_restart_peer (struct GNUNET_TRANSPORT_TESTING_PeerContext p, GNUNET_SCHEDULER_TaskCallback restart_cb, void restart_cb_cls)
	Stops and restarts the given peer, sleeping (!) for 5s in between. More...

void	GNUNET_TRANSPORT_TESTING_stop_peer (struct GNUNET_TRANSPORT_TESTING_PeerContext *p)
	Shutdown the given peer. More...

struct GNUNET_TRANSPORT_TESTING_ConnectRequest *	GNUNET_TRANSPORT_TESTING_connect_peers (struct GNUNET_TRANSPORT_TESTING_PeerContext p1, struct GNUNET_TRANSPORT_TESTING_PeerContext p2, GNUNET_SCHEDULER_TaskCallback cb, void *cls)
	Initiate a connection from p1 to p2 by offering p1 p2's HELLO message. More...

void	GNUNET_TRANSPORT_TESTING_connect_peers_cancel (struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc)
	Cancel the request to connect two peers. More...

void	GNUNET_TRANSPORT_TESTING_done (struct GNUNET_TRANSPORT_TESTING_Handle *tth)
	Clean up the transport testing. More...

struct GNUNET_TRANSPORT_TESTING_Handle *	GNUNET_TRANSPORT_TESTING_init ()
	Initialize the transport testing. More...

Macro Definition Documentation

◆ LOG

#define LOG	(	kind,
		...
	)	GNUNET_log_from (kind, "transport-testing", __VA_ARGS__)

Definition at line 30 of file transport-testing2.c.

Function Documentation

◆ find_peer_context()

static struct GNUNET_TRANSPORT_TESTING_PeerContext* find_peer_context	(	struct GNUNET_TRANSPORT_TESTING_Handle *	tth,
		const struct GNUNET_PeerIdentity *	peer
	)

static

Definition at line 34 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_PeerContext *t;
  
   for (t = tth->p_head; NULL != t; t = t->next)
     if (0 == memcmp (&t->id,
                      peer,
                      sizeof(struct GNUNET_PeerIdentity)))
       return t;
   return NULL;
 }

References GNUNET_SCHEDULER_Task::next, GNUNET_TRANSPORT_TESTING_Handle::p_head, peer, t, and GNUNET_TRANSPORT_TESTING_PeerContext::tth.

Referenced by notify_connect(), and notify_disconnect().

Here is the caller graph for this function:

◆ GNUNET_TRANSPORT_TESTING_find_connecting_context()

void GNUNET_TRANSPORT_TESTING_find_connecting_context	(	struct GNUNET_TRANSPORT_TESTING_PeerContext *	p1,
		struct GNUNET_TRANSPORT_TESTING_PeerContext *	p2,
		GNUNET_TRANSPORT_TESTING_ConnectContextCallback	cb,
		void *	cb_cls
	)

Find any connecting context matching the given pair of peers.

Parameters

p1	first peer
p2	second peer
cb	function to call
cb_cls	closure for cb

Definition at line 57 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_Handle *tth = p1->tth;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *ccn;
  
   for (cc = tth->cc_head; NULL != cc; cc = ccn)
   {
     ccn = cc->next;
     if ((cc->p1 == p1) &&
         (cc->p2 == p2))
       cb (cb_cls,
           cc);
   }
 }

References GNUNET_TRANSPORT_TESTING_ConnectRequest::cb, GNUNET_TRANSPORT_TESTING_ConnectRequest::cb_cls, GNUNET_TRANSPORT_TESTING_Handle::cc_head, GNUNET_TRANSPORT_TESTING_ConnectRequest::next, GNUNET_TRANSPORT_TESTING_ConnectRequest::p1, GNUNET_TRANSPORT_TESTING_ConnectRequest::p2, and GNUNET_TRANSPORT_TESTING_PeerContext::tth.

Referenced by notify_connect(), and notify_disconnect().

Here is the caller graph for this function:

◆ set_p1c()

static void set_p1c	(	void *	cls,
		struct GNUNET_TRANSPORT_TESTING_ConnectRequest *	cx
	)

static

Definition at line 83 of file transport-testing2.c.

 {
   int *found = cls;
  
   if (NULL != found)
     *found = GNUNET_YES;
   cx->p1_c = GNUNET_YES;
 }

References GNUNET_YES, and GNUNET_TRANSPORT_TESTING_ConnectRequest::p1_c.

Referenced by notify_connect().

Here is the caller graph for this function:

◆ set_mq()

static void set_mq	(	void *	cls,
		struct GNUNET_TRANSPORT_TESTING_ConnectRequest *	cx
	)

static

Definition at line 95 of file transport-testing2.c.

 {
   struct GNUNET_MQ_Handle *mq = cls;
  
   cx->mq = mq;
 }

References mq, and GNUNET_TRANSPORT_TESTING_ConnectRequest::mq.

Referenced by notify_connect(), and notify_disconnect().

Here is the caller graph for this function:

◆ set_p2c()

static void set_p2c	(	void *	cls,
		struct GNUNET_TRANSPORT_TESTING_ConnectRequest *	cx
	)

static

Definition at line 105 of file transport-testing2.c.

 {
   int *found = cls;
  
   if (NULL != found)
     *found = GNUNET_YES;
   cx->p2_c = GNUNET_YES;
 }

References GNUNET_YES, and GNUNET_TRANSPORT_TESTING_ConnectRequest::p2_c.

Referenced by notify_connect().

Here is the caller graph for this function:

◆ clear_p1c()

static void clear_p1c	(	void *	cls,
		struct GNUNET_TRANSPORT_TESTING_ConnectRequest *	cx
	)

static

Definition at line 117 of file transport-testing2.c.

 {
   int *found = cls;
  
   if (NULL != found)
     *found = GNUNET_YES;
   cx->p1_c = GNUNET_NO;
 }

References GNUNET_NO, GNUNET_YES, and GNUNET_TRANSPORT_TESTING_ConnectRequest::p1_c.

Referenced by notify_disconnect().

Here is the caller graph for this function:

◆ clear_p2c()

static void clear_p2c	(	void *	cls,
		struct GNUNET_TRANSPORT_TESTING_ConnectRequest *	cx
	)

static

Definition at line 129 of file transport-testing2.c.

 {
   int *found = cls;
  
   if (NULL != found)
     *found = GNUNET_YES;
   cx->p2_c = GNUNET_NO;
 }

References GNUNET_NO, GNUNET_YES, and GNUNET_TRANSPORT_TESTING_ConnectRequest::p2_c.

Referenced by notify_disconnect().

Here is the caller graph for this function:

◆ notify_connect()

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

static

Definition at line 141 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cls;
   struct GNUNET_TRANSPORT_TESTING_Handle *tth = p->tth;
   char *p2_s;
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p2;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *ccn;
   int found;
   void *ret;
  
   p2 = find_peer_context (p->tth,
                           peer);
   if (NULL != p->nc)
     ret = p->nc (p->cb_cls,
                  peer,
                  mq);
   else
     ret = NULL;
  
   if (NULL != p2)
     GNUNET_asprintf (&p2_s,
                      "%u (`%s')",
                      p2->no,
                      GNUNET_i2s (&p2->id));
   else
     GNUNET_asprintf (&p2_s,
                      "`%s'",
                      GNUNET_i2s (peer));
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Peers %s connected to peer %u (`%s')\n",
        p2_s,
        p->no,
        GNUNET_i2s (&p->id));
   GNUNET_free (p2_s);
   /* update flags in connecting contexts */
   found = GNUNET_NO;
   GNUNET_TRANSPORT_TESTING_find_connecting_context (p,
                                                     p2,
                                                     &set_p1c,
                                                     &found);
   if (GNUNET_NO == found)
   {
     cc = GNUNET_new (struct GNUNET_TRANSPORT_TESTING_ConnectRequest);
     cc->p1 = p;
     cc->p2 = p2;
     cc->p1_c = GNUNET_YES;
     GNUNET_CONTAINER_DLL_insert (tth->cc_head,
                                  tth->cc_tail,
                                  cc);
   }
   found = GNUNET_NO;
   GNUNET_TRANSPORT_TESTING_find_connecting_context (p2,
                                                     p,
                                                     &set_p2c,
                                                     &found);
   if (GNUNET_NO == found)
   {
     cc = GNUNET_new (struct GNUNET_TRANSPORT_TESTING_ConnectRequest);
     cc->p1 = p2;
     cc->p2 = p;
     cc->p1_c = GNUNET_YES;
     GNUNET_CONTAINER_DLL_insert (tth->cc_head,
                                  tth->cc_tail,
                                  cc);
   }
   GNUNET_TRANSPORT_TESTING_find_connecting_context (p,
                                                     p2,
                                                     &set_mq,
                                                     mq);
   /* update set connected flag for all requests */
   for (cc = tth->cc_head; NULL != cc; cc = cc->next)
   {
     if (GNUNET_YES == cc->connected)
       continue;
     if ((GNUNET_YES == cc->p1_c) &&
         (GNUNET_YES == cc->p2_c))
     {
       cc->connected = GNUNET_YES;
       /* stop trying to connect */
       if (NULL != cc->tct)
       {
         GNUNET_SCHEDULER_cancel (cc->tct);
         cc->tct = NULL;
       }
       if (NULL != cc->ats_sh)
       {
         GNUNET_ATS_connectivity_suggest_cancel (cc->ats_sh);
         cc->ats_sh = NULL;
       }
     }
   }
   /* then notify application */
   for (cc = tth->cc_head; NULL != cc; cc = ccn)
   {
     ccn = cc->next;
     if ((GNUNET_YES == cc->connected) &&
         (NULL != cc->cb))
     {
       cc->cb (cc->cb_cls);
       cc->cb = NULL;     /* only notify once! */
     }
   }
   return ret;
 }

Referenced by GNUNET_TRANSPORT_TESTING_restart_peer(), and GNUNET_TRANSPORT_TESTING_start_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ offer_hello()

static void offer_hello ( void * cls )

static

Offer the current HELLO of P2 to P1.

Function called after the HELLO was passed to the transport service.

Parameters

cls	our `struct GNUNET_TRANSPORT_TESTING_ConnectRequest`

FIXME maybe schedule the application_validate somehow

Definition at line 735 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc = cls;
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p1 = cc->p1;
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p2 = cc->p2;
   struct GNUNET_TIME_Absolute t;
   enum GNUNET_NetworkType nt = 0;
   char *addr;
  
   cc->tct = NULL;
   {
     char *p2_s = GNUNET_strdup (GNUNET_i2s (&p2->id));
  
     LOG (GNUNET_ERROR_TYPE_DEBUG,
          "Asking peer %u (`%s') to connect peer %u (`%s'), providing HELLO with %s\n",
          p1->no,
          GNUNET_i2s (&p1->id),
          p2->no,
          p2_s,
          p2->hello);
     GNUNET_free (p2_s);
   }
  
   addr = GNUNET_HELLO_extract_address (p2->hello,
                                        p2->hello_size,
                                        &p2->id,
                                        &nt,
                                        &t);
   GNUNET_assert (NULL != addr);
   GNUNET_assert (NULL != p1->hello);
   GNUNET_TRANSPORT_application_validate (p1->ah,
                                          &p2->id,
                                          nt,
                                          addr);
   GNUNET_free (addr);
 }

Referenced by GNUNET_TRANSPORT_TESTING_connect_peers(), and notify_disconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ notify_disconnect()

static void notify_disconnect	(	void *	cls,
		const struct GNUNET_PeerIdentity *	peer,
		void *	handler_cls
	)

static

Definition at line 260 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cls;
   struct GNUNET_TRANSPORT_TESTING_Handle *tth = p->tth;
   char *p2_s;
   /* Find PeerContext */
   int no = 0;
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p2 = NULL;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
  
   p2 = find_peer_context (p->tth,
                           peer);
   no = p->no;
   if (NULL != p2)
     GNUNET_asprintf (&p2_s,
                      "%u (`%s')",
                      p2->no,
                      GNUNET_i2s (&p2->id));
   else
     GNUNET_asprintf (&p2_s,
                      "`%s'",
                      GNUNET_i2s (peer));
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Peers %s disconnected from peer %u (`%s')\n",
        p2_s,
        no,
        GNUNET_i2s (&p->id));
   GNUNET_free (p2_s);
   /* notify about disconnect */
   if (NULL != p->nd)
     p->nd (p->cb_cls,
            peer,
            handler_cls);
   if (NULL == p2)
     return;
   /* clear MQ, it is now invalid */
   GNUNET_TRANSPORT_TESTING_find_connecting_context (p,
                                                     p2,
                                                     &set_mq,
                                                     NULL);
   /* update set connected flags for all requests */
   GNUNET_TRANSPORT_TESTING_find_connecting_context (p,
                                                     p2,
                                                     &clear_p1c,
                                                     NULL);
   GNUNET_TRANSPORT_TESTING_find_connecting_context (p2,
                                                     p,
                                                     &clear_p2c,
                                                     NULL);
   /* resume connectivity requests as necessary */
   for (cc = tth->cc_head; NULL != cc; cc = cc->next)
   {
     if (GNUNET_NO == cc->connected)
       continue;
     if ((GNUNET_YES != cc->p1_c) ||
         (GNUNET_YES != cc->p2_c))
     {
       cc->connected = GNUNET_NO;
       /* start trying to connect */
       if (NULL == cc->tct)
         cc->tct = GNUNET_SCHEDULER_add_now (&offer_hello,
                                             cc);
       if (NULL == cc->ats_sh)
         cc->ats_sh = GNUNET_ATS_connectivity_suggest (cc->p1->ats,
                                                       &p2->id,
                                                       1);
     }
   }
 }

Referenced by GNUNET_TRANSPORT_TESTING_restart_peer(), and GNUNET_TRANSPORT_TESTING_start_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ retrieve_hello()

static void retrieve_hello ( void * cls )

static

Definition at line 369 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cls;
   p->rh_task = NULL;
   p->pic = GNUNET_PEERSTORE_iterate (p->ph,
                                      "transport",
                                      &p->id,
                                      GNUNET_PEERSTORE_TRANSPORT_HELLO_KEY,
                                      hello_iter_cb,
                                      p);
  
 }

References GNUNET_PEERSTORE_iterate(), GNUNET_PEERSTORE_TRANSPORT_HELLO_KEY, hello_iter_cb(), and p.

Referenced by GNUNET_TRANSPORT_TESTING_start_peer(), and hello_iter_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ hello_iter_cb()

static void hello_iter_cb	(	void *	cb_cls,
		const struct GNUNET_PEERSTORE_Record *	record,
		const char *	emsg
	)

static

Definition at line 336 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cb_cls;
   if (NULL == record)
   {
     p->pic = NULL;
     if (NULL != p->start_cb)
       p->rh_task = GNUNET_SCHEDULER_add_now (retrieve_hello, p);
     return;
   }
   // Check record type et al?
   p->hello_size = record->value_size;
   p->hello = GNUNET_malloc (p->hello_size);
   memcpy (p->hello, record->value, p->hello_size);
   p->hello[p->hello_size - 1] = '\0';
  
   GNUNET_PEERSTORE_iterate_cancel (p->pic);
   p->pic = NULL;
   if (NULL != p->start_cb)
   {
     LOG (GNUNET_ERROR_TYPE_DEBUG,
          "Peer %u (`%s') successfully started\n",
          p->no,
          GNUNET_i2s (&p->id));
     p->start_cb (p->start_cb_cls);
     p->start_cb = NULL;
   }
 }

References GNUNET_TRANSPORT_TESTING_PeerContext::cb_cls, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_malloc, GNUNET_PEERSTORE_iterate_cancel(), GNUNET_SCHEDULER_add_now(), LOG, p, record(), and retrieve_hello().

Referenced by GNUNET_TRANSPORT_TESTING_restart_peer(), and retrieve_hello().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_TRANSPORT_TESTING_start_peer()

struct GNUNET_TRANSPORT_TESTING_PeerContext* GNUNET_TRANSPORT_TESTING_start_peer	(	struct GNUNET_TRANSPORT_TESTING_Handle *	tth,
		const char *	cfgname,
		int	peer_id,
		const struct GNUNET_MQ_MessageHandler *	handlers,
		GNUNET_TRANSPORT_NotifyConnect	nc,
		GNUNET_TRANSPORT_NotifyDisconnect	nd,
		void *	cb_cls,
		GNUNET_SCHEDULER_TaskCallback	start_cb,
		void *	start_cb_cls
	)

Start a peer with the given configuration.

Parameters

tth	the testing handle
cfgname	configuration file
peer_id	the peer_id
handlers	functions for receiving messages
nc	connect callback
nd	disconnect callback
cb_cls	closure for nc and nd callback
start_cb	start callback
start_cb_cls	closure for start_cb

Returns: the peer context

Parameters

tth	the testing handle
cfgname	configuration file
peer_id	a unique number to identify the peer
handlers	functions for receiving messages
nc	connect callback
nd	disconnect callback
cb_cls	closure for callback
start_cb	start callback
start_cb_cls	closure for callback

Returns: the peer context

Definition at line 384 of file transport-testing2.c.

 {
   char *emsg = NULL;
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p;
   struct GNUNET_PeerIdentity dummy;
   unsigned int i;
  
   if (GNUNET_NO == GNUNET_DISK_file_test (cfgname))
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "File not found: `%s'\n",
          cfgname);
     return NULL;
   }
  
   p = GNUNET_new (struct GNUNET_TRANSPORT_TESTING_PeerContext);
   p->tth = tth;
   p->nc = nc;
   p->nd = nd;
   if (NULL != handlers)
   {
     for (i = 0; NULL != handlers[i].cb; i++)
       ;
     p->handlers = GNUNET_new_array (i + 1,
                                     struct GNUNET_MQ_MessageHandler);
     GNUNET_memcpy (p->handlers,
                    handlers,
                    i * sizeof(struct GNUNET_MQ_MessageHandler));
   }
   if (NULL != cb_cls)
     p->cb_cls = cb_cls;
   else
     p->cb_cls = p;
   p->start_cb = start_cb;
   if (NULL != start_cb_cls)
     p->start_cb_cls = start_cb_cls;
   else
     p->start_cb_cls = p;
   GNUNET_CONTAINER_DLL_insert (tth->p_head,
                                tth->p_tail,
                                p);
  
   /* Create configuration and call testing lib to modify it */
   p->cfg = GNUNET_CONFIGURATION_create ();
   GNUNET_assert (GNUNET_OK ==
                  GNUNET_CONFIGURATION_load (p->cfg, cfgname));
   if (GNUNET_SYSERR ==
       GNUNET_TESTING_configuration_create (tth->tl_system,
                                            p->cfg))
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Testing library failed to create unique configuration based on `%s'\n",
          cfgname);
     GNUNET_CONFIGURATION_destroy (p->cfg);
     GNUNET_free (p);
     return NULL;
   }
  
   p->no = peer_id;
   /* Configure peer with configuration */
   p->peer = GNUNET_TESTING_peer_configure (tth->tl_system,
                                            p->cfg,
                                            p->no,
                                            NULL,
                                            &emsg);
   if (NULL == p->peer)
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Testing library failed to create unique configuration based on `%s': `%s'\n",
          cfgname,
          emsg);
     GNUNET_TRANSPORT_TESTING_stop_peer (p);
     GNUNET_free (emsg);
     return NULL;
   }
  
   if (GNUNET_OK != GNUNET_TESTING_peer_start (p->peer))
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Testing library failed to create unique configuration based on `%s'\n",
          cfgname);
     GNUNET_TRANSPORT_TESTING_stop_peer (p);
     return NULL;
   }
  
   memset (&dummy,
           '\0',
           sizeof(dummy));
   GNUNET_TESTING_peer_get_identity (p->peer,
                                     &p->id);
   if (0 == memcmp (&dummy,
                    &p->id,
                    sizeof(struct GNUNET_PeerIdentity)))
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Testing library failed to obtain peer identity for peer %u\n",
          p->no);
     GNUNET_TRANSPORT_TESTING_stop_peer (p);
     return NULL;
   }
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Peer %u configured with identity `%s'\n",
        p->no,
        GNUNET_i2s_full (&p->id));
   p->th = GNUNET_TRANSPORT_core_connect (p->cfg,
                                          NULL,
                                          handlers,
                                          p,
                                          &notify_connect,
                                          &notify_disconnect);
   if (NULL == p->th)
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Failed to connect to transport service for peer `%s': `%s'\n",
          cfgname,
          emsg);
     GNUNET_TRANSPORT_TESTING_stop_peer (p);
     GNUNET_free (emsg);
     return NULL;
   }
   p->ats = GNUNET_ATS_connectivity_init (p->cfg);
   if (NULL == p->ats)
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Failed to connect to ATS service for peer `%s': `%s'\n",
          cfgname,
          emsg);
     GNUNET_TRANSPORT_TESTING_stop_peer (p);
     GNUNET_free (emsg);
     return NULL;
   }
   p->ph = GNUNET_PEERSTORE_connect (p->cfg);
   // FIXME Error handling
   p->ah = GNUNET_TRANSPORT_application_init (p->cfg);
   GNUNET_assert (NULL != p->ah);
   // FIXME Error handling
   p->rh_task = GNUNET_SCHEDULER_add_now (retrieve_hello, p);
  
   return p;
 }

References dummy, GNUNET_assert, GNUNET_ATS_connectivity_init(), GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_destroy(), GNUNET_CONFIGURATION_load(), GNUNET_CONTAINER_DLL_insert, GNUNET_DISK_file_test(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_i2s_full(), GNUNET_memcpy, GNUNET_new, GNUNET_new_array, GNUNET_NO, GNUNET_OK, GNUNET_PEERSTORE_connect(), GNUNET_SCHEDULER_add_now(), GNUNET_SYSERR, GNUNET_TESTING_configuration_create(), GNUNET_TESTING_peer_configure(), GNUNET_TESTING_peer_get_identity(), GNUNET_TESTING_peer_start(), GNUNET_TRANSPORT_application_init(), GNUNET_TRANSPORT_core_connect(), GNUNET_TRANSPORT_TESTING_stop_peer(), handlers, LOG, nc, notify_connect(), notify_disconnect(), p, GNUNET_TRANSPORT_TESTING_Handle::p_head, GNUNET_TRANSPORT_TESTING_Handle::p_tail, peer_id, retrieve_hello(), start_cb(), and GNUNET_TRANSPORT_TESTING_Handle::tl_system.

Here is the call graph for this function:

◆ GNUNET_TRANSPORT_TESTING_restart_peer()

int GNUNET_TRANSPORT_TESTING_restart_peer	(	struct GNUNET_TRANSPORT_TESTING_PeerContext *	p,
		GNUNET_SCHEDULER_TaskCallback	restart_cb,
		void *	restart_cb_cls
	)

Stops and restarts the given peer, sleeping (!) for 5s in between.

Parameters

p	the peer
restart_cb	restart callback
restart_cb_cls	callback closure

Returns: GNUNET_OK in success otherwise GNUNET_SYSERR

Parameters

p	the peer
restart_cb	callback to call when restarted
restart_cb_cls	callback closure

Returns: GNUNET_OK in success otherwise GNUNET_SYSERR

Definition at line 537 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *ccn;
  
   /* shutdown */
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Stopping peer %u (`%s')\n",
        p->no,
        GNUNET_i2s (&p->id));
   if (NULL != p->pic)
   {
     GNUNET_PEERSTORE_iterate_cancel (p->pic);
     p->pic = NULL;
   }
   if (NULL != p->th)
   {
     GNUNET_TRANSPORT_core_disconnect (p->th);
     p->th = NULL;
   }
   for (cc = p->tth->cc_head; NULL != cc; cc = ccn)
   {
     ccn = cc->next;
     if ((cc->p1 == p) ||
         (cc->p2 == p))
       GNUNET_TRANSPORT_TESTING_connect_peers_cancel (cc);
   }
   if (NULL != p->ats)
   {
     GNUNET_ATS_connectivity_done (p->ats);
     p->ats = NULL;
   }
   if (GNUNET_SYSERR ==
       GNUNET_TESTING_peer_stop (p->peer))
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Failed to stop peer %u (`%s')\n",
          p->no,
          GNUNET_i2s (&p->id));
     return GNUNET_SYSERR;
   }
  
   sleep (5);  // YUCK!
  
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Restarting peer %u (`%s')\n",
        p->no,
        GNUNET_i2s (&p->id));
   /* restart */
   if (GNUNET_SYSERR == GNUNET_TESTING_peer_start (p->peer))
   {
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Failed to restart peer %u (`%s')\n",
          p->no,
          GNUNET_i2s (&p->id));
     return GNUNET_SYSERR;
   }
  
   GNUNET_assert (NULL == p->start_cb);
   p->start_cb = restart_cb;
   p->start_cb_cls = restart_cb_cls;
  
   p->th = GNUNET_TRANSPORT_core_connect (p->cfg,
                                          NULL,
                                          p->handlers,
                                          p,
                                          &notify_connect,
                                          &notify_disconnect);
   GNUNET_assert (NULL != p->th);
   p->ats = GNUNET_ATS_connectivity_init (p->cfg);
   p->pic = GNUNET_PEERSTORE_iterate (p->ph,
                                      "transport",
                                      &p->id,
                                      GNUNET_PEERSTORE_TRANSPORT_HELLO_KEY,
                                      hello_iter_cb,
                                      p);
   GNUNET_assert (NULL != p->pic);
   return GNUNET_OK;
 }

References GNUNET_assert, GNUNET_ATS_connectivity_done(), GNUNET_ATS_connectivity_init(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_i2s(), GNUNET_OK, GNUNET_PEERSTORE_iterate(), GNUNET_PEERSTORE_iterate_cancel(), GNUNET_PEERSTORE_TRANSPORT_HELLO_KEY, GNUNET_SYSERR, GNUNET_TESTING_peer_start(), GNUNET_TESTING_peer_stop(), GNUNET_TRANSPORT_core_connect(), GNUNET_TRANSPORT_core_disconnect(), GNUNET_TRANSPORT_TESTING_connect_peers_cancel(), hello_iter_cb(), LOG, GNUNET_TRANSPORT_TESTING_ConnectRequest::next, notify_connect(), notify_disconnect(), p, GNUNET_TRANSPORT_TESTING_ConnectRequest::p1, and GNUNET_TRANSPORT_TESTING_ConnectRequest::p2.

Here is the call graph for this function:

◆ GNUNET_TRANSPORT_TESTING_stop_peer()

void GNUNET_TRANSPORT_TESTING_stop_peer ( struct GNUNET_TRANSPORT_TESTING_PeerContext * p )

Shutdown the given peer.

Parameters

p the peer

Definition at line 627 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_Handle *tth = p->tth;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *ccn;
   /* shutdown */
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Stopping peer %u (`%s')\n",
        p->no,
        GNUNET_i2s (&p->id));
  
   for (cc = tth->cc_head; NULL != cc; cc = ccn)
   {
     ccn = cc->next;
     if ((cc->p1 == p) ||
         (cc->p2 == p))
       GNUNET_TRANSPORT_TESTING_connect_peers_cancel (cc);
   }
   if (NULL != p->pic)
   {
     GNUNET_PEERSTORE_iterate_cancel (p->pic);
     p->pic = NULL;
   }
   if (NULL != p->th)
   {
     GNUNET_TRANSPORT_core_disconnect (p->th);
     p->th = NULL;
   }
   if (NULL != p->ats)
   {
     GNUNET_ATS_connectivity_done (p->ats);
     p->ats = NULL;
   }
   if (NULL != p->ah)
   {
     GNUNET_TRANSPORT_application_done (p->ah);
     p->ah = NULL;
   }
   if (NULL != p->ph)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Disconnecting from PEERSTORE service\n");
     GNUNET_PEERSTORE_disconnect (p->ph, GNUNET_NO);
     p->ph = NULL;
   }
  
   if (NULL != p->peer)
   {
     if (GNUNET_OK !=
         GNUNET_TESTING_peer_stop (p->peer))
     {
       LOG (GNUNET_ERROR_TYPE_DEBUG,
            "Testing lib failed to stop peer %u (`%s')\n",
            p->no,
            GNUNET_i2s (&p->id));
     }
     GNUNET_TESTING_peer_destroy (p->peer);
     p->peer = NULL;
   }
   if (NULL != p->hello)
   {
     GNUNET_free (p->hello);
     p->hello = NULL;
   }
   if (NULL != p->cfg)
   {
     GNUNET_CONFIGURATION_destroy (p->cfg);
     p->cfg = NULL;
   }
   if (NULL != p->handlers)
   {
     GNUNET_free (p->handlers);
     p->handlers = NULL;
   }
   GNUNET_CONTAINER_DLL_remove (tth->p_head,
                                tth->p_tail,
                                p);
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Peer %u (`%s') stopped\n",
        p->no,
        GNUNET_i2s (&p->id));
   if (NULL != p->rh_task)
     GNUNET_SCHEDULER_cancel (p->rh_task);
   p->rh_task = NULL;
   GNUNET_free (p);
 }

References GNUNET_TRANSPORT_TESTING_Handle::cc_head, GNUNET_ATS_connectivity_done(), GNUNET_CONFIGURATION_destroy(), GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_i2s(), GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_PEERSTORE_disconnect(), GNUNET_PEERSTORE_iterate_cancel(), GNUNET_SCHEDULER_cancel(), GNUNET_TESTING_peer_destroy(), GNUNET_TESTING_peer_stop(), GNUNET_TRANSPORT_application_done(), GNUNET_TRANSPORT_core_disconnect(), GNUNET_TRANSPORT_TESTING_connect_peers_cancel(), LOG, GNUNET_TRANSPORT_TESTING_ConnectRequest::next, p, GNUNET_TRANSPORT_TESTING_ConnectRequest::p1, GNUNET_TRANSPORT_TESTING_ConnectRequest::p2, GNUNET_TRANSPORT_TESTING_Handle::p_head, and GNUNET_TRANSPORT_TESTING_Handle::p_tail.

Referenced by GNUNET_TRANSPORT_TESTING_done(), and GNUNET_TRANSPORT_TESTING_start_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_TRANSPORT_TESTING_connect_peers()

struct GNUNET_TRANSPORT_TESTING_ConnectRequest* GNUNET_TRANSPORT_TESTING_connect_peers	(	struct GNUNET_TRANSPORT_TESTING_PeerContext *	p1,
		struct GNUNET_TRANSPORT_TESTING_PeerContext *	p2,
		GNUNET_SCHEDULER_TaskCallback	cb,
		void *	cls
	)

Initiate a connection from p1 to p2 by offering p1 p2's HELLO message.

Connect the given peers and call the callback when both peers report the inbound connection.

Remarks: start_peer's notify_connect callback can be called before.

Parameters

tth	transport testing handle
p1	peer 1
p2	peer 2
cb	the callback to call when both peers notified that they are connected
cls	callback cls

Returns: a connect request handle

Definition at line 786 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_Handle *tth = p1->tth;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *ccn;
  
   ccn = NULL;
   for (cc = tth->cc_head; NULL != cc; cc = cc->next)
   {
     if ((cc->p1 == p1) &&
         (cc->p2 == p2))
     {
       ccn = cc;
       break;
     }
   }
  
   cc = GNUNET_new (struct GNUNET_TRANSPORT_TESTING_ConnectRequest);
   cc->p1 = p1;
   cc->p2 = p2;
   cc->cb = cb;
   if (NULL != cls)
     cc->cb_cls = cls;
   else
     cc->cb_cls = cc;
   if (NULL != ccn)
   {
     cc->p1_c = ccn->p1_c;
     cc->p2_c = ccn->p2_c;
     cc->connected = ccn->connected;
   }
   GNUNET_CONTAINER_DLL_insert (tth->cc_head,
                                tth->cc_tail,
                                cc);
   cc->tct = GNUNET_SCHEDULER_add_now (&offer_hello,
                                       cc);
   cc->ats_sh = GNUNET_ATS_connectivity_suggest (cc->p1->ats,
                                                 &p2->id,
                                                 1);
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "New connect request %p\n",
        cc);
   return cc;
 }

Here is the call graph for this function:

◆ GNUNET_TRANSPORT_TESTING_connect_peers_cancel()

void GNUNET_TRANSPORT_TESTING_connect_peers_cancel ( struct GNUNET_TRANSPORT_TESTING_ConnectRequest * cc )

Cancel the request to connect two peers.

You MUST cancel the request if you stop the peers before the peers connected successfully.

Parameters

cc	a connect request handle

Cancel the request to connect two peers.

Parameters

tth	transport testing handle
cc	a connect request handle

Definition at line 838 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_Handle *tth = cc->p1->tth;
  
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Canceling connect request!\n");
   if (NULL != cc->tct)
   {
     GNUNET_SCHEDULER_cancel (cc->tct);
     cc->tct = NULL;
   }
   if (NULL != cc->ats_sh)
   {
     GNUNET_ATS_connectivity_suggest_cancel (cc->ats_sh);
     cc->ats_sh = NULL;
   }
   GNUNET_CONTAINER_DLL_remove (tth->cc_head,
                                tth->cc_tail,
                                cc);
   GNUNET_free (cc);
 }

References GNUNET_TRANSPORT_TESTING_ConnectRequest::ats_sh, GNUNET_TRANSPORT_TESTING_Handle::cc_head, GNUNET_TRANSPORT_TESTING_Handle::cc_tail, GNUNET_ATS_connectivity_suggest_cancel(), GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_SCHEDULER_cancel(), LOG, GNUNET_TRANSPORT_TESTING_ConnectRequest::p1, GNUNET_TRANSPORT_TESTING_ConnectRequest::tct, and GNUNET_TRANSPORT_TESTING_PeerContext::tth.

Referenced by GNUNET_TRANSPORT_TESTING_done(), GNUNET_TRANSPORT_TESTING_restart_peer(), and GNUNET_TRANSPORT_TESTING_stop_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GNUNET_TRANSPORT_TESTING_done()

void GNUNET_TRANSPORT_TESTING_done ( struct GNUNET_TRANSPORT_TESTING_Handle * tth )

Clean up the transport testing.

Parameters

tth	transport testing handle

Definition at line 869 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *cc;
   struct GNUNET_TRANSPORT_TESTING_ConnectRequest *ct;
   struct GNUNET_TRANSPORT_TESTING_PeerContext *p;
   struct GNUNET_TRANSPORT_TESTING_PeerContext *t;
  
   if (NULL == tth)
     return;
   cc = tth->cc_head;
   while (NULL != cc)
   {
     ct = cc->next;
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Developer forgot to cancel connect request!\n");
     GNUNET_TRANSPORT_TESTING_connect_peers_cancel (cc);
     cc = ct;
   }
   p = tth->p_head;
   while (NULL != p)
   {
     t = p->next;
     LOG (GNUNET_ERROR_TYPE_ERROR,
          "Developer forgot to stop peer!\n");
     GNUNET_TRANSPORT_TESTING_stop_peer (p);
     p = t;
   }
   GNUNET_TESTING_system_destroy (tth->tl_system,
                                  GNUNET_YES);
  
   GNUNET_free (tth);
 }

References GNUNET_TRANSPORT_TESTING_Handle::cc_head, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_TESTING_system_destroy(), GNUNET_TRANSPORT_TESTING_connect_peers_cancel(), GNUNET_TRANSPORT_TESTING_stop_peer(), GNUNET_YES, LOG, GNUNET_TRANSPORT_TESTING_ConnectRequest::next, p, GNUNET_TRANSPORT_TESTING_Handle::p_head, t, GNUNET_TRANSPORT_TESTING_Handle::tl_system, and GNUNET_TRANSPORT_TESTING_PeerContext::tth.

Here is the call graph for this function:

◆ GNUNET_TRANSPORT_TESTING_init()

struct GNUNET_TRANSPORT_TESTING_Handle* GNUNET_TRANSPORT_TESTING_init ( void )

Initialize the transport testing.

Returns: transport testing handle

Definition at line 909 of file transport-testing2.c.

 {
   struct GNUNET_TRANSPORT_TESTING_Handle *tth;
  
   tth = GNUNET_new (struct GNUNET_TRANSPORT_TESTING_Handle);
   tth->tl_system = GNUNET_TESTING_system_create ("transport-testing",
                                                  NULL,
                                                  NULL,
                                                  NULL);
   if (NULL == tth->tl_system)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 "Failed to initialize testing library!\n");
     GNUNET_free (tth);
     return NULL;
   }
   return tth;
 }

References GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, GNUNET_new, GNUNET_TESTING_system_create(), and GNUNET_TRANSPORT_TESTING_Handle::tl_system.

Here is the call graph for this function:

Macros

Functions

Macro Definition Documentation

◆ LOG

Function Documentation

◆ find_peer_context()

◆ GNUNET_TRANSPORT_TESTING_find_connecting_context()

◆ set_p1c()

◆ set_mq()

◆ set_p2c()

◆ clear_p1c()

◆ clear_p2c()

◆ notify_connect()

◆ offer_hello()

◆ notify_disconnect()

◆ retrieve_hello()

◆ hello_iter_cb()

◆ GNUNET_TRANSPORT_TESTING_start_peer()

◆ GNUNET_TRANSPORT_TESTING_restart_peer()

◆ GNUNET_TRANSPORT_TESTING_stop_peer()

◆ GNUNET_TRANSPORT_TESTING_connect_peers()

◆ GNUNET_TRANSPORT_TESTING_connect_peers_cancel()

◆ GNUNET_TRANSPORT_TESTING_done()

◆ GNUNET_TRANSPORT_TESTING_init()