ats service, interaction with 'connecivity' API More...

#include "platform.h"
#include "gnunet-service-ats.h"
#include "gnunet-service-ats_addresses.h"
#include "gnunet-service-ats_connectivity.h"
#include "gnunet-service-ats_plugins.h"
#include "ats.h"

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

Data Structures
struct	ConnectionRequest
	Active connection requests. More...

Functions
unsigned int	GAS_connectivity_has_peer (void cls, const struct GNUNET_PeerIdentity peer)
	Is the given peer in the list of peers for which we have an address request? More...

void	GAS_handle_request_address (struct GNUNET_SERVICE_Client client, const struct RequestAddressMessage msg)
	Handle GNUNET_MESSAGE_TYPE_ATS_REQUEST_ADDRESS messages from clients. More...

static int	free_matching_requests (void cls, const struct GNUNET_PeerIdentity pid, void *value)
	Free the connection request from the map if the closure matches the client. More...

void	GAS_handle_request_address_cancel (struct GNUNET_SERVICE_Client client, const struct RequestAddressMessage msg)
	Handle GNUNET_MESSAGE_TYPE_ATS_REQUEST_ADDRESS_CANCEL messages from clients. More...

void	GAS_connectivity_remove_client (struct GNUNET_SERVICE_Client *client)
	Unregister a client (which may have been a connectivity client, but this is not assured). More...

void	GAS_connectivity_init ()
	Shutdown connectivity subsystem. More...

static int	free_request (void cls, const struct GNUNET_PeerIdentity pid, void *value)
	Free the connection request from the map. More...

void	GAS_connectivity_done ()
	Shutdown connectivity subsystem. More...

Variables
static struct GNUNET_CONTAINER_MultiPeerMap *	connection_requests
	Address suggestion requests by peer. More...

Detailed Description

ats service, interaction with 'connecivity' API

Author: Matthias Wachs; Christian Grothoff

Definition in file gnunet-service-ats_connectivity.c.

Function Documentation

◆ GAS_connectivity_has_peer()

unsigned int GAS_connectivity_has_peer	(	void *	cls,
		const struct GNUNET_PeerIdentity *	peer
	)

Is the given peer in the list of peers for which we have an address request?

Parameters

cls	unused, NULL
peer	peer to query for

Returns: GNUNET_YES if so, GNUNET_NO if not

Definition at line 64 of file gnunet-service-ats_connectivity.c.

 {
   if (NULL == connection_requests)
     return 0;
   /* TODO: return sum of 'strength's of connectivity requests */
   return GNUNET_CONTAINER_multipeermap_contains (connection_requests,
                                                  peer);
 }

References connection_requests, GNUNET_CONTAINER_multipeermap_contains(), and peer.

Referenced by GAS_plugin_init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GAS_handle_request_address()

void GAS_handle_request_address	(	struct GNUNET_SERVICE_Client *	client,
		const struct RequestAddressMessage *	msg
	)

Handle GNUNET_MESSAGE_TYPE_ATS_REQUEST_ADDRESS messages from clients.

Handle 'request address' messages from clients.

Parameters

client	client that sent the request
msg	the request message

Definition at line 82 of file gnunet-service-ats_connectivity.c.

 {
   struct ConnectionRequest *cr;
  
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Received `%s' message\n",
               "GNUNET_MESSAGE_TYPE_ATS_REQUEST_ADDRESS");
   /* FIXME: should not ignore "msg->strength" */
   cr = GNUNET_new (struct ConnectionRequest);
   cr->client = client;
   (void) GNUNET_CONTAINER_multipeermap_put (connection_requests,
                                             &msg->peer,
                                             cr,
                                             GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
   GAS_plugin_request_connect_start (&msg->peer);
 }

References ConnectionRequest::client, connection_requests, GAS_plugin_request_connect_start(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_CONTAINER_multipeermap_put(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_new, and msg.

Referenced by handle_request_address().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ free_matching_requests()

static int free_matching_requests	(	void *	cls,
		const struct GNUNET_PeerIdentity *	pid,
		void *	value
	)

static

Free the connection request from the map if the closure matches the client.

Parameters

cls	the client to match
pid	peer for which the request was made
value	the `struct ConnectionRequest`

Returns: GNUNET_OK (continue to iterate)

Definition at line 111 of file gnunet-service-ats_connectivity.c.

 {
   struct GNUNET_SERVICE_Client *client = cls;
   struct ConnectionRequest *cr = value;
  
   if (cr->client == client)
   {
     GAS_plugin_request_connect_stop (pid);
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Removed request pending for peer `%s\n",
                 GNUNET_i2s (pid));
     GNUNET_assert (GNUNET_YES ==
                    GNUNET_CONTAINER_multipeermap_remove (connection_requests,
                                                          pid,
                                                          cr));
     GNUNET_free (cr);
   }
   return GNUNET_OK;
 }

References ConnectionRequest::client, connection_requests, GAS_plugin_request_connect_stop(), GNUNET_assert, GNUNET_CONTAINER_multipeermap_remove(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_i2s(), GNUNET_log, GNUNET_OK, GNUNET_YES, pid, and value.

Referenced by free_request(), GAS_connectivity_remove_client(), and GAS_handle_request_address_cancel().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GAS_handle_request_address_cancel()

void GAS_handle_request_address_cancel	(	struct GNUNET_SERVICE_Client *	client,
		const struct RequestAddressMessage *	msg
	)

Handle GNUNET_MESSAGE_TYPE_ATS_REQUEST_ADDRESS_CANCEL messages from clients.

Cancel 'request address' messages from clients.

Parameters

client	the client that sent the request
msg	the request message

Definition at line 142 of file gnunet-service-ats_connectivity.c.

 {
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Received GNUNET_MESSAGE_TYPE_ATS_REQUEST_ADDRESS_CANCEL message for peer %s\n",
               GNUNET_i2s (&msg->peer));
   GNUNET_break (0 == ntohl (msg->strength));
   GNUNET_CONTAINER_multipeermap_get_multiple (connection_requests,
                                               &msg->peer,
                                               &free_matching_requests,
                                               client);
 }

References ConnectionRequest::client, connection_requests, free_matching_requests(), GNUNET_break, GNUNET_CONTAINER_multipeermap_get_multiple(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, and msg.

Referenced by handle_request_address_cancel().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GAS_connectivity_remove_client()

void GAS_connectivity_remove_client ( struct GNUNET_SERVICE_Client * client )

Unregister a client (which may have been a connectivity client, but this is not assured).

Parameters

client handle of the (now dead) client

Definition at line 163 of file gnunet-service-ats_connectivity.c.

 {
   if (NULL != connection_requests)
     GNUNET_CONTAINER_multipeermap_iterate (connection_requests,
                                            &free_matching_requests,
                                            client);
 }

References ConnectionRequest::client, connection_requests, free_matching_requests(), and GNUNET_CONTAINER_multipeermap_iterate().

Referenced by client_disconnect_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GAS_connectivity_init()

void GAS_connectivity_init ( void )

Shutdown connectivity subsystem.

Initialize connectivity subsystem.

Definition at line 176 of file gnunet-service-ats_connectivity.c.

 {
   connection_requests
     = GNUNET_CONTAINER_multipeermap_create (32,
                                             GNUNET_NO);
 }

References connection_requests, GNUNET_CONTAINER_multipeermap_create(), and GNUNET_NO.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ free_request()

static int free_request	(	void *	cls,
		const struct GNUNET_PeerIdentity *	pid,
		void *	value
	)

static

Free the connection request from the map.

Parameters

cls	NULL
pid	peer for which the request was made
value	the `struct ConnectionRequest`

Returns: GNUNET_OK (continue to iterate)

Definition at line 193 of file gnunet-service-ats_connectivity.c.

 {
   struct ConnectionRequest *cr = value;
  
   free_matching_requests (cr->client,
                           pid,
                           cr);
   return GNUNET_OK;
 }

References ConnectionRequest::client, free_matching_requests(), GNUNET_OK, pid, and value.

Referenced by GAS_connectivity_done().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GAS_connectivity_done()

void GAS_connectivity_done ( void )

Shutdown connectivity subsystem.

Definition at line 210 of file gnunet-service-ats_connectivity.c.

 {
   GAS_plugin_solver_lock ();
   GNUNET_CONTAINER_multipeermap_iterate (connection_requests,
                                          &free_request,
                                          NULL);
   GAS_plugin_solver_unlock ();
   GNUNET_CONTAINER_multipeermap_destroy (connection_requests);
   connection_requests = NULL;
 }