throughput_counter.h

Go to the documentation of this file.

#ifndef THROUGHPUT_COUNTER_CLASS
#define THROUGHPUT_COUNTER_CLASS
 
/*****************************************************************************\
*                                                                             *
*  Name   : throughput_counter                                                *
*  Author : Chris Koeritz                                                     *
*                                                                             *
*******************************************************************************
* Copyright (c) 2000-$now By Author.  This program is free software; you can  *
* redistribute it and/or modify it under the terms of the GNU General Public  *
* License as published by the Free Software Foundation; either version 2 of   *
* the License or (at your option) any later version.  This is online at:      *
*     http://www.fsf.org/copyleft/gpl.html                                    *
* Please send any updates to: fred@gruntose.com                               *
\*****************************************************************************/
 
#include <timely/time_stamp.h>
 
namespace sockets {
 
 
class throughput_counter
{
public:
  throughput_counter();
  throughput_counter(const throughput_counter &to_copy);
  ~throughput_counter();
 
  throughput_counter &operator =(const throughput_counter &to_copy);
 
  void start();
 
  void stop();
 
  void reset();
 
  void combine(const throughput_counter &to_blend);
 
  void send(double size_of_send);
 
  void add_run(double size_of_send, double time_of_send,
          double number_of_runs = 1.0);
 
  bool running() const { return _running; }
 
  timely::time_stamp start_time() const;
 
  timely::time_stamp stop_time() const;
 
  double bytes_sent() const { return _byte_count; }
 
  double number_of_sends() const { return _send_count; }
 
  double bytes_per_second() const;
  double kilobytes_per_second() const;
  double megabytes_per_second() const;
 
  double total_time() const;
 
private:
  bool _running;  
  timely::time_stamp *_start;  
  timely::time_stamp *_end;  
  double _time_overall;  
  double _byte_count;  
  double _send_count;  
};
 
} //namespace.
 
#endif