TAO/examples/CSD_Strategy/ThreadPool2/FooServantList.cpp

   1 #include "FooServantList.h"
   2 #include "Foo_i.h"
   3 #include "OrbShutdownTask.h"
   4
   5 FooServantList::FooServantList(const ACE_TCHAR* prefix,
   6                                unsigned    num_servants,
   7                                unsigned    num_clients,
   8                                CORBA::ORB_ptr orb)
   9   : prefix_(prefix),
  10     num_servants_(num_servants),
  11     num_clients_(num_clients),
  12     orb_ (CORBA::ORB::_duplicate(orb))
  13 {
  14   this->servants_ = new PortableServer::ServantBase_var[num_servants];
  15 }
  16
  17
  18 FooServantList::~FooServantList()
  19 {
  20   delete [] this->servants_;
  21 }
  22
  23
  24 void
  25 FooServantList::create_and_activate(PortableServer::POA_ptr poa)
  26 {
  27   for (unsigned i = 0; i < this->num_servants_; i++)
  28     {
  29       ACE_TCHAR buf[32];
  30       ACE_OS::sprintf(buf, ACE_TEXT("%02d"), i + 1);
  31       ACE_TString servant_name = this->prefix_ + ACE_TEXT("_") + buf;
  32
  33       this->servants_[i] = new Foo_i(servant_name.c_str(),this);
  34
  35       PortableServer::ObjectId_var id =
  36                     PortableServer::string_to_ObjectId(ACE_TEXT_ALWAYS_CHAR(servant_name.c_str()));
  37
  38       poa->activate_object_with_id(id.in(),
  39                                    this->servants_[i].in());
  40
  41       CORBA::Object_var obj = poa->id_to_reference(id.in());
  42
  43       if (CORBA::is_nil(obj.in()))
  44         {
  45           ACE_ERROR((LM_ERROR,
  46                      "(%P|%t) Failed to activate servant (%s).\n",
  47                      servant_name.c_str()));
  48           throw TestException();
  49         }
  50
  51       CORBA::String_var ior
  52         = this->orb_->object_to_string(obj.in());
  53
  54       ACE_TString filename = servant_name + ACE_TEXT(".ior");
  55       FILE* ior_file = ACE_OS::fopen(filename.c_str(), "w");
  56
  57       if (ior_file == 0)
  58         {
  59           ACE_ERROR((LM_ERROR,
  60                      "(%P|%t) Cannot open output file (%s) for writing IOR.",
  61                      filename.c_str()));
  62           throw TestException();
  63         }
  64
  65       ACE_OS::fprintf(ior_file, "%s", ior.in());
  66       ACE_OS::fclose(ior_file);
  67     }
  68 }
  69
  70
  71 void
  72 FooServantList::client_done()
  73 {
  74   unsigned num_left = --this->num_clients_;
  75
  76   if (num_left == 0)
  77     {
  78       if (TheOrbShutdownTask::instance()->open(0) != 0)
  79         {
  80           ACE_ERROR((LM_ERROR, "(%P|%t)FooServantList::client_done: "
  81             "failed to create orb shutdown thread.\n"));
  82         }
  83     }
  84 }