TAO/performance-tests/Throughput/Receiver.cpp

   1
   2 #include "Receiver.h"
   3 #include "ace/High_Res_Timer.h"
   4
   5 Receiver::Receiver ()
   6   : start_time_ (0)
   7   , message_count_ (0)
   8   , byte_count_ (0)
   9   , last_message_time_ (0)
  10   , last_message_id_ (0)
  11 {
  12 }
  13
  14 void
  15 Receiver::receive_data (const Test::Message &the_message)
  16 {
  17   ACE_hrtime_t now = ACE_OS::gethrtime ();
  18   if (this->message_count_ == 0)
  19     {
  20       this->start_time_ = now;
  21     }
  22   else
  23     {
  24       if (this->last_message_id_ > the_message.message_id)
  25         {
  26           ACE_ERROR ((LM_ERROR,
  27                       "ERROR: (%P|%t) Receiver::receive_data, "
  28                       "message out of sequence %d / %d\n",
  29                       the_message.message_id,
  30                       this->last_message_id_));
  31           return;
  32         }
  33       this->last_message_id_ = the_message.message_id;
  34     }
  35   ++this->message_count_;
  36   this->byte_count_ += the_message.the_payload.length ();
  37   this->last_message_time_ = now;
  38 }
  39
  40 void
  41 Receiver::done ()
  42 {
  43   if (this->message_count_ == 0)
  44     {
  45       ACE_ERROR ((LM_ERROR,
  46                   "ERROR: (%P|%t) Receiver::done, "
  47                   "no messages received\n"));
  48     }
  49   else
  50     {
  51       ACE_High_Res_Timer::global_scale_factor_type gsf =
  52         ACE_High_Res_Timer::global_scale_factor ();
  53
  54       ACE_hrtime_t elapsed_time =
  55         this->last_message_time_ - this->start_time_;
  56
  57       // convert to microseconds
  58       ACE_UINT32 usecs = ACE_UINT32(elapsed_time / gsf);
  59
  60       if (usecs != 0)
  61         {
  62           double bytes =
  63             (1000000.0 * this->byte_count_) / usecs;
  64           double kbytes = bytes / 1024;
  65           double mbytes = kbytes / 1024;
  66           double mbits  = bytes * 8 / 1000000;
  67
  68           ACE_DEBUG ((LM_DEBUG,
  69                       "Receiver %f (bytes/sec), %f (Kb/sec)\n"
  70                       "Receiver %f (Mb/sec), %f Mbits\n",
  71                       bytes, kbytes,
  72                       mbytes, mbits));
  73         }
  74     }
  75
  76   try
  77     {
  78       PortableServer::POA_var poa = this->_default_POA ();
  79       PortableServer::ObjectId_var oid =
  80         poa->servant_to_id (this);
  81       poa->deactivate_object (oid.in ());
  82     }
  83   catch (const CORBA::Exception&){}
  84 }