aboutsummaryrefslogtreecommitdiff
path: root/src/ats/gnunet-service-ats_scheduling.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2015-01-22 23:04:40 +0000
committerChristian Grothoff <christian@grothoff.org>2015-01-22 23:04:40 +0000
commita57305cef1ec471aea627810955e6f6cec36d847 (patch)
tree475a79a451277b60033a9919fb2499c197cc77ab /src/ats/gnunet-service-ats_scheduling.c
parent78b8e1c2a54c44992a16b65cdf67fea973e2cad0 (diff)
downloadgnunet-a57305cef1ec471aea627810955e6f6cec36d847.tar.gz
gnunet-a57305cef1ec471aea627810955e6f6cec36d847.zip
use statics instead of singleton struct, simplify internal APIs
Diffstat (limited to 'src/ats/gnunet-service-ats_scheduling.c')
-rw-r--r--src/ats/gnunet-service-ats_scheduling.c32
1 files changed, 9 insertions, 23 deletions
diff --git a/src/ats/gnunet-service-ats_scheduling.c b/src/ats/gnunet-service-ats_scheduling.c
index 90893c08a..c342525f7 100644
--- a/src/ats/gnunet-service-ats_scheduling.c
+++ b/src/ats/gnunet-service-ats_scheduling.c
@@ -41,11 +41,6 @@ static struct GNUNET_SERVER_NotificationContext *nc;
41 */ 41 */
42static struct GNUNET_SERVER_Client *my_client; 42static struct GNUNET_SERVER_Client *my_client;
43 43
44/**
45 * Handle to address subsystem
46 */
47static struct GAS_Addresses_Handle *address_handle;
48
49 44
50/** 45/**
51 * Register a new scheduling client. 46 * Register a new scheduling client.
@@ -79,7 +74,7 @@ GAS_scheduling_remove_client (struct GNUNET_SERVER_Client *client)
79{ 74{
80 if (my_client != client) 75 if (my_client != client)
81 return; 76 return;
82 GAS_addresses_destroy_all (address_handle); 77 GAS_addresses_destroy_all ();
83 my_client = NULL; 78 my_client = NULL;
84} 79}
85 80
@@ -142,7 +137,7 @@ GAS_handle_request_address (void *cls,
142 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received `%s' message\n", 137 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received `%s' message\n",
143 "REQUEST_ADDRESS"); 138 "REQUEST_ADDRESS");
144 GNUNET_break (0 == ntohl (msg->reserved)); 139 GNUNET_break (0 == ntohl (msg->reserved));
145 GAS_addresses_request_address (address_handle, &msg->peer); 140 GAS_addresses_request_address (&msg->peer);
146 GNUNET_SERVER_receive_done (client, GNUNET_OK); 141 GNUNET_SERVER_receive_done (client, GNUNET_OK);
147} 142}
148 143
@@ -166,9 +161,7 @@ GAS_handle_request_address_cancel (void *cls,
166 "Received `%s' message\n", 161 "Received `%s' message\n",
167 "REQUEST_ADDRESS_CANCEL"); 162 "REQUEST_ADDRESS_CANCEL");
168 GNUNET_break (0 == ntohl (msg->reserved)); 163 GNUNET_break (0 == ntohl (msg->reserved));
169 164 GAS_addresses_request_address_cancel (&msg->peer);
170 GAS_addresses_request_address_cancel (address_handle, &msg->peer);
171
172 GNUNET_SERVER_receive_done (client, GNUNET_OK); 165 GNUNET_SERVER_receive_done (client, GNUNET_OK);
173} 166}
174 167
@@ -192,7 +185,7 @@ GAS_handle_reset_backoff (void *cls,
192 "Received `%s' message\n", 185 "Received `%s' message\n",
193 "RESET_BACKOFF"); 186 "RESET_BACKOFF");
194 GNUNET_break (0 == ntohl (msg->reserved)); 187 GNUNET_break (0 == ntohl (msg->reserved));
195 GAS_addresses_handle_backoff_reset (address_handle, &msg->peer); 188 GAS_addresses_handle_backoff_reset (&msg->peer);
196 GNUNET_SERVER_receive_done (client, GNUNET_OK); 189 GNUNET_SERVER_receive_done (client, GNUNET_OK);
197} 190}
198 191
@@ -253,8 +246,7 @@ GAS_handle_address_add (void *cls,
253 GNUNET_STATISTICS_update (GSA_stats, 246 GNUNET_STATISTICS_update (GSA_stats,
254 "# addresses created", 1, 247 "# addresses created", 1,
255 GNUNET_NO); 248 GNUNET_NO);
256 GAS_addresses_add (address_handle, 249 GAS_addresses_add (&m->peer,
257 &m->peer,
258 plugin_name, 250 plugin_name,
259 address, 251 address,
260 address_length, 252 address_length,
@@ -309,8 +301,7 @@ GAS_handle_address_update (void *cls,
309 "# address updates received", 301 "# address updates received",
310 1, 302 1,
311 GNUNET_NO); 303 GNUNET_NO);
312 GAS_addresses_update (address_handle, 304 GAS_addresses_update (&m->peer,
313 &m->peer,
314 ntohl (m->session_id), 305 ntohl (m->session_id),
315 atsi, ats_count); 306 atsi, ats_count);
316 GNUNET_SERVER_receive_done (client, GNUNET_OK); 307 GNUNET_SERVER_receive_done (client, GNUNET_OK);
@@ -333,8 +324,7 @@ GAS_handle_address_in_use (void *cls,
333 int res; 324 int res;
334 325
335 m = (const struct AddressUseMessage *) message; 326 m = (const struct AddressUseMessage *) message;
336 res = GAS_addresses_in_use (address_handle, 327 res = GAS_addresses_in_use (&m->peer,
337 &m->peer,
338 ntohl (m->session_id), 328 ntohl (m->session_id),
339 ntohl (m->in_use)); 329 ntohl (m->in_use));
340 if (GNUNET_OK != res) 330 if (GNUNET_OK != res)
@@ -370,8 +360,7 @@ GAS_handle_address_destroyed (void *cls,
370 "# addresses destroyed", 360 "# addresses destroyed",
371 1, 361 1,
372 GNUNET_NO); 362 GNUNET_NO);
373 GAS_addresses_destroy (address_handle, 363 GAS_addresses_destroy (&m->peer,
374 &m->peer,
375 ntohl (m->session_id)); 364 ntohl (m->session_id));
376 srm.header.type = ntohs (GNUNET_MESSAGE_TYPE_ATS_SESSION_RELEASE); 365 srm.header.type = ntohs (GNUNET_MESSAGE_TYPE_ATS_SESSION_RELEASE);
377 srm.header.size = ntohs (sizeof (struct SessionReleaseMessage)); 366 srm.header.size = ntohs (sizeof (struct SessionReleaseMessage));
@@ -392,11 +381,8 @@ GAS_handle_address_destroyed (void *cls,
392 * @param ah the address handle to use 381 * @param ah the address handle to use
393 */ 382 */
394void 383void
395GAS_scheduling_init (struct GNUNET_SERVER_Handle *server, 384GAS_scheduling_init (struct GNUNET_SERVER_Handle *server)
396 struct GAS_Addresses_Handle *ah)
397{ 385{
398 GNUNET_assert (NULL != ah);
399 address_handle = ah;
400 nc = GNUNET_SERVER_notification_context_create (server, 128); 386 nc = GNUNET_SERVER_notification_context_create (server, 128);
401} 387}
402 388