TAO/tests/Oneways_Invoking_Twoways/Sender_i.cpp

   1 #include "Sender_i.h"
   2
   3 Sender_i::Sender_i (CORBA::ORB_ptr orb,
   4                     CORBA::ULong no)
   5   : orb_ (CORBA::ORB::_duplicate (orb)),
   6     number_ (no),
   7     active_objects_ (0)
   8 {
   9 }
  10
  11 Sender_i::~Sender_i ()
  12 {
  13 }
  14
  15 void
  16 Sender_i::active_objects (CORBA::Short no_threads
  17  /* */ )
  18 {
  19   this->active_objects_ = no_threads;
  20 }
  21
  22
  23 void
  24 Sender_i::send_ready_message (Test::Receiver_ptr receiver)
  25 {
  26   ACE_DEBUG ((LM_DEBUG,
  27               "Received a call ...\n"));
  28
  29   ACE_DEBUG ((LM_DEBUG,
  30               "Calling the Receiver ..\n"));
  31
  32   for (CORBA::ULong i = 0;
  33        i < this->number_;
  34        ++i)
  35     {
  36       receiver->receive_call ();
  37     }
  38
  39 }
  40
  41 void
  42 Sender_i::ping ()
  43 {
  44 }
  45
  46 void
  47 Sender_i::shutdown ()
  48 {
  49   ACE_DEBUG ((LM_DEBUG,
  50               "(%P|%t) About to invoke shutdown...\n"));
  51   this->orb_->shutdown (false);
  52 }