diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/rps/gnunet-rps-profiler.c | 57 |
1 files changed, 56 insertions, 1 deletions
diff --git a/src/rps/gnunet-rps-profiler.c b/src/rps/gnunet-rps-profiler.c index bda43a588..217c2fbbc 100644 --- a/src/rps/gnunet-rps-profiler.c +++ b/src/rps/gnunet-rps-profiler.c | |||
@@ -2098,6 +2098,22 @@ pre_profiler (struct RPSPeer *rps_peer, struct GNUNET_RPS_Handle *h) | |||
2098 | 2098 | ||
2099 | void write_final_stats (void){ | 2099 | void write_final_stats (void){ |
2100 | uint32_t i; | 2100 | uint32_t i; |
2101 | uint64_t sum_rounds = 0; | ||
2102 | uint64_t sum_blocks = 0; | ||
2103 | uint64_t sum_b_mpush = 0; | ||
2104 | uint64_t sum_b_npush = 0; | ||
2105 | uint64_t sum_b_npull = 0; | ||
2106 | uint64_t sum_b_mpush_npull = 0; | ||
2107 | uint64_t sum_b_npush_npull = 0; | ||
2108 | uint64_t sum_iss_push = 0; | ||
2109 | uint64_t sum_iss_pull_req = 0; | ||
2110 | uint64_t sum_iss_pull_rep = 0; | ||
2111 | uint64_t sum_sent_push = 0; | ||
2112 | uint64_t sum_sent_pull_req = 0; | ||
2113 | uint64_t sum_sent_pull_rep = 0; | ||
2114 | uint64_t sum_recv_push = 0; | ||
2115 | uint64_t sum_recv_pull_req = 0; | ||
2116 | uint64_t sum_recv_pull_rep = 0; | ||
2101 | 2117 | ||
2102 | for (i = 0; i < num_peers; i++) | 2118 | for (i = 0; i < num_peers; i++) |
2103 | { | 2119 | { |
@@ -2127,7 +2143,46 @@ void write_final_stats (void){ | |||
2127 | rps_peers[i].num_recv_push, | 2143 | rps_peers[i].num_recv_push, |
2128 | rps_peers[i].num_recv_pull_req, | 2144 | rps_peers[i].num_recv_pull_req, |
2129 | rps_peers[i].num_recv_pull_rep); | 2145 | rps_peers[i].num_recv_pull_rep); |
2130 | } | 2146 | sum_rounds += rps_peers[i].num_rounds; |
2147 | sum_blocks += rps_peers[i].num_blocks; | ||
2148 | sum_b_mpush += rps_peers[i].num_blocks_many_push; | ||
2149 | sum_b_npush += rps_peers[i].num_blocks_no_push; | ||
2150 | sum_b_npull += rps_peers[i].num_blocks_no_pull; | ||
2151 | sum_b_mpush_npull += rps_peers[i].num_blocks_many_push_no_pull; | ||
2152 | sum_b_npush_npull += rps_peers[i].num_blocks_no_push_no_pull; | ||
2153 | sum_iss_push += rps_peers[i].num_issued_push; | ||
2154 | sum_iss_pull_req += rps_peers[i].num_issued_pull_req; | ||
2155 | sum_iss_pull_rep += rps_peers[i].num_issued_pull_rep; | ||
2156 | sum_sent_push += rps_peers[i].num_sent_push; | ||
2157 | sum_sent_pull_req += rps_peers[i].num_sent_pull_req; | ||
2158 | sum_sent_pull_rep += rps_peers[i].num_sent_pull_rep; | ||
2159 | sum_recv_push += rps_peers[i].num_recv_push; | ||
2160 | sum_recv_pull_req += rps_peers[i].num_recv_pull_req; | ||
2161 | sum_recv_pull_rep += rps_peers[i].num_recv_pull_rep; | ||
2162 | } | ||
2163 | to_file ("/tmp/rps/final_stats.dat", | ||
2164 | "SUM %" | ||
2165 | PRIu64 " %" /* rounds */ | ||
2166 | PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" PRIu64 " %" /* blocking */ | ||
2167 | PRIu64 " %" PRIu64 " %" PRIu64 " %" /* issued */ | ||
2168 | PRIu64 " %" PRIu64 " %" PRIu64 " %" /* sent */ | ||
2169 | PRIu64 " %" PRIu64 " %" PRIu64 /* recv */, | ||
2170 | sum_rounds, | ||
2171 | sum_blocks, | ||
2172 | sum_b_mpush, | ||
2173 | sum_b_npush, | ||
2174 | sum_b_npull, | ||
2175 | sum_b_mpush_npull, | ||
2176 | sum_b_npush_npull, | ||
2177 | sum_iss_push, | ||
2178 | sum_iss_pull_req, | ||
2179 | sum_iss_pull_rep, | ||
2180 | sum_sent_push, | ||
2181 | sum_sent_pull_req, | ||
2182 | sum_sent_pull_rep, | ||
2183 | sum_recv_push, | ||
2184 | sum_recv_pull_req, | ||
2185 | sum_recv_pull_rep); | ||
2131 | } | 2186 | } |
2132 | 2187 | ||
2133 | /** | 2188 | /** |