gnunet-service-ats_connectivity.h File Reference

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

#include "ats.h"

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

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

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 'request address' messages from clients. More...
void	GAS_handle_request_address_cancel (struct GNUNET_SERVICE_Client *client, const struct RequestAddressMessage *msg)
	Cancel 'request address' 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 (void)
	Initialize connectivity subsystem. More...
void	GAS_connectivity_done (void)
	Shutdown connectivity subsystem. More...

Detailed Description

ats service, interaction with 'connecivity' API

Author

Matthias Wachs

Christian Grothoff

Definition in file gnunet-service-ats_connectivity.h.

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 'request address' messages from clients.

Parameters

client	client that sent the request
msg	the request message

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:

GAS_handle_request_address_cancel()

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

Cancel 'request address' messages from clients.

Parameters

client	client that sent the request
msg	the request message

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

)

Initialize 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:

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;
}

References connection_requests, free_request(), GAS_plugin_solver_lock(), GAS_plugin_solver_unlock(), GNUNET_CONTAINER_multipeermap_destroy(), and GNUNET_CONTAINER_multipeermap_iterate().

Referenced by cleanup_task(), and run().

Here is the call graph for this function:

Here is the caller graph for this function: