output_queue_stats.hpp

Go to the documentation of this file.

 
#ifndef OUTPUT_QUEUE_STATS_HPP_INCLUDED
#define OUTPUT_QUEUE_STATS_HPP_INCLUDED
 
#include <cstddef> // std::size_t
#include <numeric> // std::accumulate
 
#include "net_ip/queue_stats.hpp"
#include "net_ip/basic_io_output.hpp"
 
namespace chops {
namespace net {
 
template <typename Iter>
output_queue_stats accumulate_output_queue_stats(Iter beg, Iter end) {
  return std::accumulate(beg, end, output_queue_stats(),
              [] (const output_queue_stats& sum, const auto& io) {
          auto rhs = io.get_output_queue_stats();
          return rhs ? output_queue_stats { sum.output_queue_size + rhs->output_queue_size,
                                            sum.bytes_in_output_queue + rhs->bytes_in_output_queue } :
                       sum;
    }
  );
}
 
template <typename Iter, typename Cond>
void accumulate_output_queue_stats_until(Iter beg, Iter end, Cond&& cond) {
  while (!cond(accumulate_output_queue_stats(beg, end))) {
    ; // no-op, tight loop
  }
}
 
template <typename IOT, typename Iter>
output_queue_stats accumulate_net_entity_output_queue_stats(Iter beg, Iter end) {
  return std::accumulate(beg, end, output_queue_stats(),
              [] (const output_queue_stats& sum, const auto& ne) {
          output_queue_stats st{};
          ne.visit_io_output([&st] (basic_io_output<IOT> io) {
              auto r = io.get_output_queue_stats();
              if (r) {
                st.output_queue_size += r->output_queue_size;
                st.bytes_in_output_queue += r->bytes_in_output_queue;
              }
            }
          );
          return output_queue_stats {sum.output_queue_size + st.output_queue_size,
                                     sum.bytes_in_output_queue + st.bytes_in_output_queue};
    }
  );
}
 
template <typename IOT, typename Iter, typename Cond>
void accumulate_net_entity_output_queue_stats_until(Iter beg, Iter end, Cond&& cond) {
  while (!cond(accumulate_net_entity_output_queue_stats<IOT>(beg, end))) {
    ; // no-op, tight loop
  }
}
 
} // end net namespace
} // end chops namespace
 
#endif