gnunet-service-ats_reservations.h File Reference

ats service, inbound bandwidth reservation management More...

#include "gnunet_util_lib.h"
#include "ats.h"

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

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

Go to the source code of this file.

Functions
void	GAS_reservations_set_bandwidth (const struct GNUNET_PeerIdentity *peer, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in)
	Set the amount of bandwidth the other peer could currently transmit to us (as far as we know) to the given value. More...
void	GAS_handle_reservation_request (struct GNUNET_SERVICE_Client *client, const struct ReservationRequestMessage *message)
	Handle 'reservation request' messages from clients. More...
void	GAS_reservations_init (void)
	Initialize reservations subsystem. More...
void	GAS_reservations_done (void)
	Shutdown reservations subsystem. More...

Detailed Description

ats service, inbound bandwidth reservation management

Author

Christian Grothoff

Definition in file gnunet-service-ats_reservations.h.

Function Documentation

GAS_reservations_set_bandwidth()

void GAS_reservations_set_bandwidth	(	const struct GNUNET_PeerIdentity *	peer,
		struct GNUNET_BANDWIDTH_Value32NBO	bandwidth_in
	)

Set the amount of bandwidth the other peer could currently transmit to us (as far as we know) to the given value.

Parameters

peer	identity of the peer
bandwidth_in	currently available bandwidth from that peer to this peer (estimate)

Definition at line 101 of file gnunet-service-ats_reservations.c.

{
  struct GNUNET_BANDWIDTH_Tracker *tracker;
 
  tracker = GNUNET_CONTAINER_multipeermap_get (trackers, peer);
  if (0 == ntohl (bandwidth_in.value__))
  {
    if (NULL == tracker)
      return;
    GNUNET_assert (GNUNET_YES ==
                   GNUNET_CONTAINER_multipeermap_remove (trackers,
                                                         peer,
                                                         tracker));
    GNUNET_free (tracker);
    return;
  }
  if (NULL == tracker)
  {
    tracker = GNUNET_new (struct GNUNET_BANDWIDTH_Tracker);
    GNUNET_BANDWIDTH_tracker_init (tracker,
                                   NULL,
                                   NULL,
                                   bandwidth_in,
                                   MAX_BANDWIDTH_CARRY_S);
    GNUNET_assert (GNUNET_OK ==
                   GNUNET_CONTAINER_multipeermap_put (trackers,
                                                      peer,
                                                      tracker,
                                                      GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
    return;
  }
  GNUNET_BANDWIDTH_tracker_update_quota (tracker,
                                         bandwidth_in);
}

References GNUNET_assert, GNUNET_BANDWIDTH_tracker_init(), GNUNET_BANDWIDTH_tracker_update_quota(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY, GNUNET_CONTAINER_multipeermap_get(), GNUNET_CONTAINER_multipeermap_put(), GNUNET_CONTAINER_multipeermap_remove(), GNUNET_free, GNUNET_new, GNUNET_OK, GNUNET_YES, MAX_BANDWIDTH_CARRY_S, peer, trackers, 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_reservation_request()

void GAS_handle_reservation_request	(	struct GNUNET_SERVICE_Client *	client,
		const struct ReservationRequestMessage *	message
	)

Handle 'reservation request' messages from clients.

Parameters

client	client that sent the request
message	the request message

Definition at line 139 of file gnunet-service-ats_reservations.c.

{
  struct GNUNET_MQ_Envelope *env;
  struct ReservationResultMessage *result;
  int32_t amount;
  struct GNUNET_TIME_Relative res_delay;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Received RESERVATION_REQUEST message\n");
  amount = (int32_t) ntohl (msg->amount);
  res_delay = reservations_reserve (&msg->peer, amount);
  if (res_delay.rel_value_us > 0)
    amount = 0;
  env = GNUNET_MQ_msg (result,
                       GNUNET_MESSAGE_TYPE_ATS_RESERVATION_RESULT);
  result->amount = htonl (amount);
  result->peer = msg->peer;
  result->res_delay = GNUNET_TIME_relative_hton (res_delay);
  GNUNET_STATISTICS_update (GSA_stats,
                            "# reservation requests processed",
                            1,
                            GNUNET_NO);
  GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (client),
                  env);
}

References ReservationResultMessage::amount, env, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_MESSAGE_TYPE_ATS_RESERVATION_RESULT, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_SERVICE_client_get_mq(), GNUNET_STATISTICS_update(), GNUNET_TIME_relative_hton(), GSA_stats, msg, GNUNET_TIME_Relative::rel_value_us, reservations_reserve(), and result.

Referenced by handle_reservation_request().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_reservations_init()

void GAS_reservations_init

(

void

)

Initialize reservations subsystem.

Definition at line 171 of file gnunet-service-ats_reservations.c.

{
  trackers = GNUNET_CONTAINER_multipeermap_create (128,
                                                   GNUNET_NO);
}

References GNUNET_CONTAINER_multipeermap_create(), GNUNET_NO, and trackers.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

GAS_reservations_done()

void GAS_reservations_done

(

void

)

Shutdown reservations subsystem.

Definition at line 202 of file gnunet-service-ats_reservations.c.

{
  GNUNET_CONTAINER_multipeermap_iterate (trackers,
                                         &free_tracker,
                                         NULL);
  GNUNET_CONTAINER_multipeermap_destroy (trackers);
}

References free_tracker(), GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_CONTAINER_multipeermap_iterate(), and trackers.

Referenced by cleanup_task(), and run().

Here is the call graph for this function:

Here is the caller graph for this function: