TAO/examples/Event_Comm/Notifier_Server.cpp

   1 #include "Notifier_Server.h"
   2 #include "Event_CommC.h"
   3 #include "tao/debug.h"
   4 #include "tao/ORB_Core.h"
   5
   6 // Constructor.
   7 Notifier_Server::Notifier_Server (void)
   8 {
   9 }
  10
  11 // Destructor.
  12
  13 Notifier_Server::~Notifier_Server (void)
  14 {
  15 }
  16
  17 int
  18 Notifier_Server::close (void)
  19 {
  20   try
  21     {
  22       // disconnect all the consumers.
  23       this->servant_.disconnect ("notifier shutdown.");
  24
  25       // Name the object.
  26       CosNaming::Name notifier_obj_name (1);
  27       notifier_obj_name.length (1);
  28       notifier_obj_name[0].id =
  29         CORBA::string_dup (NOTIFIER_BIND_NAME);
  30
  31       this->naming_server_->unbind (notifier_obj_name);
  32
  33       // Instruct the ORB to shutdown.
  34       this->orb_manager_.orb ()->shutdown ();
  35     }
  36   catch (const CORBA::Exception&)
  37     {
  38       return -1;
  39     }
  40
  41     return 0;
  42 }
  43
  44 // The naming service is initialized and the naming context as well as
  45 // the object name is bound to the naming server.
  46
  47 int
  48 Notifier_Server::init_naming_service (void)
  49 {
  50   try
  51     {
  52       CORBA::ORB_var orb = this->orb_manager_.orb ();
  53
  54       TAO_debug_level = 1;
  55
  56       if (this->naming_server_.init (orb.in ()) == -1)
  57         ACE_ERROR_RETURN ((LM_ERROR,
  58                            "Failed to initialize TAO_Naming_Server\n"),
  59                           -1);
  60
  61       // Register the object implementation with the POA.
  62       Event_Comm::Notifier_var notifier_obj =
  63         this->servant_._this ();
  64
  65       // Name the object.
  66       CosNaming::Name notifier_obj_name (1);
  67       notifier_obj_name.length (1);
  68       notifier_obj_name[0].id =
  69         CORBA::string_dup (NOTIFIER_BIND_NAME);
  70
  71       // Now, attach the object name to the context.
  72       this->naming_server_->bind (notifier_obj_name,
  73                                   notifier_obj.in ());
  74     }
  75   catch (const CORBA::Exception& ex)
  76     {
  77       ex._tao_print_exception ("Notifier_Server::init_naming_service\n");
  78       return -1;
  79     }
  80
  81   return 0;
  82 }
  83
  84
  85 // Initialize the server.
  86 int
  87 Notifier_Server::init (int argc,
  88                        ACE_TCHAR *argv[])
  89 {
  90   // Call the init of <TAO_ORB_Manager> to initialize the ORB and
  91   // create the child poa under the root POA.
  92
  93  if (this->orb_manager_.init_child_poa (argc,
  94                                         argv,
  95                                         "child_poa") == -1)
  96
  97    ACE_ERROR_RETURN ((LM_ERROR,
  98                        "%p\n",
  99                       "init_child_poa"),
 100                       -1);
 101
 102  this->orb_manager_.activate_poa_manager ();
 103
 104  // Activate the servant in the POA.
 105  CORBA::String_var str =
 106    this->orb_manager_.activate_under_child_poa (NOTIFIER_BIND_NAME,
 107                                                  &this->servant_);
 108
 109  return this->init_naming_service ();
 110 }
 111
 112 int
 113 Notifier_Server::run (void)
 114 {
 115   ACE_DEBUG ((LM_DEBUG,
 116               "Running the notifier server...\n"));
 117
 118   // Run the main event loop for the ORB.
 119   this->orb_manager_.run ();
 120
 121   return 0;
 122 }
 123
 124 ACE_Reactor *
 125 Notifier_Server::reactor (void)
 126 {
 127   return TAO_ORB_Core_instance ()->reactor ();
 128 }