summaryrefslogtreecommitdiff
path: root/src/ats-tests/perf_ats.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2013-09-18 08:12:00 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2013-09-18 08:12:00 +0000
commitf2ae20126c316952ea414594f2f6ff0a0f54ee45 (patch)
treea1b8a1df8f73f380fffff5cfe35127a0228b7f03 /src/ats-tests/perf_ats.c
parent9adcc25df27d1e962543ac7a829f9045dd3f77f1 (diff)
downloadgnunet-f2ae20126c316952ea414594f2f6ff0a0f54ee45.tar.gz
gnunet-f2ae20126c316952ea414594f2f6ff0a0f54ee45.zip
initialize partners during creation
Diffstat (limited to 'src/ats-tests/perf_ats.c')
-rw-r--r--src/ats-tests/perf_ats.c24
1 files changed, 12 insertions, 12 deletions
diff --git a/src/ats-tests/perf_ats.c b/src/ats-tests/perf_ats.c
index 3fb127981..0b0bb19a6 100644
--- a/src/ats-tests/perf_ats.c
+++ b/src/ats-tests/perf_ats.c
@@ -504,22 +504,10 @@ do_benchmark ()
504 &do_shutdown, NULL ); 504 &do_shutdown, NULL );
505 505
506 /* Start sending test messages */ 506 /* Start sending test messages */
507 for (c_s = 0; c_s < num_slaves; c_s++)
508 {
509 for (c_m = 0; c_m < num_masters; c_m++)
510 {
511
512 sps[c_s].partners[c_m].me = &sps[c_s];
513 sps[c_s].partners[c_m].dest = &mps[c_m];
514 }
515 }
516
517 for (c_m = 0; c_m < num_masters; c_m++) 507 for (c_m = 0; c_m < num_masters; c_m++)
518 { 508 {
519 for (c_s = 0; c_s < num_slaves; c_s++) 509 for (c_s = 0; c_s < num_slaves; c_s++)
520 { 510 {
521 mps[c_m].partners[c_s].me = &mps[c_m];
522 mps[c_m].partners[c_s].dest = &sps[c_s];
523 mps[c_m].partners[c_s].cth = GNUNET_CORE_notify_transmit_ready (mps[c_m].ch, 511 mps[c_m].partners[c_s].cth = GNUNET_CORE_notify_transmit_ready (mps[c_m].ch,
524 GNUNET_NO, 0, GNUNET_TIME_UNIT_MINUTES, &sps[c_s].id, 512 GNUNET_NO, 0, GNUNET_TIME_UNIT_MINUTES, &sps[c_s].id,
525 TEST_MESSAGE_SIZE, &core_send_ready, &mps[c_m].partners[c_s]); 513 TEST_MESSAGE_SIZE, &core_send_ready, &mps[c_m].partners[c_s]);
@@ -1048,6 +1036,12 @@ main_run (void *cls, struct GNUNET_TESTBED_RunHandle *h,
1048 mps[c_m].no = c_m; 1036 mps[c_m].no = c_m;
1049 mps[c_m].master = GNUNET_YES; 1037 mps[c_m].master = GNUNET_YES;
1050 mps[c_m].partners = GNUNET_malloc (num_slaves * sizeof (struct BenchmarkPeer)); 1038 mps[c_m].partners = GNUNET_malloc (num_slaves * sizeof (struct BenchmarkPeer));
1039 /* Initialize partners */
1040 for (c_s = 0; c_s < num_slaves; c_s++)
1041 {
1042 mps[c_m].partners[c_s].me = &mps[c_m];
1043 mps[c_m].partners[c_s].dest = &sps[c_s];
1044 }
1051 mps[c_m].peer_id_op = GNUNET_TESTBED_peer_get_information ( 1045 mps[c_m].peer_id_op = GNUNET_TESTBED_peer_get_information (
1052 mps[c_m].peer, GNUNET_TESTBED_PIT_IDENTITY, 1046 mps[c_m].peer, GNUNET_TESTBED_PIT_IDENTITY,
1053 &peerinformation_cb, 1047 &peerinformation_cb,
@@ -1062,6 +1056,12 @@ main_run (void *cls, struct GNUNET_TESTBED_RunHandle *h,
1062 sps[c_s].no = c_s + num_masters; 1056 sps[c_s].no = c_s + num_masters;
1063 sps[c_s].master = GNUNET_NO; 1057 sps[c_s].master = GNUNET_NO;
1064 sps[c_s].partners = GNUNET_malloc (num_masters * sizeof (struct BenchmarkPeer)); 1058 sps[c_s].partners = GNUNET_malloc (num_masters * sizeof (struct BenchmarkPeer));
1059 /* Initialize partners */
1060 for (c_m = 0; c_m < num_masters; c_m++)
1061 {
1062 sps[c_s].partners[c_m].me = &sps[c_s];
1063 sps[c_s].partners[c_m].dest = &mps[c_m];
1064 }
1065 sps[c_s].peer_id_op = GNUNET_TESTBED_peer_get_information ( 1065 sps[c_s].peer_id_op = GNUNET_TESTBED_peer_get_information (
1066 sps[c_s].peer, GNUNET_TESTBED_PIT_IDENTITY, 1066 sps[c_s].peer, GNUNET_TESTBED_PIT_IDENTITY,
1067 &peerinformation_cb, 1067 &peerinformation_cb,