FlowRate.h

Go to the documentation of this file.

/*
 * SWC-DB© Copyright since 2019 Alex Kashirin <kashirin.alex@gmail.com>
 * License details at <https://github.com/kashirin-alex/swc-db/#license>
 */
 
#ifndef swcdb_common_Stats_FlowRate_h
#define swcdb_common_Stats_FlowRate_h
 
 
 
namespace SWC { namespace Common { namespace Stats { namespace FlowRate {
 
static const size_t KB = 1024;
static const size_t MB = KB * 1024;
static const size_t GB = MB * 1024;
static const size_t TB = GB * 1024;
static const size_t PB = TB * 1024;
 
struct Data {
  double      bytes = 0;
  const char* bytes_base = "";
  double      time = 0;
  const char* time_base = "";
 
  Data(size_t in_bytes, size_t in_ns) {
          // size_t epochs_bytes = 0, size_t epochs_ns = 0
 
    if(in_ns < 100000) {
      time = in_ns;
      time_base = "nanosecond";
    } else if(in_ns < 10000000) {
      time = double(in_ns)/1000;
      time_base = "microsecond";
    } else if(in_ns <= 10000000000) {
      time = (double(in_ns)/1000)/1000;
      time_base = "millisecond";
    } else if(in_ns <= 3600000000000) {
      time = (double(in_ns)/1000000)/1000;
      time_base = "second";
    } else if(in_ns <= 86400000000000) {
      time = (double(in_ns)/60000000)/1000;
      time_base = "minute";
    } else {
      time = (double(in_ns)/3600000000)/1000;
      time_base = "hour";
    }
 
    if(in_bytes <= MB) {
      bytes = in_bytes;
      bytes_base = "B";
    } else if(in_bytes <= GB ) {
      bytes = double(in_bytes)/KB;
      bytes_base = "KB";
    } else if(in_bytes <= TB) {
      bytes = (double(in_bytes)/KB)/KB;
      bytes_base = "MB";
    } else if(in_bytes <= PB) {
      bytes = (double(in_bytes)/MB)/KB;
      bytes_base = "GB";
    } else {
      bytes = (double(in_bytes)/GB)/KB;
      bytes_base = "TB";
    }
 
  }
 
  //~Data() noexcept { }
 
  void print_cells_statistics(std::ostream& out, size_t cells_count,
                              size_t resend_cells) const {
    out << "Statistics:\n"
        << " Total Time Took:        " << time << " " << time_base     << "s\n"
        << " Total Cells Count:      " << cells_count                  << "\n"
        << " Total Cells Size:       " << bytes << " " << bytes_base   << "\n";
 
    if(resend_cells)
    out << " Resend Cells Count:     " << resend_cells                 << "\n";
 
    out << " Average Transfer Rate:  " << bytes/time << " "
                                       << bytes_base <<"/"<< time_base << "\n"
        << " Average Cells Rate:     " << (cells_count ? cells_count/time : 0)
                                       << " cell/" << time_base        << "\n"
        << std::flush;
  }
};
 
 
}}}} // namespace SWC::Common::Stats
 
 
#endif // swcdb_common_Stats_FlowRate_h