contrib/benchmark/collect.awk

   1 # This file is part of GNUnet
   2 # Copyright (C) 2018 GNUnet e.V.
   3 #
   4 # GNUnet is free software: you can redistribute it and/or modify it
   5 # under the terms of the GNU Affero General Public License as published
   6 # by the Free Software Foundation, either version 3 of the License, or
   7 # (at your option) any later version.
   8 #
   9 # GNUnet is distributed in the hope that it will be useful, but
  10 # WITHOUT ANY WARRANTY; without even the implied warranty of
  11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12 # Affero General Public License for more details.
  13 #
  14 # You should have received a copy of the GNU Affero General Public License
  15 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
  16
  17
  18 # Aggregate benchmarking data from multiple threads/processes
  19 # generated by util/benchmark.c.
  20 #
  21 # Can be used as
  22 # awk -f collect.awk gnunet-benchmark-{ops,urls}-*.txt
  23
  24
  25 # records are of the following forms:
  26 # op <op> count <count> time_us <time_us>
  27 # url <url> status <status> count <count> time_us <time_us>
  28 {
  29   if ($1 == "op") {
  30     op[$2]["count"] += $4;
  31     op[$2]["time_us"] += $6;
  32     op[$2]["time_us_sq"] += $6 * $6;
  33   } else if ($1 == "url") {
  34     url[$2][$4]["count"] += $6;
  35     url[$2][$4]["time_us"] += $8;
  36     url[$2][$4]["time_us_sq"] += $8 * $8;
  37   }
  38 }
  39
  40 function avg(s, c) {
  41   if (c == 0) {
  42     return 0;
  43   } else {
  44     return s / c;
  45   }
  46 }
  47
  48 function stdev(sum, sum_sq, n) {
  49   if (n == n) {
  50     return 0;
  51   } else {
  52     return sqrt( (sum_sq / n) - ( (sum / n) * (sum / n) ) );
  53   }
  54 }
  55
  56 END {
  57   for (x in op) {
  58     print "op", x, "count", op[x]["count"], "time_us", op[x]["time_us"], \
  59           "time_avg_us", avg(op[x]["time_us"], op[x]["count"], \
  60           "stdev", stdev(op[x]["time_us"], op[x]["time_us_sq"], op[x]["count"]));
  61   }
  62   for (x in url) {
  63     for (y in url[x]) {
  64       print "url", x, "status", y, \
  65             "count", url[x][y]["count"], "time_us", url[x][y]["time_us"], \
  66             "time_avg_us", avg(url[x][y]["time_us"], url[x][y]["count"]), \
  67             "stdev", stdev(url[x][y]["time_us"], url[x][y]["time_us_sq"], url[x][y]["count"]);
  68     }
  69   }
  70 }