TAO/orbsvcs/tests/Bug_2925_Regression/Hello_Impl.cpp

   1
   2 #include "Hello_Impl.h"
   3
   4 Hello_Impl::Hello_Impl (CORBA::ORB_ptr orb, MessageLog* logger)
   5   : orb_ (CORBA::ORB::_duplicate (orb))
   6   , logger_ (logger)
   7 {
   8 }
   9
  10 void
  11 Hello_Impl::say_hello (CORBA::Short count)
  12 {
  13   this->logger_->register_message_recv (count);
  14
  15   ACE_DEBUG ((LM_DEBUG,
  16               "%02d<<; ",
  17               count));
  18 }
  19
  20 void
  21 Hello_Impl::shutdown ()
  22 {
  23   try
  24     {
  25       this->orb_->shutdown (0);
  26     }
  27   catch (const CORBA::Exception& ex)
  28     {
  29       //FUZZ: disable check_for_lack_ACE_OS
  30       ex._tao_print_exception ("Exception caught in shutdown ():");
  31       //FUZZ: enable check_for_lack_ACE_OS
  32     }
  33 }
  34
  35 MessageLog::MessageLog (int num)
  36   : expected_ (num)
  37 {
  38   this->rcvd_ = new int[this->expected_];
  39
  40   int i;
  41   for (i = 0; i < this->expected_; i++)
  42     {
  43       this->rcvd_[i] = 0;
  44     }
  45 }
  46
  47 MessageLog::~MessageLog ()
  48 {
  49   delete [] this->rcvd_;
  50 }
  51
  52 void
  53 MessageLog::register_message_recv (int message_num)
  54 {
  55   if (0 <= message_num && message_num < this->expected_)
  56     {
  57       this->rcvd_[message_num]++;
  58     }
  59 }
  60
  61 int
  62 MessageLog::report_statistics ()
  63 {
  64   int i, count = 0;
  65   for (i = 0; i < this->expected_; i++)
  66     {
  67       count += this->rcvd_[i];
  68
  69       if (this->rcvd_[i] == 0)
  70         {
  71           ACE_DEBUG ((LM_DEBUG,
  72                       "\nLOST message <<< %d >>>",
  73                       i));
  74         }
  75     }
  76
  77   return count;
  78 }