diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2013-09-18 08:12:00 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2013-09-18 08:12:00 +0000 |
commit | f2ae20126c316952ea414594f2f6ff0a0f54ee45 (patch) | |
tree | a1b8a1df8f73f380fffff5cfe35127a0228b7f03 /src/ats-tests/perf_ats.c | |
parent | 9adcc25df27d1e962543ac7a829f9045dd3f77f1 (diff) | |
download | gnunet-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.c | 24 |
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, |