static struct GNUNET_SERVER_Client *my_client;
+/**
+ * Handle to address subsystem
+ */
+static struct GAS_Addresses_Handle *address_handle;
+
/**
* Register a new scheduling client.
*
{
if (my_client != client)
return;
- GAS_addresses_destroy_all ();
+ GAS_addresses_destroy_all (address_handle);
my_client = NULL;
}
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received `%s' message\n",
"REQUEST_ADDRESS");
- GNUNET_STATISTICS_update (GSA_stats, "# address requests received", 1,
- GNUNET_NO);
GNUNET_break (0 == ntohl (msg->reserved));
- GAS_addresses_request_address (&msg->peer);
+ GAS_addresses_request_address (address_handle, &msg->peer);
GNUNET_SERVER_receive_done (client, GNUNET_OK);
}
"REQUEST_ADDRESS_CANCEL");
GNUNET_break (0 == ntohl (msg->reserved));
- GAS_addresses_request_address_cancel (&msg->peer);
+ GAS_addresses_request_address_cancel (address_handle, &msg->peer);
GNUNET_SERVER_receive_done (client, GNUNET_OK);
}
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received `%s' message\n",
"RESET_BACKOFF");
- GNUNET_STATISTICS_update (GSA_stats, "# backoff reset requests received", 1,
- GNUNET_NO);
GNUNET_break (0 == ntohl (msg->reserved));
- GAS_addresses_handle_backoff_reset (&msg->peer);
+ GAS_addresses_handle_backoff_reset (address_handle, &msg->peer);
GNUNET_SERVER_receive_done (client, GNUNET_OK);
}
}
GNUNET_STATISTICS_update (GSA_stats, "# address updates received", 1,
GNUNET_NO);
- GAS_addresses_add (&m->peer, plugin_name, address, address_length,
+ GAS_addresses_add (address_handle, &m->peer, plugin_name, address, address_length,
ntohl (m->session_id), atsi, ats_count);
GNUNET_SERVER_receive_done (client, GNUNET_OK);
}
}
GNUNET_STATISTICS_update (GSA_stats, "# address updates received", 1,
GNUNET_NO);
- GAS_addresses_update (&m->peer, plugin_name, address, address_length,
+ GAS_addresses_update (address_handle, &m->peer, plugin_name, address, address_length,
ntohl (m->session_id), atsi, ats_count);
GNUNET_SERVER_receive_done (client, GNUNET_OK);
}
}
in_use = ntohs (m->in_use);
- res = GAS_addresses_in_use (&m->peer,
- plugin_name,
- address,
- address_length,
- ntohl (m->session_id),
- in_use);
+ res = GAS_addresses_in_use (address_handle,
+ &m->peer,
+ plugin_name,
+ address,
+ address_length,
+ ntohl (m->session_id),
+ in_use);
if (res == GNUNET_OK)
GNUNET_SERVER_receive_done (client, GNUNET_OK);
return;
}
GNUNET_STATISTICS_update (GSA_stats, "# addresses destroyed", 1, GNUNET_NO);
- GAS_addresses_destroy (&m->peer, plugin_name, address, address_length,
+ GAS_addresses_destroy (address_handle, &m->peer, plugin_name,
+ address, address_length,
ntohl (m->session_id));
if (0 != ntohl (m->session_id))
{
* Initialize scheduling subsystem.
*
* @param server handle to our server
+ * @param ah the address handle to use
*/
void
-GAS_scheduling_init (struct GNUNET_SERVER_Handle *server)
+GAS_scheduling_init (struct GNUNET_SERVER_Handle *server, struct GAS_Addresses_Handle *ah)
{
+ GNUNET_assert (NULL != ah);
+ address_handle = ah;
nc = GNUNET_SERVER_notification_context_create (server, 128);
}