aboutsummaryrefslogtreecommitdiff
path: root/src/ats/gnunet-service-ats_scheduling.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/ats/gnunet-service-ats_scheduling.c')
-rw-r--r--src/ats/gnunet-service-ats_scheduling.c23
1 files changed, 11 insertions, 12 deletions
diff --git a/src/ats/gnunet-service-ats_scheduling.c b/src/ats/gnunet-service-ats_scheduling.c
index 4659a2363..f5e286a64 100644
--- a/src/ats/gnunet-service-ats_scheduling.c
+++ b/src/ats/gnunet-service-ats_scheduling.c
@@ -142,8 +142,10 @@ GAS_scheduling_transmit_address_suggestion (const struct GNUNET_PeerIdentity
142 memcpy (addrp, plugin_addr, plugin_addr_len); 142 memcpy (addrp, plugin_addr, plugin_addr_len);
143 strcpy (&addrp[plugin_addr_len], plugin_name); 143 strcpy (&addrp[plugin_addr_len], plugin_name);
144 144
145 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "ATS sends quota for peer `%s': (in/out) %u/%u\n", 145 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
146 GNUNET_i2s (peer), ntohl (bandwidth_in.value__), ntohl(bandwidth_out.value__)); 146 "ATS sends quota for peer `%s': (in/out) %u/%u\n",
147 GNUNET_i2s (peer), ntohl (bandwidth_in.value__),
148 ntohl (bandwidth_out.value__));
147 149
148 GNUNET_SERVER_notification_context_unicast (nc, my_client, &msg->header, 150 GNUNET_SERVER_notification_context_unicast (nc, my_client, &msg->header,
149 GNUNET_YES); 151 GNUNET_YES);
@@ -182,8 +184,9 @@ GAS_handle_request_address (void *cls, struct GNUNET_SERVER_Client *client,
182 * @param message the request message 184 * @param message the request message
183 */ 185 */
184void 186void
185GAS_handle_request_address_cancel (void *cls, struct GNUNET_SERVER_Client *client, 187GAS_handle_request_address_cancel (void *cls,
186 const struct GNUNET_MessageHeader *message) 188 struct GNUNET_SERVER_Client *client,
189 const struct GNUNET_MessageHeader *message)
187{ 190{
188 const struct RequestAddressMessage *msg = 191 const struct RequestAddressMessage *msg =
189 (const struct RequestAddressMessage *) message; 192 (const struct RequestAddressMessage *) message;
@@ -304,12 +307,8 @@ GAS_handle_address_in_use (void *cls, struct GNUNET_SERVER_Client *client,
304 } 307 }
305 308
306 in_use = ntohs (m->in_use); 309 in_use = ntohs (m->in_use);
307 GAS_addresses_in_use (&m->peer, 310 GAS_addresses_in_use (&m->peer, plugin_name, address, address_length,
308 plugin_name, 311 ntohl (m->session_id), in_use);
309 address,
310 address_length,
311 ntohl (m->session_id),
312 in_use);
313 312
314 GNUNET_SERVER_receive_done (client, GNUNET_OK); 313 GNUNET_SERVER_receive_done (client, GNUNET_OK);
315} 314}
@@ -359,8 +358,8 @@ GAS_handle_address_destroyed (void *cls, struct GNUNET_SERVER_Client *client,
359 GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); 358 GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
360 return; 359 return;
361 } 360 }
362 if ( (plugin_name_length == 0) || 361 if ((plugin_name_length == 0) ||
363 (plugin_name[plugin_name_length - 1] != '\0')) 362 (plugin_name[plugin_name_length - 1] != '\0'))
364 { 363 {
365 GNUNET_break (0); 364 GNUNET_break (0);
366 GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); 365 GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);