2 This file is part of GNUnet.
3 (C) 2010,2011 Christian Grothoff (and other contributing authors)
5 GNUnet is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published
7 by the Free Software Foundation; either version 3, or (at your
8 option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with GNUnet; see the file COPYING. If not, write to the
17 Free Software Foundation, Inc., 59 Temple Place - Suite 330,
18 Boston, MA 02111-1307, USA.
21 * @file ats/ats_api_peer_change_preference.c
22 * @brief automatic transport selection API, preference management
23 * @author Christian Grothoff
24 * @author Matthias Wachs
28 * - extend API to get performance data
29 * - implement simplistic strategy based on say 'lowest latency' or strict ordering
30 * - extend API to get peer preferences, implement proportional bandwidth assignment
31 * - re-implement API against a real ATS service (!)
34 #include "gnunet_ats_service.h"
37 struct GNUNET_ATS_InformationRequestContext
41 * Our connection to the service.
43 struct GNUNET_ATS_Handle *h;
46 * Link to peer record.
48 struct AllocationRecord *ar;
54 GNUNET_ATS_PeerConfigurationInfoCallback info;
58 struct GNUNET_PeerIdentity peer;
60 GNUNET_SCHEDULER_TaskIdentifier task;
67 const struct GNUNET_SCHEDULER_TaskContext *tc)
69 struct GNUNET_ATS_InformationRequestContext *irc = cls;
72 struct GNUNET_TIME_Relative rdelay;
74 rdelay = GNUNET_TIME_UNIT_ZERO;
75 want_reserv = irc->amount;
78 got_reserv = want_reserv;
80 else if (want_reserv > 0)
83 GNUNET_BANDWIDTH_tracker_get_delay (&irc->ar->available_recv_window,
85 if (rdelay.rel_value == 0)
86 got_reserv = want_reserv;
88 got_reserv = 0; /* all or nothing */
92 GNUNET_BANDWIDTH_tracker_consume (&irc->ar->available_recv_window, got_reserv);
94 irc->info (irc->info_cls,
103 * Obtain statistics and/or change preferences for the given peer.
105 * @param h core handle
106 * @param peer identifies the peer
107 * @param amount reserve N bytes for receiving, negative
108 * amounts can be used to undo a (recent) reservation;
109 * @param preference increase incoming traffic share preference by this amount;
110 * in the absence of "amount" reservations, we use this
111 * preference value to assign proportional bandwidth shares
112 * to all connected peers
113 * @param info function to call with the resulting configuration information
114 * @param info_cls closure for info
115 * @return NULL on error
117 struct GNUNET_ATS_InformationRequestContext *
118 GNUNET_ATS_peer_change_preference (struct GNUNET_ATS_Handle *h,
119 const struct GNUNET_PeerIdentity *peer,
120 int32_t amount, uint64_t preference,
121 GNUNET_ATS_PeerConfigurationInfoCallback
122 info, void *info_cls)
124 struct GNUNET_ATS_InformationRequestContext *irc;
125 struct AllocationRecord *ar;
127 ar = GNUNET_CONTAINER_multihashmap_get (h->peers, &peer->hashPubKey);
130 /* attempt to change preference on peer that is not connected */
134 irc = GNUNET_malloc (sizeof (struct GNUNET_ATS_InformationRequestContext));
138 irc->amount = amount;
139 irc->preference = preference;
141 irc->info_cls = info_cls;
142 irc->task = GNUNET_SCHEDULER_add_now (&exec_pcp, irc);
148 * Cancel request for getting information about a peer.
149 * Note that an eventual change in preference, trust or bandwidth
150 * assignment MAY have already been committed at the time,
151 * so cancelling a request is NOT sure to undo the original
152 * request. The original request may or may not still commit.
153 * The only thing cancellation ensures is that the callback
154 * from the original request will no longer be called.
156 * @param irc context returned by the original GNUNET_ATS_peer_get_info call
159 GNUNET_ATS_peer_change_preference_cancel (struct
160 GNUNET_ATS_InformationRequestContext
163 GNUNET_SCHEDULER_cancel (irc->task);
169 /* old CORE API implementation follows for future reference */
170 struct GNUNET_ATS_InformationRequestContext
174 * Our connection to the service.
176 struct GNUNET_ATS_Handle *h;
179 * Link to control message, NULL if CM was sent.
181 struct ControlMessage *cm;
184 * Link to peer record.
186 struct PeerRecord *pr;
191 * CM was sent, remove link so we don't double-free.
193 * @param cls the 'struct GNUNET_ATS_InformationRequestContext'
194 * @param success were we successful?
197 change_preference_send_continuation (void *cls, int success)
199 struct GNUNET_ATS_InformationRequestContext *irc = cls;
206 * Obtain statistics and/or change preferences for the given peer.
208 * @param h core handle
209 * @param peer identifies the peer
210 * @param amount reserve N bytes for receiving, negative
211 * amounts can be used to undo a (recent) reservation;
212 * @param preference increase incoming traffic share preference by this amount;
213 * in the absence of "amount" reservations, we use this
214 * preference value to assign proportional bandwidth shares
215 * to all connected peers
216 * @param info function to call with the resulting configuration information
217 * @param info_cls closure for info
218 * @return NULL on error
220 struct GNUNET_ATS_InformationRequestContext *
221 GNUNET_ATS_peer_change_preference (struct GNUNET_ATS_Handle *h,
222 const struct GNUNET_PeerIdentity *peer,
223 int32_t amount, uint64_t preference,
224 GNUNET_ATS_PeerConfigurationInfoCallback
225 info, void *info_cls)
227 struct GNUNET_ATS_InformationRequestContext *irc;
228 struct PeerRecord *pr;
229 struct RequestInfoMessage *rim;
230 struct ControlMessage *cm;
232 pr = GNUNET_CONTAINER_multihashmap_get (h->peers, &peer->hashPubKey);
235 /* attempt to change preference on peer that is not connected */
239 if (pr->pcic != NULL)
241 /* second change before first one is done */
245 irc = GNUNET_malloc (sizeof (struct GNUNET_ATS_InformationRequestContext));
248 cm = GNUNET_malloc (sizeof (struct ControlMessage) +
249 sizeof (struct RequestInfoMessage));
250 cm->cont = &change_preference_send_continuation;
253 rim = (struct RequestInfoMessage *) &cm[1];
254 rim->header.size = htons (sizeof (struct RequestInfoMessage));
255 rim->header.type = htons (GNUNET_MESSAGE_TYPE_ATS_REQUEST_INFO);
256 rim->rim_id = htonl (pr->rim_id = h->rim_id_gen++);
257 rim->reserved = htonl (0);
258 rim->reserve_inbound = htonl (amount);
259 rim->preference_change = GNUNET_htonll (preference);
262 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
263 "Queueing CHANGE PREFERENCE request for peer `%s' with RIM %u\n",
264 GNUNET_i2s (peer), (unsigned int) pr->rim_id);
266 GNUNET_CONTAINER_DLL_insert_tail (h->control_pending_head,
267 h->control_pending_tail, cm);
269 pr->pcic_cls = info_cls;
270 pr->pcic_ptr = irc; /* for free'ing irc */
271 if (NULL != h->client)
272 trigger_next_request (h, GNUNET_NO);
278 * Cancel request for getting information about a peer.
279 * Note that an eventual change in preference, trust or bandwidth
280 * assignment MAY have already been committed at the time,
281 * so cancelling a request is NOT sure to undo the original
282 * request. The original request may or may not still commit.
283 * The only thing cancellation ensures is that the callback
284 * from the original request will no longer be called.
286 * @param irc context returned by the original GNUNET_ATS_peer_get_info call
289 GNUNET_ATS_peer_change_preference_cancel (struct
290 GNUNET_ATS_InformationRequestContext
293 struct GNUNET_ATS_Handle *h = irc->h;
294 struct PeerRecord *pr = irc->pr;
296 GNUNET_assert (pr->pcic_ptr == irc);
299 GNUNET_CONTAINER_DLL_remove (h->control_pending_head,
300 h->control_pending_tail, irc->cm);
301 GNUNET_free (irc->cm);
310 /* end of ats_api_peer_change_preference.c */