gnunet-service-cadet_paths.c File Reference

Information we track per path. More...

#include "gnunet_pils_service.h"
#include "platform.h"
#include "gnunet-service-cadet_connection.h"
#include "gnunet-service-cadet_tunnels.h"
#include "gnunet-service-cadet_peer.h"
#include "gnunet-service-cadet_paths.h"

Include dependency graph for gnunet-service-cadet_paths.c:

Go to the source code of this file.

Data Structures
struct	CadetPeerPath
	Information regarding a possible path to reach a peer. More...
struct	CheckMatchContext
	Closure for #find_peer_at() and check_match(). More...

Macros
#define	LOG(level, ...)   GNUNET_log_from (level, "cadet-pat", __VA_ARGS__)

Functions
static void	recalculate_path_desirability (struct CadetPeerPath *path)
	Calculate the path's desirability score.
GNUNET_CONTAINER_HeapCostType	GCPP_get_desirability (const struct CadetPeerPath *path)
	Return how much we like keeping the path.
struct CadetConnection *	GCPP_get_connection (struct CadetPeerPath *path, struct CadetPeer *destination, unsigned int off)
	Return connection to destination using path, or return NULL if no such connection exists.
void	GCPP_add_connection (struct CadetPeerPath *path, unsigned int off, struct CadetConnection *cc)
	Notify path that it is used for connection cc which ends at the path's offset off.
void	GCPP_del_connection (struct CadetPeerPath *path, unsigned int off, struct CadetConnection *cc)
	Notify path that it is no longer used for connection cc which ended at the path's offset off.
static void	attach_path (struct CadetPeerPath *path, unsigned int stop_at)
	Tries to attach path to a peer, working backwards from the end and stopping at stop_at.
void	GCPP_release (struct CadetPeerPath *path)
	The owning peer of this path is no longer interested in maintaining it, so the path should be discarded or shortened (in case a previous peer on the path finds the path desirable).
static void	GCPP_update_score (struct CadetPeerPath *path, unsigned int off, int delta)
	Updates the score for an entry on the path based on our experiences with using path.
static int	check_match (void *cls, struct CadetPeerPath *path, unsigned int off)
	Check if the given path is identical on all of the hops until off, and not longer than off.
static void	extend_path (struct CadetPeerPath *path, struct CadetPeer **peers_ext, unsigned int num_peers, int force)
	Extend path path by the num_peers from the peers array, assuming the owners past the current owner want it.
void	GCPP_try_path_from_dht (const struct GNUNET_DHT_PathElement *get_path, unsigned int get_path_length, const struct GNUNET_DHT_PathElement *put_path, unsigned int put_path_length)
	Create a peer path based on the result of a DHT lookup.
struct CadetPeerPath *	GCPP_get_path_from_route (unsigned int path_length, const struct GNUNET_PeerIdentity *pids)
	We got an incoming connection, obtain the corresponding path.
unsigned int	GCPP_get_length (struct CadetPeerPath *path)
	Return the length of the path.
unsigned int	GCPP_find_peer (struct CadetPeerPath *path, struct CadetPeer *cp)
	Find peer's offset on path.
struct CadetPeer *	GCPP_get_peer_at_offset (struct CadetPeerPath *path, unsigned int off)
	Obtain the peer at offset off in path.
const char *	GCPP_2s (struct CadetPeerPath *path)
	Convert a path to a human-readable string.

Detailed Description

Information we track per path.

Author

Bartlomiej Polot

Christian Grothoff

Definition in file gnunet-service-cadet_paths.c.

Macro Definition Documentation

LOG

#define LOG	(		level,
			...
	)		GNUNET_log_from (level, "cadet-pat", __VA_ARGS__)

Definition at line 34 of file gnunet-service-cadet_paths.c.

Function Documentation

recalculate_path_desirability()

static void recalculate_path_desirability ( struct CadetPeerPath *  path )

static

Calculate the path's desirability score.

Parameters

path	path to calculate the score for

Definition at line 73 of file gnunet-service-cadet_paths.c.

{
  double result = 0.0;
 
  for (unsigned int i = 0; i < path->entries_length; i++)
  {
    struct CadetPeer *cp = path->entries[i]->peer;
 
    result += GCP_get_desirability_of_path (cp,
                                            i);
  }
  path->desirability = (GNUNET_CONTAINER_HeapCostType) result;
}

References CadetPeerPath::desirability, CadetPeerPath::entries, CadetPeerPath::entries_length, GCP_get_desirability_of_path(), CadetPeerPathEntry::peer, and result.

Referenced by attach_path(), GCPP_get_path_from_route(), and GCPP_update_score().

Here is the call graph for this function:

Here is the caller graph for this function:

GCPP_get_desirability()

GNUNET_CONTAINER_HeapCostType GCPP_get_desirability

(

const struct CadetPeerPath *

path

)

Return how much we like keeping the path.

This is an aggregate score based on various factors, including the age of the path (older == better), and the value of this path to all of its adjacent peers. For example, long paths that end at a peer that we have no shorter way to reach are very desirable, while long paths that end at a peer for which we have a shorter way as well are much less desirable. Higher values indicate more valuable paths. The returned value should be used to decide which paths to remember.

Parameters

path	path to return the length for

Returns

desirability of the path, larger is more desirable

Definition at line 102 of file gnunet-service-cadet_paths.c.

{
  return path->desirability;
}

References CadetPeerPath::desirability.

Referenced by consider_path_cb(), evaluate_connection(), and GCP_attach_path().

Here is the caller graph for this function:

GCPP_get_connection()

struct CadetConnection * GCPP_get_connection	(	struct CadetPeerPath *	path,
		struct CadetPeer *	destination,
		unsigned int	off
	)

Return connection to destination using path, or return NULL if no such connection exists.

Parameters

path	path to traverse
destination	destination node to get to, must be on path
off	offset of destination on path

Returns

NULL if we have no existing connection otherwise connection from us to destination via path

Definition at line 119 of file gnunet-service-cadet_paths.c.

{
  struct CadetPeerPathEntry *entry;
 
  GNUNET_assert (off < path->entries_length);
  entry = path->entries[off];
  GNUNET_assert (entry->peer == destination);
  return entry->cc;
}

References CadetPeerPathEntry::cc, CadetPeerPath::entries, GNUNET_assert, CadetPeerPathEntry::path, and CadetPeerPathEntry::peer.

Referenced by GCC_create_inbound(), and path_heap_cleanup().

Here is the caller graph for this function:

GCPP_add_connection()

void GCPP_add_connection	(	struct CadetPeerPath *	path,
		unsigned int	off,
		struct CadetConnection *	cc
	)

Notify path that it is used for connection cc which ends at the path's offset off.

Parameters

path	the path to remember the cc
off	the offset where the cc ends
cc	the connection to remember

Definition at line 141 of file gnunet-service-cadet_paths.c.

{
  struct CadetPeerPathEntry *entry;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Adding %s to path %s at offset %u\n",
       GCC_2s (cc),
       GCPP_2s (path),
       off);
  GNUNET_assert (off < path->entries_length);
  entry = path->entries[off];
  GNUNET_assert (NULL == entry->cc);
  GNUNET_assert (NULL != cc);
  entry->cc = cc;
}

References CadetPeerPathEntry::cc, CadetPeerPath::entries, GCC_2s(), GCPP_2s(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, LOG, and CadetPeerPathEntry::path.

Referenced by connection_create().

Here is the call graph for this function:

Here is the caller graph for this function:

GCPP_del_connection()

void GCPP_del_connection	(	struct CadetPeerPath *	path,
		unsigned int	off,
		struct CadetConnection *	cc
	)

Notify path that it is no longer used for connection cc which ended at the path's offset off.

Parameters

path	the path to forget the cc
off	the offset where the cc ended
cc	the connection to forget

Definition at line 169 of file gnunet-service-cadet_paths.c.

{
  struct CadetPeerPathEntry *entry;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Removing connection %s to path %s at offset %u\n",
       GCC_2s (cc),
       GCPP_2s (path),
       off);
  GNUNET_assert (off < path->entries_length);
  entry = path->entries[off];
  GNUNET_assert (cc == entry->cc);
  entry->cc = NULL;
}

References CadetPeerPathEntry::cc, CadetPeerPath::entries, GCC_2s(), GCPP_2s(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, LOG, and CadetPeerPathEntry::path.

Referenced by GCC_destroy().

Here is the call graph for this function:

Here is the caller graph for this function:

attach_path()

static void attach_path ( struct CadetPeerPath *  path, unsigned int  stop_at  )

static

Tries to attach path to a peer, working backwards from the end and stopping at stop_at.

If path->hn is NULL on return then the path was not attached and you can assume that path->entries_length is equal to stop_at.

Parameters

path	the path to attach
stop_at	the path length at which to stop trying

Definition at line 197 of file gnunet-service-cadet_paths.c.

{
  GNUNET_assert (NULL == path->hn);
 
  /* Try to attach this path to a peer, working backwards from the end. */
  while (path->entries_length > stop_at)
  {
    unsigned int end = path->entries_length - 1;
    struct CadetPeerPathEntry *entry = path->entries[end];
    int force = GNUNET_NO;
 
    recalculate_path_desirability (path);
    /* If the entry already has a connection using it, force attach. */
    if (NULL != entry->cc)
      force = GNUNET_YES;
    path->hn = GCP_attach_path (entry->peer,
                                path,
                                end,
                                force);
    if (NULL != path->hn)
      break;
 
    /* Attach failed, trim this entry from the path. */
    GNUNET_assert (NULL == entry->cc);
    GCP_path_entry_remove (entry->peer,
                           entry,
                           end);
    GNUNET_free (entry);
    path->entries[end] = NULL;
    path->entries_length--;
  }
 
  /* Shrink array to actual path length. */
  GNUNET_array_grow (path->entries,
                     path->entries_length,
                     path->entries_length);
}

References CadetPeerPathEntry::cc, end, CadetPeerPath::entries, CadetPeerPath::entries_length, GCP_attach_path(), GCP_path_entry_remove(), GNUNET_array_grow, GNUNET_assert, GNUNET_free, GNUNET_NO, GNUNET_YES, CadetPeerPath::hn, CadetPeerPathEntry::path, CadetPeerPathEntry::peer, and recalculate_path_desirability().

Referenced by extend_path(), GCPP_release(), and GCPP_try_path_from_dht().

Here is the call graph for this function:

Here is the caller graph for this function:

GCPP_release()

void GCPP_release

(

struct CadetPeerPath *

path

)

The owning peer of this path is no longer interested in maintaining it, so the path should be discarded or shortened (in case a previous peer on the path finds the path desirable).

The given peer cp used to own this path.

Parameters

path	the path that is being released

Definition at line 244 of file gnunet-service-cadet_paths.c.

{
  struct CadetPeerPathEntry *entry;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Owner releases path %s\n",
       GCPP_2s (path));
  path->hn = NULL;
  entry = path->entries[path->entries_length - 1];
  GNUNET_assert (path == entry->path);
  GNUNET_assert (NULL == entry->cc);
  /* cut 'off' end of path */
  GCP_path_entry_remove (entry->peer,
                         entry,
                         path->entries_length - 1);
  GNUNET_free (entry);
  path->entries[path->entries_length - 1] = NULL;
  path->entries_length--;
  /* see if new peer at the end likes this path any better */
  attach_path (path, 0);
  if (NULL == path->hn)
  {
    /* nobody wants us, discard the path */
    GNUNET_assert (0 == path->entries_length);
    GNUNET_assert (NULL == path->entries);
    GNUNET_free (path);
  }
}

References attach_path(), CadetPeerPathEntry::cc, CadetPeerPath::entries, CadetPeerPath::entries_length, GCP_path_entry_remove(), GCPP_2s(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, CadetPeerPath::hn, LOG, CadetPeerPathEntry::path, and CadetPeerPathEntry::peer.

Referenced by drop_paths(), GCP_drop_owned_paths(), and path_heap_cleanup().

Here is the call graph for this function:

Here is the caller graph for this function:

GCPP_update_score()

static void GCPP_update_score ( struct CadetPeerPath *  path, unsigned int  off, int  delta  )

static

Updates the score for an entry on the path based on our experiences with using path.

Parameters

path	the path to update
off	offset of the entry to update
delta	change in the score to apply

Definition at line 283 of file gnunet-service-cadet_paths.c.

{
  struct CadetPeerPathEntry *entry;
 
  GNUNET_assert (off < path->entries_length);
  entry = path->entries[off];
 
  /* Add delta, with checks for overflows */
  if (delta >= 0)
  {
    if (delta + entry->score < entry->score)
      entry->score = INT_MAX;
    else
      entry->score += delta;
  }
  else
  {
    if (delta + entry->score > entry->score)
      entry->score = INT_MIN;
    else
      entry->score += delta;
  }
  recalculate_path_desirability (path);
}

References delta, CadetPeerPath::entries, GNUNET_assert, INT_MAX, CadetPeerPathEntry::path, recalculate_path_desirability(), and CadetPeerPathEntry::score.

Here is the call graph for this function:

check_match()

static int check_match ( void *  cls, struct CadetPeerPath *  path, unsigned int  off  )

static

Check if the given path is identical on all of the hops until off, and not longer than off.

If the path matches, store it in match.

Parameters

cls	the struct CheckMatchContext to check against
path	the path to check
off	offset to check at

Returns

GNUNET_YES (continue to iterate), or if found GNUNET_NO

Definition at line 344 of file gnunet-service-cadet_paths.c.

{
  struct CheckMatchContext *cm_ctx = cls;
 
  GNUNET_assert (path->entries_length > off);
  if ((path->entries_length != off + 1) &&
      (off + 1 != cm_ctx->cpath_length))
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "check_match mismatch because path %s is too long (%u vs. %u vs. %u)\n",
         GCPP_2s (path),
         path->entries_length,
         off + 1,
         cm_ctx->cpath_length);
    return GNUNET_YES;   /* too long, goes somewhere else already, thus cannot be useful */
  }
  for (unsigned int i = 0; i < off; i++)
    if (cm_ctx->cpath[i] !=
        GCPP_get_peer_at_offset (path,
                                 i))
    {
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "check_match path %s mismatches at offset %u\n",
           GCPP_2s (path),
           i);
      return GNUNET_YES;   /* mismatch, ignore */
    }
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "check_match found match with path %s\n",
       GCPP_2s (path));
  cm_ctx->match = path;
  return GNUNET_NO; /* match, we are done! */
}

References CheckMatchContext::cpath, CheckMatchContext::cpath_length, CadetPeerPath::entries_length, GCPP_2s(), GCPP_get_peer_at_offset(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_NO, GNUNET_YES, LOG, and CheckMatchContext::match.

Referenced by GCPP_get_path_from_route(), and GCPP_try_path_from_dht().

Here is the call graph for this function:

Here is the caller graph for this function:

extend_path()

static void extend_path ( struct CadetPeerPath *  path, struct CadetPeer **  peers_ext, unsigned int  num_peers, int  force  )

static

Extend path path by the num_peers from the peers array, assuming the owners past the current owner want it.

Parameters

path	path to extend
peers	list of peers beyond the end of path
num_peers	length of the peers array
force	force attachment, even if we have other paths already

Definition at line 392 of file gnunet-service-cadet_paths.c.

{
  unsigned int old_len = path->entries_length;
  int i;
 
  /* Expand path */
  GNUNET_array_grow (path->entries,
                     path->entries_length,
                     old_len + num_peers);
  for (i = num_peers - 1; i >= 0; i--)
  {
    struct CadetPeerPathEntry *entry = GNUNET_new (struct CadetPeerPathEntry);
 
    path->entries[old_len + i] = entry;
    entry->peer = peers_ext[i];
    entry->path = path;
  }
  for (i = num_peers - 1; i >= 0; i--)
  {
    struct CadetPeerPathEntry *entry = path->entries[old_len + i];
 
    GCP_path_entry_add (entry->peer,
                        entry,
                        old_len + i);
  }
 
  /* If we extend an existing path, detach it from the
     old owner and re-attach to the new one */
  GCP_detach_path (path->entries[old_len - 1]->peer,
                   path,
                   path->hn);
  path->hn = NULL;
  path->entries_length = old_len + num_peers;
  if (GNUNET_YES == force)
  {
    int end = path->entries_length - 1;
 
    path->hn = GCP_attach_path (path->entries[end]->peer,
                                path,
                                end,
                                GNUNET_YES);
  }
  else
  {
    attach_path (path, old_len);
  }
  if (NULL == path->hn)
  {
    /* none of the peers is interested in this path;
       re-attach. */
    GNUNET_assert (old_len == path->entries_length);
    path->hn = GCP_attach_path (path->entries[old_len - 1]->peer,
                                path,
                                old_len - 1,
                                GNUNET_YES);
    GNUNET_assert (NULL != path->hn);
    return;
  }
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Extended path %s\n",
       GCPP_2s (path));
}

References attach_path(), end, CadetPeerPath::entries, CadetPeerPath::entries_length, GCP_attach_path(), GCP_detach_path(), GCP_path_entry_add(), GCPP_2s(), GNUNET_array_grow, GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_YES, CadetPeerPath::hn, LOG, num_peers, CadetPeerPathEntry::path, and CadetPeerPathEntry::peer.

Referenced by GCPP_get_path_from_route(), and GCPP_try_path_from_dht().

Here is the call graph for this function:

Here is the caller graph for this function:

GCPP_try_path_from_dht()

void GCPP_try_path_from_dht	(	const struct GNUNET_DHT_PathElement *	get_path,
		unsigned int	get_path_length,
		const struct GNUNET_DHT_PathElement *	put_path,
		unsigned int	put_path_length
	)

Create a peer path based on the result of a DHT lookup.

If we already know this path, or one that is longer, simply return NULL. Otherwise, we try to extend an existing path, or create a new one if applicable.

Parameters

get_path	path of the get request
get_path_length	length of get_path
put_path	path of the put request
put_path_length	length of the put_path

Returns

a path through the network

Definition at line 472 of file gnunet-service-cadet_paths.c.

{
  const struct GNUNET_PeerIdentity *my_identity;
  struct CadetPeer *cpath[get_path_length + put_path_length];
  struct CheckMatchContext cm_ctx;
  struct CadetPeerPath *path;
  unsigned int skip;
  unsigned int total_len;
 
  my_identity = GNUNET_PILS_get_identity (pils);
 
  /* precompute 'cpath' so we can avoid doing the lookups lots of times */
  skip = 0;
  memset (cpath,
          0,
          sizeof(cpath));  /* Just to trigger harder errors later. */
  total_len = get_path_length + put_path_length;
  for (unsigned int off = 0; off < total_len; off++)
  {
    const struct GNUNET_PeerIdentity *pid;
 
    pid = (off < get_path_length)
          ? &get_path[get_path_length - off - 1].pred
          : &put_path[get_path_length + put_path_length - off - 1].pred;
    /* Check that I am not in the path */
    if (0 == GNUNET_memcmp (my_identity, pid))
    {
      skip = off + 1;
      continue;
    }
    cpath[off - skip] = GCP_get (pid,
                                 GNUNET_YES);
    /* Check that no peer is twice on the path */
    for (unsigned int i = 0; i < off - skip; i++)
    {
      if (cpath[i] == cpath[off - skip])
      {
        skip = off - i;
        break;
      }
    }
  }
  if (skip >= total_len)
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "Path discovered from DHT is one big cycle?\n");
    return;
  }
  total_len -= skip;
 
  /* First figure out if this path is a subset of an existing path, an
     extension of an existing path, or a new path. */
  cm_ctx.cpath_length = total_len;
  cm_ctx.cpath = cpath;
  cm_ctx.match = NULL;
  for (int i = total_len - 1; i >= 0; i--)
  {
    GCP_iterate_paths_at (cpath[i],
                          (unsigned int) i,
                          &check_match,
                          &cm_ctx);
    if (NULL != cm_ctx.match)
    {
      if (i == total_len - 1)
      {
        /* Existing path includes this one, nothing to do! */
        LOG (GNUNET_ERROR_TYPE_DEBUG,
             "Path discovered from DHT is already known\n");
        return;
      }
      if (cm_ctx.match->entries_length == i + 1)
      {
        /* Existing path ends in the middle of new path, extend it! */
        LOG (GNUNET_ERROR_TYPE_DEBUG,
             "Trying to extend existing path %s by additional links discovered from DHT\n",
             GCPP_2s (cm_ctx.match));
        extend_path (cm_ctx.match,
                     &cpath[i + 1],
                     total_len - i - 1,
                     GNUNET_NO);
        return;
      }
    }
  }
 
  /* No match at all, create completely new path */
  path = GNUNET_new (struct CadetPeerPath);
  path->entries_length = total_len;
  path->entries = GNUNET_new_array (path->entries_length,
                                    struct CadetPeerPathEntry *);
  for (int i = path->entries_length - 1; i >= 0; i--)
  {
    struct CadetPeerPathEntry *entry = GNUNET_new (struct CadetPeerPathEntry);
 
    path->entries[i] = entry;
    entry->peer = cpath[i];
    entry->path = path;
  }
  for (int i = path->entries_length - 1; i >= 0; i--)
  {
    struct CadetPeerPathEntry *entry = path->entries[i];
 
    GCP_path_entry_add (entry->peer,
                        entry,
                        i);
  }
 
  /* Finally, try to attach it */
  attach_path (path, 0);
  if (NULL == path->hn)
  {
    /* None of the peers on the path care about it. */
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "Path discovered from DHT is not interesting to us\n");
    GNUNET_assert (0 == path->entries_length);
    GNUNET_assert (NULL == path->entries);
    GNUNET_free (path);
    return;
  }
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Created new path %s based on information from DHT\n",
       GCPP_2s (path));
}

References attach_path(), check_match(), CheckMatchContext::cpath, CheckMatchContext::cpath_length, CadetPeerPath::entries, CadetPeerPath::entries_length, extend_path(), GCP_get(), GCP_iterate_paths_at(), GCP_path_entry_add(), GCPP_2s(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_memcmp, GNUNET_new, GNUNET_new_array, GNUNET_NO, GNUNET_PILS_get_identity(), GNUNET_YES, CadetPeerPath::hn, LOG, CheckMatchContext::match, my_identity, CadetPeerPathEntry::path, CadetPeerPathEntry::peer, pid, pils, and GNUNET_DHT_PathElement::pred.

Referenced by dht_get_id_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

GCPP_get_path_from_route()

struct CadetPeerPath * GCPP_get_path_from_route	(	unsigned int	path_length,
		const struct GNUNET_PeerIdentity *	pids
	)

We got an incoming connection, obtain the corresponding path.

Parameters

path_length	number of segments on the path
pids	path through the network, in reverse order (we are at the end, at index path_length)

Returns

corresponding path object

Definition at line 601 of file gnunet-service-cadet_paths.c.

{
  struct CheckMatchContext cm_ctx;
  struct CadetPeer *cpath[path_length];
  struct CadetPeerPath *path;
 
  /* precompute inverted 'cpath' so we can avoid doing the lookups and
     have the correct order */
  for (unsigned int off = 0; off < path_length; off++)
    cpath[off] = GCP_get (&pids[path_length - 1 - off],
                          GNUNET_YES);
 
  /* First figure out if this path is a subset of an existing path, an
     extension of an existing path, or a new path. */
  cm_ctx.cpath = cpath;
  cm_ctx.cpath_length = path_length;
  cm_ctx.match = NULL;
  for (int i = path_length - 1; i >= 0; i--)
  {
    GCP_iterate_paths_at (cpath[i],
                          (unsigned int) i,
                          &check_match,
                          &cm_ctx);
    if (NULL != cm_ctx.match)
    {
      if (i == path_length - 1)
      {
        /* Existing path includes this one, return the match! */
        LOG (GNUNET_ERROR_TYPE_DEBUG,
             "Returning existing path %s as inverse for incoming connection\n",
             GCPP_2s (cm_ctx.match));
        return cm_ctx.match;
      }
      if (cm_ctx.match->entries_length == i + 1)
      {
        /* Existing path ends in the middle of new path, extend it! */
        LOG (GNUNET_ERROR_TYPE_DEBUG,
             "Extending existing path %s to create inverse for incoming connection\n",
             GCPP_2s (cm_ctx.match));
        extend_path (cm_ctx.match,
                     &cpath[i + 1],
                     path_length - i - 1,
                     GNUNET_YES);
        /* Check that extension was successful */
        GNUNET_assert (cm_ctx.match->entries_length == path_length);
        return cm_ctx.match;
      }
      /* Eh, we found a match but couldn't use it? Something is wrong. */
      GNUNET_break (0);
    }
  }
 
  /* No match at all, create completely new path */
  path = GNUNET_new (struct CadetPeerPath);
  path->entries_length = path_length;
  path->entries = GNUNET_new_array (path->entries_length,
                                    struct CadetPeerPathEntry *);
  for (int i = path_length - 1; i >= 0; i--)
  {
    struct CadetPeerPathEntry *entry = GNUNET_new (struct CadetPeerPathEntry);
 
    path->entries[i] = entry;
    entry->peer = cpath[i];
    entry->path = path;
  }
  for (int i = path_length - 1; i >= 0; i--)
  {
    struct CadetPeerPathEntry *entry = path->entries[i];
 
    GCP_path_entry_add (entry->peer,
                        entry,
                        i);
  }
  recalculate_path_desirability (path);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Created new path %s to create inverse for incoming connection\n",
       GCPP_2s (path));
  path->hn = GCP_attach_path (cpath[path_length - 1],
                              path,
                              path_length - 1,
                              GNUNET_YES);
  return path;
}

References check_match(), CheckMatchContext::cpath, CheckMatchContext::cpath_length, CadetPeerPath::entries, CadetPeerPath::entries_length, extend_path(), GCP_attach_path(), GCP_get(), GCP_iterate_paths_at(), GCP_path_entry_add(), GCPP_2s(), GNUNET_assert, GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_new_array, GNUNET_YES, CadetPeerPath::hn, LOG, CheckMatchContext::match, CadetPeerPathEntry::path, CadetPeerPathEntry::peer, and recalculate_path_desirability().

Referenced by GCP_iterate_paths(), GCP_set_mq(), and handle_connection_create().

Here is the call graph for this function:

Here is the caller graph for this function:

GCPP_get_length()

unsigned int GCPP_get_length

(

struct CadetPeerPath *

path

)

Return the length of the path.

Excludes one end of the path, so the loopback path has length 0.

Parameters

path	path to return the length for

Returns

number of peers on the path

Definition at line 695 of file gnunet-service-cadet_paths.c.

{
  return path->entries_length;
}

References CadetPeerPath::entries_length, and CadetPeerPathEntry::path.

Referenced by consider_path_cb(), evaluate_connection(), GCP_attach_path(), path_heap_cleanup(), and path_info_iterator().

Here is the caller graph for this function:

GCPP_find_peer()

unsigned int GCPP_find_peer	(	struct CadetPeerPath *	path,
		struct CadetPeer *	cp
	)

Find peer's offset on path.

Parameters

path	path to search
cp	peer to look for

Returns

offset of cp on path, or UINT_MAX if not found

Definition at line 709 of file gnunet-service-cadet_paths.c.

{
  for (unsigned int off = 0;
       off < path->entries_length;
       off++)
    if (cp == GCPP_get_peer_at_offset (path,
                                       off))
      return off;
  return UINT_MAX;
}

References CadetPeerPath::entries_length, GCPP_get_peer_at_offset(), and CadetPeerPathEntry::path.

Referenced by GCC_create_inbound().

Here is the call graph for this function:

Here is the caller graph for this function:

GCPP_get_peer_at_offset()

struct CadetPeer * GCPP_get_peer_at_offset	(	struct CadetPeerPath *	path,
		unsigned int	off
	)

Obtain the peer at offset off in path.

Parameters

path	peer path to inspect
off	offset to return, must be smaller than path length

Returns

peer at offset off

Definition at line 723 of file gnunet-service-cadet_paths.c.

{
  GNUNET_assert (off < path->entries_length);
  return path->entries[off]->peer;
}

References CadetPeerPath::entries, GNUNET_assert, and CadetPeerPathEntry::peer.

Referenced by check_match(), connection_create(), consider_path_cb(), cont_send_create(), evaluate_connection(), GCC_destroy(), GCP_attach_path(), GCP_path_entry_add(), GCPP_2s(), GCPP_find_peer(), handle_connection_broken(), handle_connection_create_ack(), handle_connection_destroy(), handle_tunnel_encrypted(), handle_tunnel_kx(), handle_tunnel_kx_auth(), and path_info_iterator().

Here is the caller graph for this function:

GCPP_2s()

const char * GCPP_2s

(

struct CadetPeerPath *

path

)

Convert a path to a human-readable string.

Parameters

path	path to convert

Returns

string, to be freed by caller (unlike other *_2s APIs!)

Definition at line 738 of file gnunet-service-cadet_paths.c.

{
  static char buf[2048];
  size_t off;
  const unsigned int max_plen = (sizeof(buf) - 16) / 5 - 2; /* 5 characters per entry */
 
  off = 0;
  for (unsigned int i = 0;
       i < path->entries_length;
       i++)
  {
    if ((path->entries_length > max_plen) &&
        (i == max_plen / 2))
      off += GNUNET_snprintf (&buf[off],
                              sizeof(buf) - off,
                              "...-");
    if ((path->entries_length > max_plen) &&
        (i > max_plen / 2) &&
        (i < path->entries_length - max_plen / 2))
      continue;
    off += GNUNET_snprintf (&buf[off],
                            sizeof(buf) - off,
                            "%s%s",
                            GNUNET_i2s (GCP_get_id (GCPP_get_peer_at_offset (
                                                      path,
                                                      i))),
                            (i == path->entries_length - 1) ? "" : "-");
  }
  GNUNET_snprintf (&buf[off],
                   sizeof(buf) - off,
                   "(%p)",
                   path);
  return buf;
}

References CadetPeerPath::entries_length, GCP_get_id(), GCPP_get_peer_at_offset(), GNUNET_i2s(), and GNUNET_snprintf().

Referenced by check_match(), connection_create(), consider_path_cb(), evaluate_connection(), extend_path(), GCC_create_inbound(), GCC_debug(), GCP_attach_path(), GCP_detach_path(), GCP_path_entry_add(), GCP_path_entry_remove(), GCPP_add_connection(), GCPP_del_connection(), GCPP_get_path_from_route(), GCPP_release(), GCPP_try_path_from_dht(), GCT_consider_path(), and handle_connection_create().

Here is the call graph for this function:

Here is the caller graph for this function: