TAO/orbsvcs/tests/Notify/lib/EventChannel_Command.cpp

   1 #include "EventChannel_Command.h"
   2 #include "ace/Log_Msg.h"
   3
   4
   5 #include "LookupManager.h"
   6 #include "Name.h"
   7 #include "Options_Parser.h"
   8 #include "orbsvcs/Notify/Service.h"
   9
  10 TAO_Notify_Tests_EventChannel_Command::TAO_Notify_Tests_EventChannel_Command ()
  11   : collocated_ (0)
  12 {
  13 }
  14
  15 TAO_Notify_Tests_EventChannel_Command::~TAO_Notify_Tests_EventChannel_Command ()
  16 {
  17 }
  18
  19 const char*
  20 TAO_Notify_Tests_EventChannel_Command::get_name ()
  21 {
  22   return TAO_Notify_Tests_EventChannel_Command::name ();
  23 }
  24
  25 const char*
  26 TAO_Notify_Tests_EventChannel_Command::name ()
  27 {
  28   return TAO_Notify_Tests_Name::event_channel_command;
  29 }
  30
  31 void
  32 TAO_Notify_Tests_EventChannel_Command::init (ACE_Arg_Shifter& arg_shifter)
  33 {
  34   if (arg_shifter.is_anything_left ())
  35     {
  36       if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("-Create")) == 0) // -Create ec_name factory_name [COLLOCATED]
  37         {
  38           this->command_ = CREATE;
  39
  40           arg_shifter.consume_arg ();
  41
  42           this->name_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  43           arg_shifter.consume_arg ();
  44
  45           this->factory_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  46           arg_shifter.consume_arg ();
  47
  48           if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("COLLOCATED")) == 0)
  49             {
  50               this->collocated_ = 1;
  51             }
  52
  53           if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("COLOCATED")) == 0) // grandfather in misspelled
  54             {
  55               this->collocated_ = 1;
  56               ACE_DEBUG ((LM_WARNING, "TAO_Notify_Tests_EventChannel_Command::init --"
  57                           " warning: deprecated misspelled COLOCATED option used.\n"));
  58             }
  59         }
  60       else if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("-Destroy")) == 0) // -Destroy ec_name
  61         {
  62           this->command_ = DESTROY;
  63
  64           arg_shifter.consume_arg ();
  65
  66           this->name_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  67
  68           arg_shifter.consume_arg ();
  69         }
  70       else if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("-Set_QoS")) == 0) // -Set_QoS ec_name [Qos Options]
  71         {
  72           this->command_ = SET_QOS;
  73
  74           arg_shifter.consume_arg ();
  75
  76           this->name_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  77
  78           arg_shifter.consume_arg ();
  79
  80           TAO_Notify_Tests_Options_Parser qos_parser;
  81           qos_parser.execute (this->qos_, arg_shifter);
  82         }
  83     }
  84 }
  85
  86 void
  87 TAO_Notify_Tests_EventChannel_Command::create_collocated_ecf ()
  88 {
  89   CosNotifyChannelAdmin::EventChannelFactory_var notify_factory;
  90
  91   // The Service Object.
  92   TAO_Notify_Service* notify_service = TAO_Notify_Service::load_default ();
  93
  94   if (notify_service == 0)
  95     {
  96       ACE_DEBUG ((LM_DEBUG, "Service not found! check conf. file\n"));
  97       return;
  98     }
  99
 100   // Resolve some helpers.
 101   CORBA::ORB_var orb;
 102   PortableServer::POA_var poa;
 103   CosNaming::NamingContextExt_var naming;
 104
 105   LOOKUP_MANAGER->resolve (orb);
 106
 107   LOOKUP_MANAGER->resolve (poa);
 108
 109   LOOKUP_MANAGER->resolve (naming);
 110
 111   notify_service->init_service (orb.in ());
 112
 113   // Activate the factory
 114   notify_factory =
 115     notify_service->create (poa.in ());
 116
 117   // Register with the Naming Service
 118   CosNaming::Name_var name =
 119     naming->to_name (TAO_Notify_Tests_Name::event_channel_factory);
 120
 121   naming->rebind (name.in (),
 122                   notify_factory.in ());
 123 }
 124
 125 void
 126 TAO_Notify_Tests_EventChannel_Command::handle_create ()
 127 {
 128   if (this->collocated_ == 1)
 129     {
 130       this->create_collocated_ecf ();
 131     }
 132
 133   CosNotifyChannelAdmin::EventChannelFactory_var ec_factory;
 134
 135   LOOKUP_MANAGER->resolve (ec_factory , TAO_Notify_Tests_Name::event_channel_factory);
 136
 137   CosNotification::QoSProperties qos;
 138   CosNotification::AdminProperties admin;
 139
 140   // Create an event channel
 141   CosNotifyChannelAdmin::EventChannel_var ec =
 142     ec_factory->create_channel (qos,
 143                                 admin,
 144                                 this->id_);
 145
 146   LOOKUP_MANAGER->_register (ec.in(), this->name_.c_str ());
 147 }
 148
 149 void
 150 TAO_Notify_Tests_EventChannel_Command::handle_destroy ()
 151 {
 152   ACE_DEBUG ((LM_DEBUG, "Destroying event channel %s\n", this->name_.c_str ()));
 153   CosNotifyChannelAdmin::EventChannel_var ec;
 154
 155   LOOKUP_MANAGER->resolve (ec, this->name_.c_str ());
 156
 157   ec->destroy ();
 158 }
 159 void
 160 TAO_Notify_Tests_EventChannel_Command::handle_set_qos ()
 161 {
 162   CosNotifyChannelAdmin::EventChannel_var ec;
 163
 164   LOOKUP_MANAGER->resolve (ec, this->name_.c_str ());
 165
 166   ec->set_qos (this->qos_);
 167 }
 168
 169 void
 170 TAO_Notify_Tests_EventChannel_Command::handle_status ()
 171 {
 172   //@@ TODO: Implement
 173 }
 174
 175 void
 176 TAO_Notify_Tests_EventChannel_Command::execute_i ()
 177 {
 178   if (this->command_ == CREATE)
 179     {
 180       this->handle_create ();
 181     }
 182   else if (this->command_ == DESTROY)
 183     {
 184       this->handle_destroy ();
 185     }
 186   else if (this->command_ == SET_QOS)
 187     {
 188       this->handle_set_qos ();
 189     }
 190   else if (this->command_ == DUMP_STATE)
 191     {
 192       this->handle_status ();
 193     }
 194 }