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

   1 #include "SupplierAdmin_Command.h"
   2
   3
   4 #include "LookupManager.h"
   5 #include "Name.h"
   6 #include "Options_Parser.h"
   7
   8 TAO_Notify_Tests_SupplierAdmin_Command::TAO_Notify_Tests_SupplierAdmin_Command ()
   9 : ifgop_ (CosNotifyChannelAdmin::OR_OP), id_ (0)
  10 {
  11 }
  12
  13 TAO_Notify_Tests_SupplierAdmin_Command::~TAO_Notify_Tests_SupplierAdmin_Command ()
  14 {
  15 }
  16
  17 const char*
  18 TAO_Notify_Tests_SupplierAdmin_Command::get_name ()
  19 {
  20   return TAO_Notify_Tests_SupplierAdmin_Command::name ();
  21 }
  22
  23 const char*
  24 TAO_Notify_Tests_SupplierAdmin_Command::name ()
  25 {
  26   return TAO_Notify_Tests_Name::supplier_admin_command;
  27 }
  28
  29 void
  30 TAO_Notify_Tests_SupplierAdmin_Command::init (ACE_Arg_Shifter& arg_shifter)
  31 {
  32   if (arg_shifter.is_anything_left ())
  33     {
  34       /// -Create sa_name factory_name
  35       if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("-Create")) == 0)
  36         {
  37           this->command_ = CREATE;
  38
  39           arg_shifter.consume_arg ();
  40
  41           this->name_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  42           arg_shifter.consume_arg ();
  43
  44           this->factory_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  45           arg_shifter.consume_arg ();
  46
  47           if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("-AND_OP")) == 0)
  48             {
  49               arg_shifter.consume_arg ();
  50
  51               this->ifgop_ = CosNotifyChannelAdmin::AND_OP;
  52             }
  53           else if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("-OR_OP")) == 0)
  54             {
  55               arg_shifter.consume_arg ();
  56
  57               this->ifgop_ = CosNotifyChannelAdmin::OR_OP;
  58             }
  59         }
  60       else if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("-Offer")) == 0)
  61         // -Subscription admin_name +added_type1 +-added_type2 ... -added_type3 -added_type4..
  62         {
  63           this->command_ = OFFER;
  64
  65           arg_shifter.consume_arg ();
  66
  67           this->name_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  68           arg_shifter.consume_arg ();
  69
  70           TAO_Notify_Tests_Options_Parser options_parser;
  71           options_parser.execute (this->added_, this->removed_, arg_shifter);
  72         } // Subscription
  73       else if (arg_shifter.cur_arg_strncasecmp (ACE_TEXT("-Set_QoS")) == 0) // -Set_QoS ec_name [Qos Options]
  74         {
  75           this->command_ = SET_QOS;
  76
  77           arg_shifter.consume_arg ();
  78
  79           this->name_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
  80
  81           arg_shifter.consume_arg ();
  82
  83           TAO_Notify_Tests_Options_Parser qos_parser;
  84           qos_parser.execute (this->qos_, arg_shifter);
  85         }
  86     } /* if */
  87 }
  88
  89 void
  90 TAO_Notify_Tests_SupplierAdmin_Command::handle_create ()
  91 {
  92   CosNotifyChannelAdmin::EventChannel_var ec;
  93
  94   LOOKUP_MANAGER->resolve (ec, this->factory_.c_str ());
  95
  96   // create supplier admin
  97   CosNotifyChannelAdmin::SupplierAdmin_var sa =
  98     ec->new_for_suppliers (this->ifgop_,
  99                            this->id_);
 100
 101   LOOKUP_MANAGER->_register (sa.in(), this->name_.c_str ());
 102 }
 103
 104 void
 105 TAO_Notify_Tests_SupplierAdmin_Command::handle_offers ()
 106 {
 107   CosNotifyChannelAdmin::SupplierAdmin_var admin;
 108
 109   LOOKUP_MANAGER->resolve (admin, this->name_.c_str ());
 110
 111       // Let the user see what we're subscribed for,
 112   ACE_DEBUG ((LM_DEBUG, "Calling SupplierAdmin offer_change : "));
 113
 114   CORBA::ULong i = 0;
 115
 116   for (; i < added_.length (); ++i)
 117     {
 118       ACE_DEBUG ((LM_DEBUG, "+(%s,%s), ", added_[i].domain_name.in (), added_[i].type_name.in ()));
 119     }
 120   for (i = 0; i < removed_.length (); ++i)
 121     {
 122       ACE_DEBUG ((LM_DEBUG, "-(%s,%s), ", removed_[i].domain_name.in (), removed_[i].type_name.in ()));
 123     }
 124
 125   ACE_DEBUG ((LM_DEBUG, "\n"));
 126
 127   admin->offer_change (this->added_, this->removed_);
 128 }
 129
 130 void
 131 TAO_Notify_Tests_SupplierAdmin_Command::handle_status ()
 132 {
 133 }
 134
 135 void
 136 TAO_Notify_Tests_SupplierAdmin_Command::handle_set_qos ()
 137 {
 138   CosNotifyChannelAdmin::SupplierAdmin_var admin;
 139
 140   LOOKUP_MANAGER->resolve (admin, this->name_.c_str ());
 141
 142   admin->set_qos (this->qos_);
 143 }
 144
 145 void
 146 TAO_Notify_Tests_SupplierAdmin_Command::execute_i ()
 147 {
 148   if (this->command_ == CREATE)
 149     {
 150       this->handle_create ();
 151     }
 152   else if (this->command_ == OFFER)
 153     {
 154       this->handle_offers ();
 155     }
 156   else if (this->command_ == SET_QOS)
 157     {
 158       this->handle_set_qos ();
 159     }
 160   else if (this->command_ == DUMP_STATE)
 161     {
 162       this->handle_status ();
 163     }
 164 }