TAO/tests/MT_BiDir/Sender_i.cpp

   1 #include "Sender_i.h"
   2 #include "ace/Manual_Event.h"
   3
   4 Sender_i::Sender_i (CORBA::ULong no_clients,
   5                     ACE_Manual_Event &event)
   6   : event_ (event)
   7   , receivers_ (0)
   8   , no_clients_ (no_clients)
   9   , last_index_ (0)
  10   , payload_ (32768)
  11 {
  12   ACE_NEW (this->receivers_,
  13            Receiver_var [no_clients]);
  14
  15   // Okay to have a magic number...
  16   this->payload_.length (32768);
  17
  18   for (CORBA::ULong j = 0; j != this->payload_.length (); ++j)
  19     this->payload_[j] = (j % 256);
  20 }
  21
  22 Sender_i::~Sender_i ()
  23 {
  24   delete []this->receivers_;
  25 }
  26
  27 CORBA::Long
  28 Sender_i::receiver_object (Receiver_ptr recv)
  29 {
  30   ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
  31                     ace_mon,
  32                     this->mutex_,-1);
  33
  34   if (this->no_clients_ == this->last_index_)
  35     throw Sender::Table_Full ();
  36
  37   this->receivers_[this->last_index_] =
  38     Receiver::_duplicate (recv);
  39
  40   ++this->last_index_;
  41
  42   if (this->last_index_ == this->no_clients_)
  43     {
  44       this->event_.signal ();
  45     }
  46
  47   return this->last_index_;
  48 }
  49
  50
  51 void
  52 Sender_i::send_message ()
  53 {
  54   // NOTE:No synchronization with purpose. Synchrnozing this is
  55   // going to spoil the whole purpose of this test.
  56   CORBA::ULong send_to =
  57     static_cast<CORBA::ULong> (ACE_OS::rand () % this->no_clients_);
  58
  59   this->receivers_[send_to]->receive_payload (this->payload_);
  60 }