diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-01-22 23:04:40 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-01-22 23:04:40 +0000 |
commit | a57305cef1ec471aea627810955e6f6cec36d847 (patch) | |
tree | 475a79a451277b60033a9919fb2499c197cc77ab /src/ats/gnunet-service-ats_scheduling.c | |
parent | 78b8e1c2a54c44992a16b65cdf67fea973e2cad0 (diff) | |
download | gnunet-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.c | 32 |
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 | */ |
42 | static struct GNUNET_SERVER_Client *my_client; | 42 | static struct GNUNET_SERVER_Client *my_client; |
43 | 43 | ||
44 | /** | ||
45 | * Handle to address subsystem | ||
46 | */ | ||
47 | static 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 | */ |
394 | void | 383 | void |
395 | GAS_scheduling_init (struct GNUNET_SERVER_Handle *server, | 384 | GAS_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 | ||