ACE/protocols/ace/RMCast/Flow.h

   1 // author    : Boris Kolpackov <boris@kolpackov.net>
   2
   3 #ifndef ACE_RMCAST_FLOW_H
   4 #define ACE_RMCAST_FLOW_H
   5
   6 #include "Stack.h"
   7 #include "Protocol.h"
   8 #include "Bits.h"
   9 #include "Parameters.h"
  10
  11 namespace ACE_RMCast
  12 {
  13   class Flow : public Element
  14   {
  15   public:
  16     Flow (Parameters const& );
  17
  18   public:
  19     virtual void
  20     send (Message_ptr m);
  21
  22     virtual void
  23     recv (Message_ptr m);
  24
  25   private:
  26     // Parameters const& params_;
  27
  28     Mutex mutex_;
  29     ACE_Time_Value nak_time_;
  30
  31     // Throughput sampling.
  32     //
  33     ACE_Time_Value sample_start_time_;
  34     unsigned long sample_bytes_;
  35     double current_tput_;
  36     double cap_tput_;
  37   };
  38 }
  39
  40
  41 #endif  // ACE_RMCAST_FLOW_H