ats service plugin management More...

#include "platform.h"
#include "gnunet_ats_plugin.h"
#include "gnunet-service-ats_connectivity.h"
#include "gnunet-service-ats_performance.h"
#include "gnunet-service-ats_preferences.h"
#include "gnunet-service-ats_plugins.h"
#include "gnunet-service-ats_reservations.h"
#include "gnunet-service-ats_scheduling.h"
#include "gnunet-service-ats_normalization.h"

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

Functions
void	GAS_plugin_notify_preference_changed (const struct GNUNET_PeerIdentity *peer, enum GNUNET_ATS_PreferenceKind kind, double pref_rel)
	The preference changed for a peer, update solver. More...

void	GAS_plugin_notify_property_changed (struct ATS_Address *address)
	The relative value for a property changed. More...

static void	solver_info_cb (void *cls, enum GAS_Solver_Operation op, enum GAS_Solver_Status status, enum GAS_Solver_Additional_Information add)
	Solver information callback. More...

static void	bandwidth_changed_cb (void cls, struct ATS_Address address)
	Callback for solver to notify about assignment changes. More...

static unsigned long long	parse_quota (const char quota_str, const char direction, enum GNUNET_NetworkType network)
	Convert quota from text to numeric value. More...

static unsigned long long	load_quota (const struct GNUNET_CONFIGURATION_Handle cfg, enum GNUNET_NetworkType type, const char direction)
	Load quota value from the configuration cfg for the given network type and direction. More...

static unsigned int	load_quotas (const struct GNUNET_CONFIGURATION_Handle cfg, unsigned long long out_dest, unsigned long long *in_dest, int dest_length)
	Load quotas for networks from configuration. More...

int	GAS_plugin_init (const struct GNUNET_CONFIGURATION_Handle *cfg)
	Initialize address subsystem. More...

void	GAS_plugin_done ()
	Shutdown address subsystem. More...

void	GAS_plugin_new_address (struct ATS_Address *new_address)
	Tell the solver that the given address can now be used for talking to the respective peer. More...

void	GAS_plugin_delete_address (struct ATS_Address *address)
	Tell the solver that the given address is no longer valid can cannot be used any longer. More...

void	GAS_plugin_notify_feedback (struct GNUNET_SERVICE_Client application, const struct GNUNET_PeerIdentity peer, const struct GNUNET_TIME_Relative scope, enum GNUNET_ATS_PreferenceKind kind, float score_abs)
	Tell the solver that the given client has expressed its appreciation for the past performance of a given connection. More...

void	GAS_plugin_solver_lock ()
	Stop instant solving, there are many state updates happening in bulk right now. More...

void	GAS_plugin_solver_unlock ()
	Resume instant solving, we are done with the bulk state updates. More...

void	GAS_plugin_request_connect_start (const struct GNUNET_PeerIdentity *pid)
	Notify the plugin that a request to connect to a particular peer was given to us. More...

void	GAS_plugin_request_connect_stop (const struct GNUNET_PeerIdentity *pid)
	Notify the plugin that a request to connect to a particular peer was dropped. More...

Variables
static struct GNUNET_ATS_SolverFunctions *	sf
	Solver handle. More...

static struct GNUNET_ATS_PluginEnvironment	env
	Solver environment. More...

static char *	plugin
	Solver plugin name as string. More...

Detailed Description

ats service plugin management

Author: Matthias Wachs; Christian Grothoff

Definition in file gnunet-service-ats_plugins.c.

Function Documentation

◆ GAS_plugin_notify_preference_changed()

void GAS_plugin_notify_preference_changed	(	const struct GNUNET_PeerIdentity *	peer,
		enum GNUNET_ATS_PreferenceKind	kind,
		double	pref_rel
	)

The preference changed for a peer, update solver.

Parameters

peer	the peer
kind	the ATS kind
pref_rel	the new relative preference value

Definition at line 62 of file gnunet-service-ats_plugins.c.

 {
   sf->s_pref (sf->cls,
               peer,
               kind,
               pref_rel);
 }

References GNUNET_ATS_SolverFunctions::cls, peer, GNUNET_ATS_SolverFunctions::s_pref, and sf.

Referenced by update_relative_values_for_peer().

Here is the caller graph for this function:

◆ GAS_plugin_notify_property_changed()

void GAS_plugin_notify_property_changed ( struct ATS_Address * address )

The relative value for a property changed.

Parameters

address The peer for which a property changed.

Definition at line 74 of file gnunet-service-ats_plugins.c.

 {
   sf->s_address_update_property (sf->cls,
                                  address);
 }

References address, GNUNET_ATS_SolverFunctions::cls, GNUNET_ATS_SolverFunctions::s_address_update_property, and sf.

Referenced by notify_change().

Here is the caller graph for this function:

◆ solver_info_cb()

static void solver_info_cb	(	void *	cls,
		enum GAS_Solver_Operation	op,
		enum GAS_Solver_Status	status,
		enum GAS_Solver_Additional_Information	add
	)

static

Solver information callback.

Parameters

cls	the closure
op	the operation
status	operation status
add	additional information

Definition at line 90 of file gnunet-service-ats_plugins.c.

 {
   const char *add_info;
  
   switch (add)
   {
   case GAS_INFO_NONE:
     add_info = "GAS_INFO_NONE";
     break;
  
   case GAS_INFO_FULL:
     add_info = "GAS_INFO_MLP_FULL";
     break;
  
   case GAS_INFO_UPDATED:
     add_info = "GAS_INFO_MLP_UPDATED";
     break;
  
   case GAS_INFO_PROP_ALL:
     add_info = "GAS_INFO_PROP_ALL";
     break;
  
   case GAS_INFO_PROP_SINGLE:
     add_info = "GAS_INFO_PROP_SINGLE";
     break;
  
   default:
     add_info = "INVALID";
     break;
   }
   switch (op)
   {
   case GAS_OP_SOLVE_START:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s' `%s'\n",
                 "GAS_OP_SOLVE_START",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL",
                 add_info);
     return;
  
   case GAS_OP_SOLVE_STOP:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_STOP",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   case GAS_OP_SOLVE_SETUP_START:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_SETUP_START",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   case GAS_OP_SOLVE_SETUP_STOP:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_SETUP_STOP",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   case GAS_OP_SOLVE_MLP_LP_START:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_LP_START",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   case GAS_OP_SOLVE_MLP_LP_STOP:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_LP_STOP",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   case GAS_OP_SOLVE_MLP_MLP_START:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_MLP_START",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   case GAS_OP_SOLVE_MLP_MLP_STOP:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_MLP_STOP",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   case GAS_OP_SOLVE_UPDATE_NOTIFICATION_START:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_UPDATE_NOTIFICATION_START",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   case GAS_OP_SOLVE_UPDATE_NOTIFICATION_STOP:
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Solver notifies `%s' with result `%s'\n",
                 "GAS_OP_SOLVE_UPDATE_NOTIFICATION_STOP",
                 (GAS_STAT_SUCCESS == status) ? "SUCCESS" : "FAIL");
     return;
  
   default:
     GNUNET_break (0);
     break;
   }
 }

References add, GAS_INFO_FULL, GAS_INFO_NONE, GAS_INFO_PROP_ALL, GAS_INFO_PROP_SINGLE, GAS_INFO_UPDATED, GAS_OP_SOLVE_MLP_LP_START, GAS_OP_SOLVE_MLP_LP_STOP, GAS_OP_SOLVE_MLP_MLP_START, GAS_OP_SOLVE_MLP_MLP_STOP, GAS_OP_SOLVE_SETUP_START, GAS_OP_SOLVE_SETUP_STOP, GAS_OP_SOLVE_START, GAS_OP_SOLVE_STOP, GAS_OP_SOLVE_UPDATE_NOTIFICATION_START, GAS_OP_SOLVE_UPDATE_NOTIFICATION_STOP, GAS_STAT_SUCCESS, GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, op, and status.

Referenced by GAS_plugin_init().

Here is the caller graph for this function:

◆ bandwidth_changed_cb()

static void bandwidth_changed_cb	(	void *	cls,
		struct ATS_Address *	address
	)

static

Callback for solver to notify about assignment changes.

Parameters

cls	NULL
address	the address with changes

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

 {
   long long diff_out;
   long long diff_in;
  
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Bandwidth assignment changed for peer %s to %u/%u\n",
               GNUNET_i2s (&address->peer),
               (unsigned int) address->assigned_bw_in,
               (unsigned int) address->assigned_bw_out);
   GAS_reservations_set_bandwidth (&address->peer,
                                   GNUNET_BANDWIDTH_value_init (
                                     address->assigned_bw_in));
   /* Notify performance clients about changes to address */
   GAS_performance_notify_all_clients (&address->peer,
                                       address->plugin,
                                       address->addr,
                                       address->addr_len,
                                       address->active,
                                       &address->properties,
                                       address->local_address_info,
                                       GNUNET_BANDWIDTH_value_init (
                                         address->assigned_bw_out),
                                       GNUNET_BANDWIDTH_value_init (
                                         address->assigned_bw_in));
  
   if ((0 == address->assigned_bw_in) &&
       (0 == address->assigned_bw_out))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Telling transport to disconnect peer `%s'\n",
                 GNUNET_i2s (&address->peer));
  
     /* Notify scheduling clients about suggestion */
     GAS_scheduling_transmit_address_suggestion (&address->peer,
                                                 address->session_id,
                                                 GNUNET_BANDWIDTH_ZERO,
                                                 GNUNET_BANDWIDTH_ZERO);
     return;
   }
  
   /* Do bandwidth stability check */
   diff_out = llabs ((long long) address->assigned_bw_out
                     - (long long) address->last_notified_bw_out);
   diff_in = llabs ((long long) address->assigned_bw_in
                    - (long long) address->last_notified_bw_in);
   if ((diff_out < htonl (GNUNET_CONSTANTS_DEFAULT_BW_IN_OUT.value__)) &&
       (diff_in < htonl (GNUNET_CONSTANTS_DEFAULT_BW_IN_OUT.value__)))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Bandwidth change too small, not notifying client\n");
     return;
   }
  
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Sending bandwidth update for peer `%s': %u/%u\n",
               GNUNET_i2s (&address->peer),
               address->assigned_bw_out,
               address->assigned_bw_out);
  
   /* *Notify scheduling clients about suggestion */
   GAS_scheduling_transmit_address_suggestion (&address->peer,
                                               address->session_id,
                                               GNUNET_BANDWIDTH_value_init (
                                                 address->assigned_bw_out),
                                               GNUNET_BANDWIDTH_value_init (
                                                 address->assigned_bw_in));
  
   address->last_notified_bw_out = address->assigned_bw_out;
   address->last_notified_bw_in = address->assigned_bw_in;
 }

References address, GAS_performance_notify_all_clients(), GAS_reservations_set_bandwidth(), GAS_scheduling_transmit_address_suggestion(), GNUNET_BANDWIDTH_value_init(), GNUNET_BANDWIDTH_ZERO, GNUNET_CONSTANTS_DEFAULT_BW_IN_OUT, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), and GNUNET_log.

Referenced by GAS_plugin_init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ parse_quota()

static unsigned long long parse_quota	(	const char *	quota_str,
		const char *	direction,
		enum GNUNET_NetworkType	network
	)

static

Convert quota from text to numeric value.

Parameters

quota_str	the value found in the configuration
direction	direction of the quota
network	network the quota applies to

Returns: numeric quota value to use

Definition at line 293 of file gnunet-service-ats_plugins.c.

 {
   int res;
   unsigned long long ret;
  
   res = GNUNET_NO;
   if (0 == strcmp (quota_str, GNUNET_ATS_MaxBandwidthString))
   {
     ret = GNUNET_ATS_MaxBandwidth;
     res = GNUNET_YES;
   }
   if ((GNUNET_NO == res) &&
       (GNUNET_OK ==
        GNUNET_STRINGS_fancy_size_to_bytes (quota_str,
                                            &ret)))
     res = GNUNET_YES;
   if ((GNUNET_NO == res) &&
       (1 ==
        sscanf (quota_str,
                "%llu",
                &ret)))
     res = GNUNET_YES;
   if (GNUNET_NO == res)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 _ (
                   "Could not load %s quota for network `%s':  `%s', assigning default bandwidth %llu\n"),
                 direction,
                 GNUNET_NT_to_string (network),
                 quota_str,
                 (unsigned long long) GNUNET_ATS_DefaultBandwidth);
     ret = GNUNET_ATS_DefaultBandwidth;
   }
   else
   {
     GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                 _ ("%s quota configured for network `%s' is %llu\n"),
                 direction,
                 GNUNET_NT_to_string (network),
                 ret);
   }
   return ret;
 }

References _, direction, GNUNET_ATS_DefaultBandwidth, GNUNET_ATS_MaxBandwidth, GNUNET_ATS_MaxBandwidthString, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_NO, GNUNET_NT_to_string(), GNUNET_OK, GNUNET_STRINGS_fancy_size_to_bytes(), GNUNET_YES, res, and ret.

Referenced by load_quota().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ load_quota()

static unsigned long long load_quota	(	const struct GNUNET_CONFIGURATION_Handle *	cfg,
		enum GNUNET_NetworkType	type,
		const char *	direction
	)

static

Load quota value from the configuration cfg for the given network type and direction.

Parameters

cfg	configuration to parse
type	network type to parse for
direction	traffic direction to parse for

Returns: quota to apply

Definition at line 350 of file gnunet-service-ats_plugins.c.

 {
   char *entry;
   char *quota_str;
   unsigned long long ret;
  
   GNUNET_asprintf (&entry,
                    "%s_QUOTA_%s",
                    GNUNET_NT_to_string (type),
                    direction);
   if (GNUNET_OK ==
       GNUNET_CONFIGURATION_get_value_string (cfg,
                                              "ats",
                                              entry,
                                              &quota_str))
   {
     ret = parse_quota (quota_str,
                        direction,
                        type);
     GNUNET_free (quota_str);
   }
   else
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 _ (
                   "No %s-quota configured for network `%s', assigning default bandwidth %llu\n"),
                 direction,
                 GNUNET_NT_to_string (type),
                 (unsigned long long) GNUNET_ATS_DefaultBandwidth);
     ret = GNUNET_ATS_DefaultBandwidth;
   }
   GNUNET_free (entry);
   return ret;
 }

References _, cfg, direction, GNUNET_asprintf(), GNUNET_ATS_DefaultBandwidth, GNUNET_CONFIGURATION_get_value_string(), GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, GNUNET_NT_to_string(), GNUNET_OK, parse_quota(), ret, and type.

Referenced by load_quotas().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ load_quotas()

static unsigned int load_quotas	(	const struct GNUNET_CONFIGURATION_Handle *	cfg,
		unsigned long long *	out_dest,
		unsigned long long *	in_dest,
		int	dest_length
	)

static

Load quotas for networks from configuration.

Parameters

cfg	configuration handle
out_dest	where to write outbound quotas
in_dest	where to write inbound quotas
dest_length	length of inbound and outbound arrays

Returns: number of networks loaded

Definition at line 398 of file gnunet-service-ats_plugins.c.

 {
   unsigned int c;
  
   for (c = 0; (c < GNUNET_NT_COUNT) && (c < dest_length); c++)
   {
     in_dest[c] = load_quota (cfg,
                              c,
                              "out");
     out_dest[c] = load_quota (cfg,
                               c,
                               "in");
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Loaded quota for network `%s' (in/out): %llu %llu\n",
                 GNUNET_NT_to_string (c),
                 in_dest[c],
                 out_dest[c]);
   }
   return c;
 }

References cfg, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_NT_COUNT, GNUNET_NT_to_string(), and load_quota().

Referenced by GAS_plugin_init().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GAS_plugin_init()

int GAS_plugin_init ( const struct GNUNET_CONFIGURATION_Handle * cfg )

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.

Parameters

cfg	configuration to use

Returns: GNUNET_OK on success, GNUNET_SYSERR on error (failed to load solver plugin)

Definition at line 424 of file gnunet-service-ats_plugins.c.

 {
   char *mode_str;
  
   /* Figure out configured solution method */
   if (GNUNET_SYSERR ==
       GNUNET_CONFIGURATION_get_value_string (cfg,
                                              "ats",
                                              "MODE",
                                              &mode_str))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                 "No resource assignment method configured, using proportional approach\n");
     mode_str = GNUNET_strdup ("proportional");
   }
   env.cls = NULL;
   env.info_cb = &solver_info_cb;
   env.bandwidth_changed_cb = &bandwidth_changed_cb;
   env.get_preferences = &GAS_preference_get_by_peer;
   env.get_connectivity = &GAS_connectivity_has_peer;
   env.cfg = cfg;
   env.stats = GSA_stats;
   env.addresses = GSA_addresses;
   env.network_count = GNUNET_NT_COUNT;
   load_quotas (cfg,
                env.out_quota,
                env.in_quota,
                GNUNET_NT_COUNT);
   GNUNET_asprintf (&plugin,
                    "libgnunet_plugin_ats_%s",
                    mode_str);
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Initializing solver `%s'\n",
               mode_str);
   GNUNET_free (mode_str);
   if (NULL == (sf = GNUNET_PLUGIN_load (plugin, &env)))
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 _ ("Failed to initialize solver `%s'!\n"),
                 plugin);
     return GNUNET_SYSERR;
   }
   return GNUNET_OK;
 }

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GAS_plugin_done()

void GAS_plugin_done ( void )

Shutdown address subsystem.

Definition at line 474 of file gnunet-service-ats_plugins.c.

 {
   GNUNET_PLUGIN_unload (plugin,
                         sf);
   sf = NULL;
   GNUNET_free (plugin);
   plugin = NULL;
 }

References GNUNET_free, GNUNET_PLUGIN_unload(), plugin, and sf.

Referenced by cleanup_task().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GAS_plugin_new_address()

void GAS_plugin_new_address ( struct ATS_Address * new_address )

Tell the solver that the given address can now be used for talking to the respective peer.

Parameters

new_address the new address

Definition at line 485 of file gnunet-service-ats_plugins.c.

 {
   sf->s_add (sf->cls,
              new_address,
              new_address->properties.scope); /* FIXME: remove 3rd arg here! */
 }

References GNUNET_ATS_SolverFunctions::cls, ATS_Address::properties, GNUNET_ATS_SolverFunctions::s_add, GNUNET_ATS_Properties::scope, and sf.

Referenced by GAS_addresses_add().

Here is the caller graph for this function:

◆ GAS_plugin_delete_address()

void GAS_plugin_delete_address ( struct ATS_Address * address )

Tell the solver that the given address is no longer valid can cannot be used any longer.

Parameters

address address that was deleted

Definition at line 500 of file gnunet-service-ats_plugins.c.

 {
   sf->s_del (sf->cls,
              address);
 }

References address, GNUNET_ATS_SolverFunctions::cls, GNUNET_ATS_SolverFunctions::s_del, and sf.

Referenced by free_address().

Here is the caller graph for this function:

◆ GAS_plugin_notify_feedback()

void GAS_plugin_notify_feedback	(	struct GNUNET_SERVICE_Client *	application,
		const struct GNUNET_PeerIdentity *	peer,
		const struct GNUNET_TIME_Relative	scope,
		enum GNUNET_ATS_PreferenceKind	kind,
		float	score_abs
	)

Tell the solver that the given client has expressed its appreciation for the past performance of a given connection.

Parameters

application	client providing the feedback
peer	peer the feedback is about
scope	timeframe the feedback applies to
kind	performance property the feedback relates to
score_abs	degree of the appreciation

Definition at line 518 of file gnunet-service-ats_plugins.c.

 {
   sf->s_feedback (sf->cls,
                   application,
                   peer,
                   scope,
                   kind,
                   score_abs);
 }

References GNUNET_ATS_SolverFunctions::cls, peer, GNUNET_ATS_SolverFunctions::s_feedback, scope, and sf.

Referenced by handle_feedback().

Here is the caller graph for this function:

◆ GAS_plugin_solver_lock()

void GAS_plugin_solver_lock ( void )

Stop instant solving, there are many state updates happening in bulk right now.

Definition at line 538 of file gnunet-service-ats_plugins.c.

 {
   sf->s_bulk_start (sf->cls);
 }

References GNUNET_ATS_SolverFunctions::cls, GNUNET_ATS_SolverFunctions::s_bulk_start, and sf.

Referenced by GAS_addresses_add(), GAS_addresses_destroy_all(), GAS_addresses_done(), GAS_connectivity_done(), GAS_handle_preference_change(), GAS_normalization_update_property(), and preference_aging().

Here is the caller graph for this function:

◆ GAS_plugin_solver_unlock()

void GAS_plugin_solver_unlock ( void )

Resume instant solving, we are done with the bulk state updates.

Definition at line 548 of file gnunet-service-ats_plugins.c.

 {
   sf->s_bulk_stop (sf->cls);
 }

References GNUNET_ATS_SolverFunctions::cls, GNUNET_ATS_SolverFunctions::s_bulk_stop, and sf.

Referenced by GAS_addresses_add(), GAS_addresses_destroy_all(), GAS_addresses_done(), GAS_connectivity_done(), GAS_handle_preference_change(), GAS_normalization_update_property(), and preference_aging().

Here is the caller graph for this function:

◆ GAS_plugin_request_connect_start()

void GAS_plugin_request_connect_start ( const struct GNUNET_PeerIdentity * pid )

Notify the plugin that a request to connect to a particular peer was given to us.

Parameters

pid	identity of peer we now care about

Definition at line 561 of file gnunet-service-ats_plugins.c.

 {
   sf->s_get (sf->cls,
              pid);
 }

References GNUNET_ATS_SolverFunctions::cls, pid, GNUNET_ATS_SolverFunctions::s_get, and sf.

Referenced by GAS_handle_request_address().

Here is the caller graph for this function:

◆ GAS_plugin_request_connect_stop()

void GAS_plugin_request_connect_stop ( const struct GNUNET_PeerIdentity * pid )

Notify the plugin that a request to connect to a particular peer was dropped.

Parameters

pid	identity of peer we care now less about

Definition at line 575 of file gnunet-service-ats_plugins.c.

 {
   sf->s_get_stop (sf->cls,
                   pid);
 }

References GNUNET_ATS_SolverFunctions::cls, pid, GNUNET_ATS_SolverFunctions::s_get_stop, and sf.

Referenced by free_matching_requests().

Here is the caller graph for this function:

Variable Documentation

◆ sf

struct GNUNET_ATS_SolverFunctions* sf

static

Solver handle.

Definition at line 41 of file gnunet-service-ats_plugins.c.

Referenced by GAS_plugin_delete_address(), GAS_plugin_done(), GAS_plugin_init(), GAS_plugin_new_address(), GAS_plugin_notify_feedback(), GAS_plugin_notify_preference_changed(), GAS_plugin_notify_property_changed(), GAS_plugin_request_connect_start(), GAS_plugin_request_connect_stop(), GAS_plugin_solver_lock(), GAS_plugin_solver_unlock(), libgnunet_plugin_ats_proportional_done(), and libgnunet_plugin_ats_proportional_init().

◆ env

struct GNUNET_ATS_PluginEnvironment env

static

Solver environment.

Definition at line 41 of file gnunet-service-ats_plugins.c.

Referenced by GAS_plugin_init().

◆ plugin

char* plugin

static

Solver plugin name as string.

Definition at line 51 of file gnunet-service-ats_plugins.c.

Referenced by GAS_plugin_done(), and GAS_plugin_init().

Functions

Variables

Detailed Description

Function Documentation

◆ GAS_plugin_notify_preference_changed()

◆ GAS_plugin_notify_property_changed()

◆ solver_info_cb()

◆ bandwidth_changed_cb()

◆ parse_quota()

◆ load_quota()

◆ load_quotas()

◆ GAS_plugin_init()

◆ GAS_plugin_done()

◆ GAS_plugin_new_address()

◆ GAS_plugin_delete_address()

◆ GAS_plugin_notify_feedback()

◆ GAS_plugin_solver_lock()

◆ GAS_plugin_solver_unlock()

◆ GAS_plugin_request_connect_start()

◆ GAS_plugin_request_connect_stop()

Variable Documentation

◆ sf

◆ env

◆ plugin