gnunet-service-ats_addresses.c File Reference

ats service address management More...

#include "platform.h"
#include "gnunet-service-ats_addresses.h"
#include "gnunet-service-ats_performance.h"
#include "gnunet-service-ats_normalization.h"
#include "gnunet-service-ats_plugins.h"

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

Go to the source code of this file.

Data Structures
struct	FindAddressContext
	Closure for find_address_cb() More...
struct	PeerInfoIteratorContext
	Closure for peerinfo_it(). More...
struct	AddressIteration
	Information we need for the callbacks to return a list of addresses back to the client. More...

Functions
static void	update_addresses_stat ()
	Update statistic on number of addresses. More...
static void	free_address (struct ATS_Address *addr)
	Free the given address. More...
static void	init_norm (struct GAS_NormalizationInfo *norm)
	Initialize norm. More...
static struct ATS_Address *	create_address (const struct GNUNET_PeerIdentity *peer, const char *plugin_name, const void *plugin_addr, size_t plugin_addr_len, uint32_t local_address_info, uint32_t session_id)
	Create a ATS_address with the given information. More...
static int	find_address_cb (void *cls, const struct GNUNET_PeerIdentity *key, void *value)
	Find session matching given session ID. More...
static struct ATS_Address *	find_exact_address (const struct GNUNET_PeerIdentity *peer, uint32_t session_id)
	Find the exact address. More...
void	GAS_addresses_add (const struct GNUNET_PeerIdentity *peer, const char *plugin_name, const void *plugin_addr, size_t plugin_addr_len, uint32_t local_address_info, uint32_t session_id, const struct GNUNET_ATS_Properties *prop)
	Add a new address for a peer. More...
void	GAS_addresses_update (const struct GNUNET_PeerIdentity *peer, uint32_t session_id, const struct GNUNET_ATS_Properties *prop)
	Update an address with new performance information for a peer. More...
void	GAS_addresses_destroy (const struct GNUNET_PeerIdentity *peer, uint32_t session_id)
	Remove an address for a peer. More...
void	GAS_addresses_init ()
	Initialize address subsystem. More...
static int	destroy_all_address_it (void *cls, const struct GNUNET_PeerIdentity *key, void *value)
	Destroy all addresses iterator. More...
void	GAS_addresses_destroy_all ()
	Remove all addresses. More...
void	GAS_addresses_done ()
	Shutdown address subsystem. More...
static int	peerinfo_it (void *cls, const struct GNUNET_PeerIdentity *key, void *value)
	Iterator to iterate over a peer's addresses. More...
void	GAS_addresses_get_peer_info (const struct GNUNET_PeerIdentity *peer, GNUNET_ATS_PeerInfo_Iterator pi_it, void *pi_it_cls)
	Return information all peers currently known to ATS. More...
static void	transmit_req_addr (struct AddressIteration *ai, const struct GNUNET_PeerIdentity *id, const char *plugin_name, const void *plugin_addr, size_t plugin_addr_len, int active, const struct GNUNET_ATS_Properties *prop, enum GNUNET_HELLO_AddressInfo local_address_info, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in)
	Send a GNUNET_MESSAGE_TYPE_ATS_ADDRESSLIST_RESPONSE with the given address details to the client identified in ai. More...
static void	req_addr_peerinfo_it (void *cls, const struct GNUNET_PeerIdentity *id, const char *plugin_name, const void *plugin_addr, size_t plugin_addr_len, int active, const struct GNUNET_ATS_Properties *prop, enum GNUNET_HELLO_AddressInfo local_address_info, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in)
	Iterator for GAS_addresses_get_peer_info(), called with peer-specific information to be passed back to the client. More...
void	GAS_handle_request_address_list (struct GNUNET_SERVICE_Client *client, const struct AddressListRequestMessage *alrm)
	Handle 'address list request' messages from clients. More...

Variables
struct GNUNET_CONTAINER_MultiPeerMap *	GSA_addresses
	A multihashmap to store all addresses. More...

Detailed Description

ats service address management

Author

Matthias Wachs

Christian Grothoff

Definition in file gnunet-service-ats_addresses.c.

Function Documentation

update_addresses_stat()

static void update_addresses_stat ( )

static

Update statistic on number of addresses.

Definition at line 44 of file gnunet-service-ats_addresses.c.

{
  GNUNET_STATISTICS_set (GSA_stats,
                         "# addresses",
                         GNUNET_CONTAINER_multipeermap_size (GSA_addresses),
                         GNUNET_NO);
}

References GNUNET_CONTAINER_multipeermap_size(), GNUNET_NO, GNUNET_STATISTICS_set(), GSA_addresses, and GSA_stats.

Referenced by free_address(), GAS_addresses_add(), and GAS_addresses_init().

Here is the call graph for this function:

Here is the caller graph for this function:

free_address()

static void free_address ( struct ATS_Address *  addr )

static

Free the given address.

Parameters

addr	address to destroy

Definition at line 59 of file gnunet-service-ats_addresses.c.

{
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multipeermap_remove (GSA_addresses,
                                                       &addr->peer,
                                                       addr));
  update_addresses_stat ();
  GAS_plugin_delete_address (addr);
  GAS_performance_notify_all_clients (&addr->peer,
                                      addr->plugin,
                                      addr->addr,
                                      addr->addr_len,
                                      GNUNET_NO,
                                      NULL,
                                      addr->local_address_info,
                                      GNUNET_BANDWIDTH_ZERO,
                                      GNUNET_BANDWIDTH_ZERO);
  GNUNET_free (addr->plugin);
  GNUNET_free (addr);
}

References ATS_Address::addr, ATS_Address::addr_len, GAS_performance_notify_all_clients(), GAS_plugin_delete_address(), GNUNET_assert, GNUNET_BANDWIDTH_ZERO, GNUNET_CONTAINER_multipeermap_remove(), GNUNET_free, GNUNET_NO, GNUNET_YES, GSA_addresses, ATS_Address::local_address_info, ATS_Address::peer, ATS_Address::plugin, and update_addresses_stat().

Referenced by destroy_all_address_it(), and GAS_addresses_destroy().

Here is the call graph for this function:

Here is the caller graph for this function:

init_norm()

static void init_norm ( struct GAS_NormalizationInfo *  norm )

static

Initialize norm.

Sets all historic values to undefined.

Parameters

norm	normalization data to initialize

Definition at line 87 of file gnunet-service-ats_addresses.c.

{
  unsigned int c;
 
  for (c = 0; c < GAS_normalization_queue_length; c++)
    norm->atsi_abs[c] = UINT64_MAX;
}

References GAS_NormalizationInfo::atsi_abs, and GAS_normalization_queue_length.

Referenced by create_address().

Here is the caller graph for this function:

create_address()

static struct ATS_Address* create_address ( const struct GNUNET_PeerIdentity *  peer, const char *  plugin_name, const void *  plugin_addr, size_t  plugin_addr_len, uint32_t  local_address_info, uint32_t  session_id  )

static

Create a ATS_address with the given information.

Parameters

peer	peer
plugin_name	plugin
plugin_addr	address
plugin_addr_len	address length
local_address_info	additional local info for the address
session_id	session identifier, can never be 0

Returns

the ATS_Address

Definition at line 108 of file gnunet-service-ats_addresses.c.

{
  struct ATS_Address *aa;
 
  aa = GNUNET_malloc (sizeof(struct ATS_Address) + plugin_addr_len);
  aa->peer = *peer;
  aa->addr_len = plugin_addr_len;
  aa->addr = &aa[1];
  GNUNET_memcpy (&aa[1],
                 plugin_addr,
                 plugin_addr_len);
  aa->plugin = GNUNET_strdup (plugin_name);
  aa->session_id = session_id;
  aa->local_address_info = local_address_info;
  init_norm (&aa->norm_delay);
  init_norm (&aa->norm_distance);
  init_norm (&aa->norm_utilization_in);
  init_norm (&aa->norm_utilization_out);
  return aa;
}

References ATS_Address::addr, ATS_Address::addr_len, GNUNET_malloc, GNUNET_memcpy, GNUNET_strdup, init_norm(), ATS_Address::local_address_info, ATS_Address::norm_delay, ATS_Address::norm_distance, ATS_Address::norm_utilization_in, ATS_Address::norm_utilization_out, ATS_Address::peer, peer, ATS_Address::plugin, plugin_name, ATS_Address::session_id, and session_id.

Referenced by GAS_addresses_add().

Here is the call graph for this function:

Here is the caller graph for this function:

find_address_cb()

static int find_address_cb ( void *  cls, const struct GNUNET_PeerIdentity *  key, void *  value  )

static

Find session matching given session ID.

Parameters

cls	a struct FindAddressContext
key	peer id
value	the address to compare with

Returns

GNUNET_YES to continue, GNUNET_NO if address is found

Definition at line 161 of file gnunet-service-ats_addresses.c.

{
  struct FindAddressContext *fac = cls;
  struct ATS_Address *aa = value;
 
  if (aa->session_id == fac->session_id)
  {
    fac->exact_address = aa;
    return GNUNET_NO;
  }
  return GNUNET_YES;
}

References fac(), GNUNET_NO, GNUNET_YES, ATS_Address::session_id, and value.

Referenced by find_exact_address().

Here is the call graph for this function:

Here is the caller graph for this function:

find_exact_address()

static struct ATS_Address* find_exact_address ( const struct GNUNET_PeerIdentity *  peer, uint32_t  session_id  )

static

Find the exact address.

Parameters

peer	peer
session_id	session id, can never be 0

Returns

an ATS_address or NULL

Definition at line 185 of file gnunet-service-ats_addresses.c.

{
  struct FindAddressContext fac;
 
  fac.exact_address = NULL;
  fac.session_id = session_id;
  GNUNET_CONTAINER_multipeermap_get_multiple (GSA_addresses,
                                              peer,
                                              &find_address_cb, &fac);
  return fac.exact_address;
}

References fac(), find_address_cb(), GNUNET_CONTAINER_multipeermap_get_multiple(), GSA_addresses, peer, and session_id.

Referenced by GAS_addresses_add(), GAS_addresses_destroy(), and GAS_addresses_update().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_addresses_add()

void GAS_addresses_add	(	const struct GNUNET_PeerIdentity *	peer,
		const char *	plugin_name,
		const void *	plugin_addr,
		size_t	plugin_addr_len,
		uint32_t	local_address_info,
		uint32_t	session_id,
		const struct GNUNET_ATS_Properties *	prop
	)

Add a new address for a peer.

Parameters

peer	peer
plugin_name	transport plugin name
plugin_addr	plugin address
plugin_addr_len	length of the plugin_addr
local_address_info	the local address for the address
session_id	session id, can never be 0.
prop	performance information for this address

Definition at line 200 of file gnunet-service-ats_addresses.c.

{
  struct ATS_Address *new_address;
 
  if (NULL != find_exact_address (peer,
                                  session_id))
  {
    GNUNET_break (0);
    return;
  }
  GNUNET_break (GNUNET_NT_UNSPECIFIED != prop->scope);
  new_address = create_address (peer,
                                plugin_name,
                                plugin_addr,
                                plugin_addr_len,
                                local_address_info,
                                session_id);
  /* Add a new address */
  new_address->properties = *prop;
  new_address->t_added = GNUNET_TIME_absolute_get ();
  new_address->t_last_activity = GNUNET_TIME_absolute_get ();
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_CONTAINER_multipeermap_put (GSA_addresses,
                                                    peer,
                                                    new_address,
                                                    GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE));
  update_addresses_stat ();
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Adding new address for peer `%s' slot %u\n",
              GNUNET_i2s (peer),
              session_id);
  /* Tell solver about new address */
  GAS_plugin_solver_lock ();
  GAS_plugin_new_address (new_address);
  GAS_normalization_update_property (new_address);  // FIXME: needed?
  GAS_plugin_solver_unlock ();
  /* Notify performance clients about new address */
  GAS_performance_notify_all_clients (&new_address->peer,
                                      new_address->plugin,
                                      new_address->addr,
                                      new_address->addr_len,
                                      new_address->active,
                                      &new_address->properties,
                                      new_address->local_address_info,
                                      GNUNET_BANDWIDTH_value_init (
                                        new_address->assigned_bw_out),
                                      GNUNET_BANDWIDTH_value_init (
                                        new_address->assigned_bw_in));
}

References ATS_Address::active, ATS_Address::addr, ATS_Address::addr_len, ATS_Address::assigned_bw_in, ATS_Address::assigned_bw_out, create_address(), find_exact_address(), GAS_normalization_update_property(), GAS_performance_notify_all_clients(), GAS_plugin_new_address(), GAS_plugin_solver_lock(), GAS_plugin_solver_unlock(), GNUNET_assert, GNUNET_BANDWIDTH_value_init(), GNUNET_break, GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_CONTAINER_multipeermap_put(), GNUNET_ERROR_TYPE_INFO, GNUNET_i2s(), GNUNET_log, GNUNET_NT_UNSPECIFIED, GNUNET_OK, GNUNET_TIME_absolute_get(), GSA_addresses, ATS_Address::local_address_info, ATS_Address::peer, peer, ATS_Address::plugin, plugin_name, ATS_Address::properties, GNUNET_ATS_Properties::scope, session_id, ATS_Address::t_added, ATS_Address::t_last_activity, and update_addresses_stat().

Referenced by GAS_handle_address_add().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_addresses_update()

void GAS_addresses_update	(	const struct GNUNET_PeerIdentity *	peer,
		uint32_t	session_id,
		const struct GNUNET_ATS_Properties *	prop
	)

Update an address with new performance information for a peer.

Parameters

peer	peer
session_id	session id, can never be 0
prop	performance information for this address

Definition at line 258 of file gnunet-service-ats_addresses.c.

{
  struct ATS_Address *aa;
 
  /* Get existing address */
  aa = find_exact_address (peer,
                           session_id);
  if (NULL == aa)
  {
    GNUNET_break (0);
    return;
  }
  if (NULL == aa->solver_information)
  {
    GNUNET_break (0);
    return;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Received ADDRESS_UPDATE for peer `%s' slot %u\n",
              GNUNET_i2s (peer),
              (unsigned int) session_id);
  GNUNET_break (GNUNET_NT_UNSPECIFIED != prop->scope);
  /* Update address */
  aa->t_last_activity = GNUNET_TIME_absolute_get ();
  aa->properties = *prop;
  /* Notify performance clients about updated address */
  GAS_performance_notify_all_clients (&aa->peer,
                                      aa->plugin,
                                      aa->addr,
                                      aa->addr_len,
                                      aa->active,
                                      prop,
                                      aa->local_address_info,
                                      GNUNET_BANDWIDTH_value_init (
                                        aa->assigned_bw_out),
                                      GNUNET_BANDWIDTH_value_init (
                                        aa->assigned_bw_in));
 
  GAS_normalization_update_property (aa);
}

References ATS_Address::active, ATS_Address::addr, ATS_Address::addr_len, ATS_Address::assigned_bw_in, ATS_Address::assigned_bw_out, find_exact_address(), GAS_normalization_update_property(), GAS_performance_notify_all_clients(), GNUNET_BANDWIDTH_value_init(), GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, GNUNET_NT_UNSPECIFIED, GNUNET_TIME_absolute_get(), ATS_Address::local_address_info, ATS_Address::peer, peer, ATS_Address::plugin, ATS_Address::properties, GNUNET_ATS_Properties::scope, session_id, ATS_Address::solver_information, and ATS_Address::t_last_activity.

Referenced by GAS_handle_address_update().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_addresses_destroy()

void GAS_addresses_destroy	(	const struct GNUNET_PeerIdentity *	peer,
		uint32_t	session_id
	)

Remove an address for a peer.

Parameters

peer	peer
session_id	session id, can never be 0

Definition at line 309 of file gnunet-service-ats_addresses.c.

{
  struct ATS_Address *ea;
 
  /* Get existing address */
  ea = find_exact_address (peer,
                           session_id);
  if (NULL == ea)
  {
    GNUNET_break (0);
    return;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Received ADDRESS_DESTROYED for peer `%s' session %u\n",
              GNUNET_i2s (peer),
              session_id);
  free_address (ea);
}

References find_exact_address(), free_address(), GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, peer, and session_id.

Referenced by GAS_handle_address_destroyed().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_addresses_init()

void GAS_addresses_init

(

void

)

Initialize address subsystem.

The addresses subsystem manages the addresses known and current performance information. It has a solver component responsible for the resource allocation. It tells the solver about changes and receives updates when the solver changes the resource allocation.

Definition at line 337 of file gnunet-service-ats_addresses.c.

{
  GSA_addresses
    = GNUNET_CONTAINER_multipeermap_create (128,
                                            GNUNET_NO);
  update_addresses_stat ();
}

References GNUNET_CONTAINER_multipeermap_create(), GNUNET_NO, GSA_addresses, and update_addresses_stat().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

destroy_all_address_it()

static int destroy_all_address_it ( void *  cls, const struct GNUNET_PeerIdentity *  key, void *  value  )

static

Destroy all addresses iterator.

Parameters

cls	NULL
key	peer identity (unused)
value	the 'struct ATS_Address' to free

Returns

GNUNET_OK (continue to iterate)

Definition at line 355 of file gnunet-service-ats_addresses.c.

{
  struct ATS_Address *aa = value;
 
  free_address (aa);
  return GNUNET_OK;
}

References free_address(), GNUNET_OK, and value.

Referenced by GAS_addresses_destroy_all().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_addresses_destroy_all()

void GAS_addresses_destroy_all

(

void

)

Remove all addresses.

Definition at line 370 of file gnunet-service-ats_addresses.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Destroying all addresses\n");
  if (NULL == GSA_addresses)
    return;
  if (0 ==
      GNUNET_CONTAINER_multipeermap_size (GSA_addresses))
    return;
  GAS_plugin_solver_lock ();
  GNUNET_CONTAINER_multipeermap_iterate (GSA_addresses,
                                         &destroy_all_address_it,
                                         NULL);
  GAS_plugin_solver_unlock ();
}

References destroy_all_address_it(), GAS_plugin_solver_lock(), GAS_plugin_solver_unlock(), GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_CONTAINER_multipeermap_size(), GNUNET_ERROR_TYPE_INFO, GNUNET_log, and GSA_addresses.

Referenced by GAS_addresses_done(), and GAS_scheduling_remove_client().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_addresses_done()

void GAS_addresses_done

(

void

)

Shutdown address subsystem.

Definition at line 391 of file gnunet-service-ats_addresses.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Shutting down addresses\n");
  GAS_plugin_solver_lock ();
  GAS_addresses_destroy_all ();
  GAS_plugin_solver_unlock ();
  GNUNET_CONTAINER_multipeermap_destroy (GSA_addresses);
  GSA_addresses = NULL;
}

References GAS_addresses_destroy_all(), GAS_plugin_solver_lock(), GAS_plugin_solver_unlock(), GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_ERROR_TYPE_INFO, GNUNET_log, and GSA_addresses.

Referenced by cleanup_task(), and run().

Here is the call graph for this function:

Here is the caller graph for this function:

peerinfo_it()

static int peerinfo_it ( void *  cls, const struct GNUNET_PeerIdentity *  key, void *  value  )

static

Iterator to iterate over a peer's addresses.

Parameters

cls	a struct PeerInfoIteratorContext
key	the peer id
value	the struct ATS_address

Returns

GNUNET_OK to continue

Definition at line 429 of file gnunet-service-ats_addresses.c.

{
  struct PeerInfoIteratorContext *pi_ctx = cls;
  struct ATS_Address *addr = value;
 
  pi_ctx->it (pi_ctx->it_cls,
              &addr->peer,
              addr->plugin,
              addr->addr,
              addr->addr_len,
              addr->active,
              &addr->properties,
              addr->local_address_info,
              GNUNET_BANDWIDTH_value_init (addr->assigned_bw_out),
              GNUNET_BANDWIDTH_value_init (addr->assigned_bw_in));
  return GNUNET_OK;
}

References ATS_Address::addr, GNUNET_BANDWIDTH_value_init(), GNUNET_OK, PeerInfoIteratorContext::it, PeerInfoIteratorContext::it_cls, and value.

Referenced by GAS_addresses_get_peer_info().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_addresses_get_peer_info()

void GAS_addresses_get_peer_info	(	const struct GNUNET_PeerIdentity *	peer,
		GNUNET_ATS_PeerInfo_Iterator	pi_it,
		void *	pi_it_cls
	)

Return information all peers currently known to ATS.

Parameters

peer	the respective peer, NULL for 'all' peers
pi_it	the iterator to call for every peer
pi_it_cls	the closure for pi_it

Definition at line 451 of file gnunet-service-ats_addresses.c.

{
  struct PeerInfoIteratorContext pi_ctx;
 
  if (NULL == pi_it)
  {
    /* does not make sense without callback */
    GNUNET_break (0);
    return;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Returning information for %s from a total of %u known addresses\n",
              (NULL == peer)
              ? "all peers"
              : GNUNET_i2s (peer),
              (unsigned int) GNUNET_CONTAINER_multipeermap_size (
                GSA_addresses));
  pi_ctx.it = pi_it;
  pi_ctx.it_cls = pi_it_cls;
  if (NULL == peer)
    GNUNET_CONTAINER_multipeermap_iterate (GSA_addresses,
                                           &peerinfo_it,
                                           &pi_ctx);
  else
    GNUNET_CONTAINER_multipeermap_get_multiple (GSA_addresses,
                                                peer,
                                                &peerinfo_it, &pi_ctx);
  pi_it (pi_it_cls,
         NULL, NULL, NULL, 0,
         GNUNET_NO,
         NULL,
         GNUNET_HELLO_ADDRESS_INFO_NONE,
         GNUNET_BANDWIDTH_ZERO,
         GNUNET_BANDWIDTH_ZERO);
}

References GNUNET_BANDWIDTH_ZERO, GNUNET_break, GNUNET_CONTAINER_multipeermap_get_multiple(), GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_CONTAINER_multipeermap_size(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_HELLO_ADDRESS_INFO_NONE, GNUNET_i2s(), GNUNET_log, GNUNET_NO, GSA_addresses, PeerInfoIteratorContext::it, PeerInfoIteratorContext::it_cls, peer, and peerinfo_it().

Referenced by GAS_handle_request_address_list(), and GAS_performance_add_client().

Here is the call graph for this function:

Here is the caller graph for this function:

transmit_req_addr()

static void transmit_req_addr ( struct AddressIteration *  ai, const struct GNUNET_PeerIdentity *  id, const char *  plugin_name, const void *  plugin_addr, size_t  plugin_addr_len, int  active, const struct GNUNET_ATS_Properties *  prop, enum GNUNET_HELLO_AddressInfo  local_address_info, struct GNUNET_BANDWIDTH_Value32NBO  bandwidth_out, struct GNUNET_BANDWIDTH_Value32NBO  bandwidth_in  )

static

Send a GNUNET_MESSAGE_TYPE_ATS_ADDRESSLIST_RESPONSE with the given address details to the client identified in ai.

Parameters

ai	our address information context (identifies the client)
id	the peer id this address is for
plugin_name	name of the plugin that supports this address
plugin_addr	address
plugin_addr_len	length of plugin_addr
active	GNUNET_YES if this address is actively used
prop	performance information
local_address_info	flags for the address
bandwidth_out	current outbound bandwidth assigned to address
bandwidth_in	current inbound bandwidth assigned to address

Definition at line 529 of file gnunet-service-ats_addresses.c.

{
  struct GNUNET_MQ_Envelope *env;
  struct PeerInformationMessage *msg;
  char *addrp;
  size_t plugin_name_length;
  size_t msize;
 
  if (NULL != plugin_name)
    plugin_name_length = strlen (plugin_name) + 1;
  else
    plugin_name_length = 0;
  msize = plugin_addr_len + plugin_name_length;
 
  GNUNET_assert (sizeof(struct PeerInformationMessage) + msize
                 < GNUNET_MAX_MESSAGE_SIZE);
  env = GNUNET_MQ_msg_extra (msg,
                             msize,
                             GNUNET_MESSAGE_TYPE_ATS_ADDRESSLIST_RESPONSE);
  msg->id = htonl (ai->id);
  if (NULL != id)
    msg->peer = *id;
  msg->address_length = htons (plugin_addr_len);
  msg->address_active = ntohl (active);
  msg->plugin_name_length = htons (plugin_name_length);
  msg->bandwidth_out = bandwidth_out;
  msg->bandwidth_in = bandwidth_in;
  if (NULL != prop)
    GNUNET_ATS_properties_hton (&msg->properties,
                                prop);
  msg->address_local_info = htonl ((uint32_t) local_address_info);
  addrp = (char *) &msg[1];
  GNUNET_memcpy (addrp,
                 plugin_addr,
                 plugin_addr_len);
  if (NULL != plugin_name)
    strcpy (&addrp[plugin_addr_len],
            plugin_name);
  GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (ai->client),
                  env);
}

References ai, PeerInformationMessage::bandwidth_in, PeerInformationMessage::bandwidth_out, env, GNUNET_assert, GNUNET_ATS_properties_hton(), GNUNET_MAX_MESSAGE_SIZE, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_ATS_ADDRESSLIST_RESPONSE, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_SERVICE_client_get_mq(), id, msg, plugin_name, and PeerInformationMessage::plugin_name_length.

Referenced by GAS_handle_request_address_list(), and req_addr_peerinfo_it().

Here is the call graph for this function:

Here is the caller graph for this function:

req_addr_peerinfo_it()

static void req_addr_peerinfo_it ( void *  cls, const struct GNUNET_PeerIdentity *  id, const char *  plugin_name, const void *  plugin_addr, size_t  plugin_addr_len, int  active, const struct GNUNET_ATS_Properties *  prop, enum GNUNET_HELLO_AddressInfo  local_address_info, struct GNUNET_BANDWIDTH_Value32NBO  bandwidth_out, struct GNUNET_BANDWIDTH_Value32NBO  bandwidth_in  )

static

Iterator for GAS_addresses_get_peer_info(), called with peer-specific information to be passed back to the client.

Parameters

cls	closure with our struct AddressIteration *
id	the peer id
plugin_name	plugin name
plugin_addr	address
plugin_addr_len	length of plugin_addr
active	is address actively used
prop	performance information
local_address_info	additional local info for the address
bandwidth_out	current outbound bandwidth assigned to address
bandwidth_in	current inbound bandwidth assigned to address

Definition at line 598 of file gnunet-service-ats_addresses.c.

{
  struct AddressIteration *ai = cls;
 
  if ((NULL == id) &&
      (NULL == plugin_name) &&
      (NULL == plugin_addr))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Address iteration done for one peer\n");
    return;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Callback for %s peer `%s' plugin `%s' BW out %u, BW in %u\n",
              (active == GNUNET_YES) ? "ACTIVE" : "INACTIVE",
              GNUNET_i2s (id),
              plugin_name,
              (unsigned int) ntohl (bandwidth_out.value__),
              (unsigned int) ntohl (bandwidth_in.value__));
  /* Transmit result (either if address is active, or if
     client wanted all addresses) */
  if ((GNUNET_YES != ai->all) &&
      (GNUNET_YES != active))
    return;
  transmit_req_addr (ai,
                     id,
                     plugin_name,
                     plugin_addr, plugin_addr_len,
                     active,
                     prop,
                     local_address_info,
                     bandwidth_out,
                     bandwidth_in);
}

References ai, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, GNUNET_YES, plugin_name, transmit_req_addr(), and GNUNET_BANDWIDTH_Value32NBO::value__.

Referenced by GAS_handle_request_address_list().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_handle_request_address_list()

void GAS_handle_request_address_list	(	struct GNUNET_SERVICE_Client *	client,
		const struct AddressListRequestMessage *	alrm
	)

Handle 'address list request' messages from clients.

Parameters

client	client that sent the request
alrm	the request message

Definition at line 644 of file gnunet-service-ats_addresses.c.

{
  struct AddressIteration ai;
  struct GNUNET_PeerIdentity allzeros;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Received ADDRESSLIST_REQUEST message\n");
  ai.all = ntohl (alrm->all);
  ai.id = ntohl (alrm->id);
  ai.client = client;
 
  memset (&allzeros,
          '\0',
          sizeof(struct GNUNET_PeerIdentity));
  if (GNUNET_YES == GNUNET_is_zero (&alrm->peer))
  {
    /* Return addresses for all peers */
    GAS_addresses_get_peer_info (NULL,
                                 &req_addr_peerinfo_it,
                                 &ai);
  }
  else
  {
    /* Return addresses for a specific peer */
    GAS_addresses_get_peer_info (&alrm->peer,
                                 &req_addr_peerinfo_it,
                                 &ai);
  }
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Finished handling `%s' message\n",
              "ADDRESSLIST_REQUEST");
  transmit_req_addr (&ai,
                     NULL, NULL, NULL,
                     0, GNUNET_NO,
                     NULL,
                     GNUNET_HELLO_ADDRESS_INFO_NONE,
                     GNUNET_BANDWIDTH_ZERO,
                     GNUNET_BANDWIDTH_ZERO);
}

References ai, AddressListRequestMessage::all, GAS_addresses_get_peer_info(), GNUNET_BANDWIDTH_ZERO, GNUNET_ERROR_TYPE_DEBUG, GNUNET_HELLO_ADDRESS_INFO_NONE, GNUNET_is_zero, GNUNET_log, GNUNET_NO, GNUNET_YES, AddressListRequestMessage::id, AddressListRequestMessage::peer, req_addr_peerinfo_it(), and transmit_req_addr().

Referenced by handle_request_address_list().

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

GSA_addresses

struct GNUNET_CONTAINER_MultiPeerMap* GSA_addresses

A multihashmap to store all addresses.

A multipeermap mapping peer identities to struct ATS_Address.

Definition at line 37 of file gnunet-service-ats_addresses.c.

Referenced by find_exact_address(), free_address(), GAS_addresses_add(), GAS_addresses_destroy_all(), GAS_addresses_done(), GAS_addresses_get_peer_info(), GAS_addresses_init(), GAS_normalization_update_property(), GAS_plugin_init(), handle_feedback(), and update_addresses_stat().