* @param test_core connect to CORE service (GNUNET_YES) or transport (GNUNET_NO)
* @param done_cb function to call when topology is setup
* @param done_cb_cls cls for callback
- * @param transport_recv_cb callback to call when data are received
* @param log_request_cb callback to call when logging is required
*/
void
int test_core,
GNUNET_ATS_TEST_TopologySetupDoneCallback done_cb,
void *done_cb_cls,
- GNUNET_TRANSPORT_ReceiveCallback transport_recv_cb,
GNUNET_ATS_AddressInformationCallback log_request_cb)
{
static struct GNUNET_CORE_MessageHandler handlers[] = {
top->done_cb = done_cb;
top->done_cb_cls = done_cb_cls;
top->test_core = test_core;
- top->transport_recv_cb = transport_recv_cb;
top->ats_perf_cb = log_request_cb;
- top->mps = GNUNET_malloc (num_masters * sizeof (struct BenchmarkPeer));
- top->sps = GNUNET_malloc (num_slaves * sizeof (struct BenchmarkPeer));
+ top->mps = GNUNET_new_array (num_masters,
+ struct BenchmarkPeer);
+ top->sps = GNUNET_new_array (num_slaves,
+ struct BenchmarkPeer);
/* Start topology */
uint64_t event_mask;
struct GNUNET_CORE_MessageHandler *handlers;
- GNUNET_TRANSPORT_ReceiveCallback transport_recv_cb;
-
GNUNET_ATS_TEST_TopologySetupDoneCallback done_cb;
GNUNET_ATS_AddressInformationCallback ats_perf_cb;
void *done_cb_cls;
* @param test_core connect to CORE service (#GNUNET_YES) or transport (#GNUNET_NO)
* @param done_cb function to call when topology is setup
* @param done_cb_cls cls for callback
- * @param transport_recv_cb callback to call when data are received
* @param log_request_cb callback to call when logging is required
*/
void
int test_core,
GNUNET_ATS_TEST_TopologySetupDoneCallback done_cb,
void *done_cb_cls,
- GNUNET_TRANSPORT_ReceiveCallback recv_cb,
GNUNET_ATS_TEST_LogRequest ats_perf_cb);
static void
-transport_recv_cb (void *cls,
- const struct GNUNET_PeerIdentity *peer,
- const struct GNUNET_MessageHeader *message)
+log_request__cb (void *cls,
+ const struct GNUNET_HELLO_Address *address,
+ int address_active,
+ struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out,
+ struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in,
+ const struct GNUNET_ATS_Properties *ats)
{
-
-}
-
-static void
-log_request__cb (void *cls, const struct GNUNET_HELLO_Address *address,
- int address_active, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out,
- struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in,
- const struct GNUNET_ATS_Properties *ats)
-{
-
if (NULL != l)
{
//GNUNET_break (0);
//GNUNET_ATS_TEST_logging_now (l);
}
-
}
static void
experiment_done_cb (struct Experiment *e,
- struct GNUNET_TIME_Relative duration,int success)
+ struct GNUNET_TIME_Relative duration,
+ int success)
{
if (GNUNET_OK == success)
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
static void
episode_done_cb (struct Episode *ep)
{
- GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Episode %u done\n", ep->id);
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "Episode %u done\n",
+ ep->id);
}
-static void topology_setup_done (void *cls,
- struct BenchmarkPeer *masters,
- struct BenchmarkPeer *slaves)
+static void
+topology_setup_done (void *cls,
+ struct BenchmarkPeer *masters,
+ struct BenchmarkPeer *slaves)
{
- GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Topology setup complete!\n");
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "Topology setup complete!\n");
masters_p = masters;
slaves_p = slaves;
masters_p,
e->num_masters, e->num_slaves,
opt_verbose);
- GNUNET_ATS_TEST_experimentation_run (e, &episode_done_cb, &experiment_done_cb);
+ GNUNET_ATS_TEST_experimentation_run (e,
+ &episode_done_cb,
+ &experiment_done_cb);
/*
GNUNET_ATS_TEST_generate_preferences_start(&masters[0],&masters[0].partners[0],
GNUNET_ATS_TEST_TG_CONSTANT, 1, 1, GNUNET_TIME_UNIT_SECONDS,
GNUNET_NO,
&topology_setup_done,
NULL,
- &transport_recv_cb,
&log_request__cb);
GNUNET_free (opt_exp_file);
return 0;