Enabled Aggregate flag which computes the h-mean of bandwidth over all configs

Author: healpert

src/Spatter/Configuration.cc

@@ -125,6 +125,7 @@ void ConfigurationBase::report() {
 #else
   double min_time = *std::min_element(time_seconds.begin(), time_seconds.end());
   double bandwidth = static_cast<double>(bytes_moved) / min_time / 1000000.0;
+  m_maximum_bandwidth = bandwidth;
 
   print_no_mpi(bytes_moved, min_time, bandwidth);
 #endif
@@ -309,6 +310,8 @@ void ConfigurationBase::print_mpi(
           0));
   double average_maximum_bandwidth_per_rank = total_maximum_bandwidth /
       static_cast<double>(vector_maximum_bandwidth.size());
+  
+  m_maximum_bandwidth = average_maximum_bandwidth_per_rank;
 
   std::cout << std::setw(15) << std::left << id << std::setw(30) << std::left
             << average_bytes_per_rank << std::setw(30) << std::left

src/Spatter/Configuration.hh

@@ -151,6 +151,7 @@ public:
 
   Spatter::Timer timer;
   std::vector<double> time_seconds;
+  double m_maximum_bandwidth = -1.0;
 };
 
 std::ostream &operator<<(std::ostream &out, const ConfigurationBase &config);

src/main.cc

@@ -125,6 +125,9 @@ int main(int argc, char **argv) {
 
   const unsigned long warmup_runs = 10;
   bool timed = 0;
+  // Vars for aggregate
+    double total_inverse_bandwidth = 0.0;
+    size_t n_configs = 0;
 
   Spatter::ClArgs cl;
   if (Spatter::parse_input(argc, argv, cl) != 0)
@@ -164,9 +167,21 @@ int main(int argc, char **argv) {
     if (rank == 0) {
 #endif
     config->report();
+    
+    if(cl.aggregate && config->m_maximum_bandwidth > 0.0){
+      total_inverse_bandwidth += (1.0 / config->m_maximum_bandwidth);
+      n_configs++;
+    }
+
 #ifdef USE_MPI
     }
 #endif
+
+  }
+  if(cl.aggregate && n_configs > 0){
+    double hmean_bandwidth = static_cast<double>(n_configs) / total_inverse_bandwidth;
+
+    std::cout << "Aggregate Summary - Mean Bandwidth: " << hmean_bandwidth << " MB/s" << std::endl;
   }
 
 #ifdef USE_MPI