gnunet-service-ats_scheduling.c File Reference

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

#include "platform.h"
#include "gnunet-service-ats_addresses.h"
#include "gnunet-service-ats_scheduling.h"
#include "ats.h"

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

Go to the source code of this file.

Functions
int	GAS_scheduling_add_client (struct GNUNET_SERVICE_Client *client)
	Register a new scheduling client. More...
void	GAS_scheduling_remove_client (struct GNUNET_SERVICE_Client *client)
	Unregister a client (which may have been a scheduling client, but this is not assured). More...
void	GAS_scheduling_transmit_address_suggestion (const struct GNUNET_PeerIdentity *peer, uint32_t session_id, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in)
	Transmit the given address suggestion and bandwidth update to all scheduling clients. More...
void	GAS_handle_address_add (const struct AddressAddMessage *m)
	Handle 'address add' messages from clients. More...
void	GAS_handle_address_update (const struct AddressUpdateMessage *m)
	Handle 'address update' messages from clients. More...
void	GAS_handle_address_destroyed (const struct AddressDestroyedMessage *m)
	Handle 'address destroyed' messages from clients. More...

Variables
static struct GNUNET_SERVICE_Client *	my_client
	Actual handle to the client. More...

Detailed Description

ats service, interaction with 'scheduling' API

Author

Matthias Wachs

Christian Grothoff

Definition in file gnunet-service-ats_scheduling.c.

Function Documentation

GAS_scheduling_add_client()

int GAS_scheduling_add_client

(

struct GNUNET_SERVICE_Client *

client

)

Register a new scheduling client.

Parameters

client

handle of the new client

Returns

GNUNET_OK on success, GNUNET_SYSERR on error

Definition at line 45 of file gnunet-service-ats_scheduling.c.

{
  if (NULL != my_client)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "This ATS already has a scheduling client, refusing new scheduling client for now.\n");
    return GNUNET_SYSERR;
  }
  my_client = client;
  return GNUNET_OK;
}

References GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_OK, GNUNET_SYSERR, and my_client.

Referenced by handle_ats_start().

Here is the caller graph for this function:

GAS_scheduling_remove_client()

void GAS_scheduling_remove_client

(

struct GNUNET_SERVICE_Client *

client

)

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

Parameters

client

handle of the (now dead) client

Definition at line 65 of file gnunet-service-ats_scheduling.c.

{
  if (my_client != client)
    return;
  GAS_addresses_destroy_all ();
  my_client = NULL;
}

References GAS_addresses_destroy_all(), and my_client.

Referenced by client_disconnect_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_scheduling_transmit_address_suggestion()

void GAS_scheduling_transmit_address_suggestion	(	const struct GNUNET_PeerIdentity *	peer,
		uint32_t	session_id,
		struct GNUNET_BANDWIDTH_Value32NBO	bandwidth_out,
		struct GNUNET_BANDWIDTH_Value32NBO	bandwidth_in
	)

Transmit the given address suggestion and bandwidth update to all scheduling clients.

Parameters

peer	peer for which this is an address suggestion
session_id	session ID to use for the given client
bandwidth_out	assigned outbound bandwidth
bandwidth_in	assigned inbound bandwidth

Definition at line 75 of file gnunet-service-ats_scheduling.c.

{
  struct GNUNET_MQ_Envelope *env;
  struct AddressSuggestionMessage *msg;
 
  if (NULL == my_client)
    return;
  GNUNET_STATISTICS_update (GSA_stats,
                            "# address suggestions made",
                            1,
                            GNUNET_NO);
  env = GNUNET_MQ_msg (msg,
                       GNUNET_MESSAGE_TYPE_ATS_ADDRESS_SUGGESTION);
  msg->peer = *peer;
  msg->session_id = htonl (session_id);
  msg->bandwidth_out = bandwidth_out;
  msg->bandwidth_in = bandwidth_in;
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "ATS sends quota for peer `%s': (in/out) %u/%u\n",
              GNUNET_i2s (peer),
              (unsigned int) ntohl (bandwidth_in.value__),
              (unsigned int) ntohl (bandwidth_out.value__));
  GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (my_client),
                  env);
}

References AddressSuggestionMessage::bandwidth_in, AddressSuggestionMessage::bandwidth_out, env, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, GNUNET_MESSAGE_TYPE_ATS_ADDRESS_SUGGESTION, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_SERVICE_client_get_mq(), GNUNET_STATISTICS_update(), GSA_stats, msg, my_client, peer, session_id, and GNUNET_BANDWIDTH_Value32NBO::value__.

Referenced by bandwidth_changed_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_handle_address_add()

void GAS_handle_address_add

(

const struct AddressAddMessage *

m

)

Handle 'address add' messages from clients.

Parameters

m	the request message

Definition at line 109 of file gnunet-service-ats_scheduling.c.

{
  const char *address;
  const char *plugin_name;
  uint16_t address_length;
  uint16_t plugin_name_length;
  struct GNUNET_ATS_Properties prop;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Received `%s' message\n",
              "ADDRESS_ADD");
  address_length = ntohs (m->address_length);
  plugin_name_length = ntohs (m->plugin_name_length);
  address = (const char *) &m[1];
  if (plugin_name_length != 0)
    plugin_name = &address[address_length];
  else
    plugin_name = "";
  GNUNET_STATISTICS_update (GSA_stats,
                            "# addresses created",
                            1,
                            GNUNET_NO);
  GNUNET_ATS_properties_ntoh (&prop,
                              &m->properties);
  GNUNET_break (GNUNET_NT_UNSPECIFIED != prop.scope);
  GAS_addresses_add (&m->peer,
                     plugin_name,
                     address,
                     address_length,
                     ntohl (m->address_local_info),
                     ntohl (m->session_id),
                     &prop);
}

References address, GAS_addresses_add(), GNUNET_ATS_properties_ntoh(), GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_NO, GNUNET_NT_UNSPECIFIED, GNUNET_STATISTICS_update(), GSA_stats, m, plugin_name, and GNUNET_ATS_Properties::scope.

Referenced by handle_address_add().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_handle_address_update()

void GAS_handle_address_update

(

const struct AddressUpdateMessage *

m

)

Handle 'address update' messages from clients.

Parameters

m	the request message

Definition at line 150 of file gnunet-service-ats_scheduling.c.

{
  struct GNUNET_ATS_Properties prop;
 
  GNUNET_STATISTICS_update (GSA_stats,
                            "# address updates received",
                            1,
                            GNUNET_NO);
  GNUNET_ATS_properties_ntoh (&prop,
                              &m->properties);
  GAS_addresses_update (&m->peer,
                        ntohl (m->session_id),
                        &prop);
}

References GAS_addresses_update(), GNUNET_ATS_properties_ntoh(), GNUNET_NO, GNUNET_STATISTICS_update(), GSA_stats, and m.

Referenced by handle_address_update().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_handle_address_destroyed()

void GAS_handle_address_destroyed

(

const struct AddressDestroyedMessage *

m

)

Handle 'address destroyed' messages from clients.

Parameters

m	the request message

Definition at line 172 of file gnunet-service-ats_scheduling.c.

{
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_ATS_SessionReleaseMessage *srm;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Received `%s' message\n",
              "ADDRESS_DESTROYED");
  GNUNET_STATISTICS_update (GSA_stats,
                            "# addresses destroyed",
                            1,
                            GNUNET_NO);
  GAS_addresses_destroy (&m->peer,
                         ntohl (m->session_id));
  env = GNUNET_MQ_msg (srm,
                       GNUNET_MESSAGE_TYPE_ATS_SESSION_RELEASE);
  srm->session_id = m->session_id;
  srm->peer = m->peer;
  GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (my_client),
                  env);
}

References env, GAS_addresses_destroy(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_MESSAGE_TYPE_ATS_SESSION_RELEASE, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_SERVICE_client_get_mq(), GNUNET_STATISTICS_update(), GSA_stats, m, my_client, GNUNET_ATS_SessionReleaseMessage::peer, and GNUNET_ATS_SessionReleaseMessage::session_id.

Referenced by handle_address_destroyed().

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

my_client

struct GNUNET_SERVICE_Client* my_client

static

Actual handle to the client.

Definition at line 35 of file gnunet-service-ats_scheduling.c.

Referenced by GAS_handle_address_destroyed(), GAS_scheduling_add_client(), GAS_scheduling_remove_client(), and GAS_scheduling_transmit_address_suggestion().