aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorJulius Bünger <buenger@mytum.de>2018-06-07 14:18:49 +0200
committerJulius Bünger <buenger@mytum.de>2018-06-07 14:19:43 +0200
commitedc238be68955758e99da87337b984abaa656e93 (patch)
tree16fe30d146044c87c58da6199b0510c091f2f449 /src
parent122caec56d618d8d86d1fa83ddb38b2a6586c7c4 (diff)
downloadgnunet-edc238be68955758e99da87337b984abaa656e93.tar.gz
gnunet-edc238be68955758e99da87337b984abaa656e93.zip
rps profiler: summarize statistics
Diffstat (limited to 'src')
-rw-r--r--src/rps/gnunet-rps-profiler.c57
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
2099void write_final_stats (void){ 2099void 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/**