utilities for managing (information about) peers More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet-service-rps_custommap.h"
#include <inttypes.h>

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

Data Structures
struct	CustomPeerMap
	Peer map to store peers with specialised use-cases (push_list, pull_list, view, ...) More...

Macros
#define	LOG(kind, ...) GNUNET_log_from (kind, "rps-peers", __VA_ARGS__)

Functions
struct CustomPeerMap *	CustomPeerMap_create (unsigned int len)
	Create an empty peermap. More...

unsigned int	CustomPeerMap_size (const struct CustomPeerMap *c_peer_map)
	Get the size of the custom peer map. More...

int	CustomPeerMap_put (const struct CustomPeerMap c_peer_map, const struct GNUNET_PeerIdentity peer)
	Insert peer into the custom peer map. More...

int	CustomPeerMap_contains_peer (const struct CustomPeerMap c_peer_map, const struct GNUNET_PeerIdentity peer)
	Check whether custom peer map contains a peer. More...

static uint32_t *	CustomPeerMap_get_index_pointer (const struct CustomPeerMap c_peer_map, const struct GNUNET_PeerIdentity peer)
	Get index of peer in custom peer map. More...

int	CustomPeerMap_remove_peer (const struct CustomPeerMap c_peer_map, const struct GNUNET_PeerIdentity peer)
	Remove peer from custom peer map. More...

struct GNUNET_PeerIdentity *	CustomPeerMap_get_peer_by_index (const struct CustomPeerMap *c_peer_map, uint32_t index)
	Get a peer by index. More...

int	CustomPeerMap_remove_peer_by_index (const struct CustomPeerMap *c_peer_map, uint32_t index)
	Remove peer from custom peer map by index. More...

void	CustomPeerMap_clear (const struct CustomPeerMap *c_peer_map)
	Clear the custom peer map. More...

void	CustomPeerMap_destroy (struct CustomPeerMap *c_peer_map)
	Destroy peermap. More...

Detailed Description

utilities for managing (information about) peers

Author: Julius Bünger

Definition in file gnunet-service-rps_custommap.c.

Macro Definition Documentation

◆ LOG

#define LOG	(	kind,
		...
	)	GNUNET_log_from (kind, "rps-peers", __VA_ARGS__)

Definition at line 31 of file gnunet-service-rps_custommap.c.

Function Documentation

◆ CustomPeerMap_create()

struct CustomPeerMap * CustomPeerMap_create ( unsigned int len )

Create an empty peermap.

Parameters

len	the initial length for the internal maps

Returns: the newly created custom peer map

Definition at line 79 of file gnunet-service-rps_custommap.c.

{
  struct CustomPeerMap *c_peer_map;
 
  c_peer_map = GNUNET_new (struct CustomPeerMap);
  c_peer_map->hash_map = GNUNET_CONTAINER_multihashmap32_create (len);
  c_peer_map->peer_map = GNUNET_CONTAINER_multipeermap_create (len,
                                                               GNUNET_NO);
  return c_peer_map;
}

References GNUNET_CONTAINER_multihashmap32_create(), GNUNET_CONTAINER_multipeermap_create(), GNUNET_new, GNUNET_NO, CustomPeerMap::hash_map, and CustomPeerMap::peer_map.

Referenced by new_sub().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_size()

unsigned int CustomPeerMap_size ( const struct CustomPeerMap * c_peer_map )

Get the size of the custom peer map.

Parameters

c_peer_map the custom peer map to look in

Returns: size of the map

Definition at line 99 of file gnunet-service-rps_custommap.c.

{
  GNUNET_assert (GNUNET_CONTAINER_multihashmap32_size (c_peer_map->hash_map) ==
                 GNUNET_CONTAINER_multipeermap_size (c_peer_map->peer_map));
  return GNUNET_CONTAINER_multipeermap_size (c_peer_map->peer_map);
}

References GNUNET_assert, GNUNET_CONTAINER_multihashmap32_size(), GNUNET_CONTAINER_multipeermap_size(), CustomPeerMap::hash_map, and CustomPeerMap::peer_map.

Referenced by CustomPeerMap_clear(), CustomPeerMap_put(), CustomPeerMap_remove_peer(), CustomPeerMap_remove_peer_by_index(), and do_round().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_put()

int CustomPeerMap_put	(	const struct CustomPeerMap *	c_peer_map,
		const struct GNUNET_PeerIdentity *	peer
	)

Insert peer into the custom peer map.

Parameters

c_peer_map	the custom peer map to insert peer
peer	the peer to insert

Returns: GNUNET_OK if map did not contain peer previously GNUNET_NO if map did contain peer previously

Definition at line 117 of file gnunet-service-rps_custommap.c.

{
  uint32_t *index;
  struct GNUNET_PeerIdentity *p;
 
  GNUNET_assert (GNUNET_CONTAINER_multihashmap32_size (c_peer_map->hash_map) ==
                 GNUNET_CONTAINER_multipeermap_size (c_peer_map->peer_map));
  if (GNUNET_NO == GNUNET_CONTAINER_multipeermap_contains (c_peer_map->peer_map,
                                                           peer))
  {
    /* Need to store the index of the peer in the peermap to be able to remove
     * it properly */
    index = GNUNET_new (uint32_t);
    *index = CustomPeerMap_size (c_peer_map);
    p = GNUNET_new (struct GNUNET_PeerIdentity);
    *p = *peer;
    GNUNET_assert (p != peer);
    GNUNET_assert (0 == memcmp (p,
                                peer,
                                sizeof(struct GNUNET_PeerIdentity)));
    GNUNET_CONTAINER_multipeermap_put (c_peer_map->peer_map,
                                       p,
                                       index,
                                       GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST);
    GNUNET_CONTAINER_multihashmap32_put (c_peer_map->hash_map,
                                         *index,
                                         p,
                                         GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST);
    GNUNET_assert (GNUNET_CONTAINER_multihashmap32_size (
                     c_peer_map->hash_map) ==
                   GNUNET_CONTAINER_multipeermap_size (c_peer_map->peer_map));
    return GNUNET_OK;
  }
  return GNUNET_NO;
}

References CustomPeerMap_size(), GNUNET_assert, GNUNET_CONTAINER_multihashmap32_put(), GNUNET_CONTAINER_multihashmap32_size(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_CONTAINER_multipeermap_contains(), GNUNET_CONTAINER_multipeermap_put(), GNUNET_CONTAINER_multipeermap_size(), GNUNET_new, GNUNET_NO, GNUNET_OK, CustomPeerMap::hash_map, p, and CustomPeerMap::peer_map.

Referenced by handle_peer_pull_reply(), handle_peer_push(), and insert_in_pull_map().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_contains_peer()

int CustomPeerMap_contains_peer	(	const struct CustomPeerMap *	c_peer_map,
		const struct GNUNET_PeerIdentity *	peer
	)

Check whether custom peer map contains a peer.

Parameters

c_peer_map	the custom peer map to look in
peer	the peer to check for

Returns: GNUNET_OK if map contains peer GNUNET_NO otherwise

Definition at line 165 of file gnunet-service-rps_custommap.c.

{
  return GNUNET_CONTAINER_multipeermap_contains (c_peer_map->peer_map, peer);
}

References GNUNET_CONTAINER_multipeermap_contains(), and CustomPeerMap::peer_map.

Referenced by check_sending_channel_needed(), clean_peer(), CustomPeerMap_get_index_pointer(), and CustomPeerMap_remove_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_get_index_pointer()

static uint32_t * CustomPeerMap_get_index_pointer	(	const struct CustomPeerMap *	c_peer_map,
		const struct GNUNET_PeerIdentity *	peer
	)

static

Get index of peer in custom peer map.

Parameters

c_peer_map	the custom peer map to look in
peer	the peer to get the index from

Returns: the index

Definition at line 181 of file gnunet-service-rps_custommap.c.

{
  uint32_t *index;
 
  GNUNET_assert (GNUNET_YES == CustomPeerMap_contains_peer (c_peer_map, peer));
  index = GNUNET_CONTAINER_multipeermap_get (c_peer_map->peer_map, peer);
  return index;
}

References CustomPeerMap_contains_peer(), GNUNET_assert, GNUNET_CONTAINER_multipeermap_get(), GNUNET_YES, and CustomPeerMap::peer_map.

Referenced by CustomPeerMap_remove_peer(), and CustomPeerMap_remove_peer_by_index().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_remove_peer()

int CustomPeerMap_remove_peer	(	const struct CustomPeerMap *	c_peer_map,
		const struct GNUNET_PeerIdentity *	peer
	)

Remove peer from custom peer map.

Parameters

c_peer_map	the custom peer map to remove the peer from
peer	the peer to remove

Returns: GNUNET_OK if map contained peer and removed it successfully GNUNET_NO if map does not contain peer

Definition at line 202 of file gnunet-service-rps_custommap.c.

{
  uint32_t *index;
  struct GNUNET_PeerIdentity *p;
  uint32_t *last_index;
  struct GNUNET_PeerIdentity *last_p;
  int ret;
 
  if (GNUNET_NO == CustomPeerMap_contains_peer (c_peer_map,
                                                peer))
  {
    return GNUNET_NO;
  }
  index = CustomPeerMap_get_index_pointer (c_peer_map,
                                           peer);
  GNUNET_assert (*index < CustomPeerMap_size (c_peer_map));
  /* Need to get the pointer stored in the hashmap to free it */
  p = GNUNET_CONTAINER_multihashmap32_get (c_peer_map->hash_map,
                                           *index);
  GNUNET_assert (NULL != p);
  GNUNET_CONTAINER_multihashmap32_remove_all (c_peer_map->hash_map,
                                              *index);
  // TODO wrong peerid?
  GNUNET_CONTAINER_multipeermap_remove_all (c_peer_map->peer_map,
                                            peer);
  if (*index != CustomPeerMap_size (c_peer_map))
  {   /* fill 'gap' with peer at last index */
    last_p =
      GNUNET_CONTAINER_multihashmap32_get (c_peer_map->hash_map,
                                           CustomPeerMap_size (c_peer_map));
    GNUNET_assert (NULL != last_p);
    last_index = GNUNET_CONTAINER_multipeermap_get (c_peer_map->peer_map,
                                                    last_p);
    GNUNET_assert (NULL != last_index);
    GNUNET_assert (CustomPeerMap_size (c_peer_map) == *last_index);
    ret = GNUNET_CONTAINER_multihashmap32_put (c_peer_map->hash_map,
                                               *index,
                                               last_p,
                                               GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY);
    GNUNET_assert (GNUNET_OK == ret);
    GNUNET_CONTAINER_multihashmap32_remove_all (c_peer_map->hash_map,
                                                *last_index);
    *last_index = *index;
  }
  GNUNET_free (index);
  GNUNET_assert (GNUNET_CONTAINER_multihashmap32_size (c_peer_map->hash_map) ==
                 GNUNET_CONTAINER_multipeermap_size (c_peer_map->peer_map));
  GNUNET_free (p);
  return GNUNET_OK;
}

References CustomPeerMap_contains_peer(), CustomPeerMap_get_index_pointer(), CustomPeerMap_size(), GNUNET_assert, GNUNET_CONTAINER_multihashmap32_get(), GNUNET_CONTAINER_multihashmap32_put(), GNUNET_CONTAINER_multihashmap32_remove_all(), GNUNET_CONTAINER_multihashmap32_size(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY, GNUNET_CONTAINER_multipeermap_get(), GNUNET_CONTAINER_multipeermap_remove_all(), GNUNET_CONTAINER_multipeermap_size(), GNUNET_free, GNUNET_NO, GNUNET_OK, CustomPeerMap::hash_map, p, CustomPeerMap::peer_map, and ret.

Referenced by CustomPeerMap_remove_peer_by_index(), and remove_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_get_peer_by_index()

struct GNUNET_PeerIdentity * CustomPeerMap_get_peer_by_index	(	const struct CustomPeerMap *	c_peer_map,
		uint32_t	index
	)

Get a peer by index.

Parameters

c_peer_map	the custom peer map to look in
index	the index of the peer to get

Returns: peer to the corresponding index. if this index is not known, return NULL

Definition at line 265 of file gnunet-service-rps_custommap.c.

{
  if (GNUNET_YES ==
      GNUNET_CONTAINER_multihashmap32_contains (c_peer_map->hash_map, index))
  {
    return GNUNET_CONTAINER_multihashmap32_get (c_peer_map->hash_map, index);
  }
  return NULL;
}

References GNUNET_CONTAINER_multihashmap32_contains(), GNUNET_CONTAINER_multihashmap32_get(), GNUNET_YES, and CustomPeerMap::hash_map.

Referenced by CustomPeerMap_remove_peer_by_index(), and do_round().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_remove_peer_by_index()

int CustomPeerMap_remove_peer_by_index	(	const struct CustomPeerMap *	c_peer_map,
		uint32_t	index
	)

Remove peer from custom peer map by index.

Parameters

c_peer_map	the custom peer map to remove the peer from
index	the index of the peer to remove

Returns: GNUNET_OK if map contained peer and removed it successfully GNUNET_NO if map does not contain (index of) peer

Definition at line 287 of file gnunet-service-rps_custommap.c.

{
  uint32_t *index_p;
  struct GNUNET_PeerIdentity *peer;
 
  if (index >= CustomPeerMap_size (c_peer_map))
  {
    return GNUNET_NO;
  }
  GNUNET_assert (GNUNET_CONTAINER_multihashmap32_size (c_peer_map->hash_map) ==
                 GNUNET_CONTAINER_multipeermap_size (c_peer_map->peer_map));
  if (GNUNET_NO ==
      GNUNET_CONTAINER_multihashmap32_contains (c_peer_map->hash_map, index))
  {
    return GNUNET_NO;
  }
  peer = CustomPeerMap_get_peer_by_index (c_peer_map, index);
  GNUNET_assert (NULL != peer);
  index_p = CustomPeerMap_get_index_pointer (c_peer_map, peer);
  GNUNET_assert (index == *index_p);
  CustomPeerMap_remove_peer (c_peer_map, peer);
  GNUNET_assert (GNUNET_CONTAINER_multihashmap32_size (c_peer_map->hash_map) ==
                 GNUNET_CONTAINER_multipeermap_size (c_peer_map->peer_map));
  return GNUNET_OK;
}

References CustomPeerMap_get_index_pointer(), CustomPeerMap_get_peer_by_index(), CustomPeerMap_remove_peer(), CustomPeerMap_size(), GNUNET_assert, GNUNET_CONTAINER_multihashmap32_contains(), GNUNET_CONTAINER_multihashmap32_size(), GNUNET_CONTAINER_multipeermap_size(), GNUNET_NO, GNUNET_OK, CustomPeerMap::hash_map, and CustomPeerMap::peer_map.

Referenced by CustomPeerMap_clear().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_clear()

void CustomPeerMap_clear ( const struct CustomPeerMap * c_peer_map )

Clear the custom peer map.

Parameters

c_peer_map the custom peer map to look in

Returns: size of the map

Definition at line 323 of file gnunet-service-rps_custommap.c.

{
  while (0 < CustomPeerMap_size (c_peer_map))
  {
    GNUNET_assert (GNUNET_YES ==
                   GNUNET_CONTAINER_multihashmap32_contains (
                     c_peer_map->hash_map,
                     CustomPeerMap_size (
                       c_peer_map) - 1));
    GNUNET_assert (GNUNET_OK ==
                   CustomPeerMap_remove_peer_by_index (c_peer_map,
                                                       CustomPeerMap_size (
                                                         c_peer_map) - 1));
  }
  GNUNET_assert (0 == CustomPeerMap_size (c_peer_map));
}

References CustomPeerMap_remove_peer_by_index(), CustomPeerMap_size(), GNUNET_assert, GNUNET_CONTAINER_multihashmap32_contains(), GNUNET_OK, GNUNET_YES, and CustomPeerMap::hash_map.

Referenced by CustomPeerMap_destroy(), and do_round().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ CustomPeerMap_destroy()

void CustomPeerMap_destroy ( struct CustomPeerMap * c_peer_map )

Destroy peermap.

Parameters

c_peer_map the map to destroy

Definition at line 347 of file gnunet-service-rps_custommap.c.

{
  CustomPeerMap_clear (c_peer_map);
  GNUNET_CONTAINER_multihashmap32_destroy (c_peer_map->hash_map);
  GNUNET_CONTAINER_multipeermap_destroy (c_peer_map->peer_map);
  GNUNET_free (c_peer_map);
}

References CustomPeerMap_clear(), GNUNET_CONTAINER_multihashmap32_destroy(), GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_free, CustomPeerMap::hash_map, and CustomPeerMap::peer_map.

Referenced by destroy_sub().

Here is the call graph for this function:

Here is the caller graph for this function:

Data Structures

Macros

Functions

Detailed Description

Macro Definition Documentation

◆ LOG

Function Documentation

◆ CustomPeerMap_create()

◆ CustomPeerMap_size()

◆ CustomPeerMap_put()

◆ CustomPeerMap_contains_peer()

◆ CustomPeerMap_get_index_pointer()

◆ CustomPeerMap_remove_peer()

◆ CustomPeerMap_get_peer_by_index()

◆ CustomPeerMap_remove_peer_by_index()

◆ CustomPeerMap_clear()

◆ CustomPeerMap_destroy()