gnunet-service-ats_preferences.h File Reference

manage preferences expressed by clients More...

#include "gnunet_util_lib.h"
#include "gnunet_ats_service.h"
#include "gnunet-service-ats.h"
#include "gnunet_statistics_service.h"
#include "ats.h"

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

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

Go to the source code of this file.

Macros
#define	DEFAULT_ABS_PREFERENCE   0.0
	Default preference value we assume if we know nothing. More...
#define	DEFAULT_REL_PREFERENCE   0.0
	Default relative preference value we assume if we know nothing. More...

Functions
void	GAS_handle_preference_change (struct GNUNET_SERVICE_Client *client, const struct ChangePreferenceMessage *msg)
	Handle 'preference change' messages from clients. More...
void	GAS_preference_init (void)
	Initialize preferences subsystem. More...
void	GAS_preference_done (void)
	Shutdown preferences subsystem. More...
const double *	GAS_preference_get_by_peer (void *cls, const struct GNUNET_PeerIdentity *id)
	Get the normalized preference values for a specific peer. More...
void	GAS_preference_client_disconnect (struct GNUNET_SERVICE_Client *client)
	A performance client disconnected. More...

Detailed Description

manage preferences expressed by clients

Author

Matthias Wachs

Christian Grothoff

Definition in file gnunet-service-ats_preferences.h.

Macro Definition Documentation

DEFAULT_ABS_PREFERENCE

#define DEFAULT_ABS_PREFERENCE   0.0

Default preference value we assume if we know nothing.

Definition at line 38 of file gnunet-service-ats_preferences.h.

DEFAULT_REL_PREFERENCE

#define DEFAULT_REL_PREFERENCE   0.0

Default relative preference value we assume if we know nothing.

Definition at line 43 of file gnunet-service-ats_preferences.h.

Function Documentation

GAS_handle_preference_change()

void GAS_handle_preference_change	(	struct GNUNET_SERVICE_Client *	client,
		const struct ChangePreferenceMessage *	msg
	)

Handle 'preference change' messages from clients.

Parameters

client	the client that sent the request
msg	the request message

Definition at line 650 of file gnunet-service-ats_preferences.c.

{
  const struct PreferenceInformation *pi;
  uint32_t nump;
 
  nump = ntohl (msg->num_preferences);
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Received PREFERENCE_CHANGE message for peer `%s'\n",
              GNUNET_i2s (&msg->peer));
  GNUNET_STATISTICS_update (GSA_stats,
                            "# preference change requests processed",
                            1,
                            GNUNET_NO);
  pi = (const struct PreferenceInformation *) &msg[1];
  GAS_plugin_solver_lock ();
  for (uint32_t i = 0; i < nump; i++)
    update_preference (client,
                       &msg->peer,
                       (enum GNUNET_ATS_PreferenceKind) ntohl (
                         pi[i].preference_kind),
                       pi[i].preference_value);
  GAS_plugin_solver_unlock ();
}

References GAS_plugin_solver_lock(), GAS_plugin_solver_unlock(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, GNUNET_NO, GNUNET_STATISTICS_update(), GSA_stats, msg, pi, PreferenceInformation::preference_kind, PreferenceInformation::preference_value, and update_preference().

Referenced by handle_preference_change().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_preference_init()

void GAS_preference_init

(

void

)

Initialize preferences subsystem.

Definition at line 680 of file gnunet-service-ats_preferences.c.

{
  unsigned int i;
 
  preference_peers = GNUNET_CONTAINER_multipeermap_create (16,
                                                           GNUNET_NO);
  for (i = 0; i < GNUNET_ATS_PREFERENCE_END; i++)
    defvalues.f_rel[i] = DEFAULT_REL_PREFERENCE;
}

References DEFAULT_REL_PREFERENCE, defvalues, PeerRelative::f_rel, GNUNET_ATS_PREFERENCE_END, GNUNET_CONTAINER_multipeermap_create(), GNUNET_NO, and preference_peers.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_preference_done()

void GAS_preference_done

(

void

)

Shutdown preferences subsystem.

Definition at line 695 of file gnunet-service-ats_preferences.c.

{
  struct PreferenceClient *pc;
  struct PreferenceClient *next_pc;
 
  if (NULL != aging_task)
  {
    GNUNET_SCHEDULER_cancel (aging_task);
    aging_task = NULL;
  }
  next_pc = pc_head;
  while (NULL != (pc = next_pc))
  {
    next_pc = pc->next;
    GNUNET_CONTAINER_DLL_remove (pc_head,
                                 pc_tail,
                                 pc);
    GNUNET_CONTAINER_multipeermap_iterate (pc->peer2pref,
                                           &free_preference,
                                           pc);
    GNUNET_CONTAINER_multipeermap_destroy (pc->peer2pref);
    GNUNET_free (pc);
  }
  GNUNET_CONTAINER_multipeermap_iterate (preference_peers,
                                         &free_peer,
                                         NULL);
  GNUNET_CONTAINER_multipeermap_destroy (preference_peers);
}

References aging_task, free_peer(), free_preference(), GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_free, GNUNET_SCHEDULER_cancel(), pc, pc_head, pc_tail, and preference_peers.

Referenced by cleanup_task(), and run().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_preference_get_by_peer()

const double* GAS_preference_get_by_peer	(	void *	cls,
		const struct GNUNET_PeerIdentity *	id
	)

Get the normalized preference values for a specific peer.

Parameters

cls	ignored
id	the peer

Returns

pointer to the values, can be indexed with enum GNUNET_ATS_PreferenceKind, never NULL

Get the normalized preference values for a specific peer.

Parameters

cls	ignored
id	the peer

Returns

pointer to the values, can be indexed with GNUNET_ATS_PreferenceKind, default preferences if peer does not exist

Definition at line 735 of file gnunet-service-ats_preferences.c.

{
  struct PeerRelative *rp;
 
  if (NULL ==
      (rp = GNUNET_CONTAINER_multipeermap_get (preference_peers,
                                               id)))
  {
    return defvalues.f_rel;
  }
  return rp->f_rel;
}

References defvalues, PeerRelative::f_rel, GNUNET_CONTAINER_multipeermap_get(), preference_peers, and rp.

Referenced by GAS_plugin_init(), and get_preferences_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_preference_client_disconnect()

void GAS_preference_client_disconnect

(

struct GNUNET_SERVICE_Client *

client

)

A performance client disconnected.

Parameters

client

the disconnecting client

Definition at line 751 of file gnunet-service-ats_preferences.c.

{
  struct PreferenceClient *c_cur;
 
  for (c_cur = pc_head; NULL != c_cur; c_cur = c_cur->next)
    if (client == c_cur->client)
      break;
  if (NULL == c_cur)
    return;
  GNUNET_CONTAINER_DLL_remove (pc_head,
                               pc_tail,
                               c_cur);
  GNUNET_CONTAINER_multipeermap_iterate (c_cur->peer2pref,
                                         &free_preference,
                                         c_cur);
  GNUNET_CONTAINER_multipeermap_destroy (c_cur->peer2pref);
  GNUNET_free (c_cur);
}

References PreferenceClient::client, free_preference(), GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_free, PreferenceClient::next, pc_head, pc_tail, and PreferenceClient::peer2pref.

Referenced by client_disconnect_cb().

Here is the call graph for this function:

Here is the caller graph for this function: