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

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