diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/lib/Options_Parser.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/Notify/lib/Options_Parser.cpp | 149 |
1 files changed, 0 insertions, 149 deletions
diff --git a/TAO/orbsvcs/tests/Notify/lib/Options_Parser.cpp b/TAO/orbsvcs/tests/Notify/lib/Options_Parser.cpp deleted file mode 100644 index fbcb5f8c03b..00000000000 --- a/TAO/orbsvcs/tests/Notify/lib/Options_Parser.cpp +++ /dev/null @@ -1,149 +0,0 @@ -// $Id$ - -#include "Options_Parser.h" - -ACE_RCSID (lib, - TAO_Options_Parser, - "$Id$") - -#include "orbsvcs/NotifyExtC.h" -#include "tao/debug.h" -#include "ace/Log_Msg.h" - -TAO_Notify_Tests_Options_Parser::TAO_Notify_Tests_Options_Parser (void) -{ -} - -TAO_Notify_Tests_Options_Parser::~TAO_Notify_Tests_Options_Parser () -{ -} - -void -TAO_Notify_Tests_Options_Parser::execute (CosNotification::EventTypeSeq& added, CosNotification::EventTypeSeq& removed, ACE_Arg_Shifter& arg_shifter) -{ - const ACE_TCHAR* current_arg = 0; - - while (arg_shifter.is_anything_left ()) - { - current_arg = arg_shifter.get_current (); - arg_shifter.consume_arg (); - - if (current_arg[0] == '+') - { - // create 1 more space. - int seq_ln = added.length (); - added.length (seq_ln + 1); - - added[seq_ln].domain_name = CORBA::string_dup ("*"); - added[seq_ln].type_name = CORBA::string_dup (++current_arg); // Skip the '+' sign. - } - else if (current_arg[0] == '-') - { - // create 1 more space. - int seq_ln = removed.length (); - removed.length (seq_ln + 1); - - removed[seq_ln].domain_name = CORBA::string_dup ("*"); - removed[seq_ln].type_name = CORBA::string_dup (++current_arg); // Skip the '-' sign. - } - } -} - -void -TAO_Notify_Tests_Options_Parser::execute (CosNotification::QoSProperties& qos, ACE_Arg_Shifter& arg_shifter) -{ - const ACE_TCHAR *current_arg = 0; - int default_priority = ACE_DEFAULT_THREAD_PRIORITY; - - if (arg_shifter.cur_arg_strncasecmp ("-ThreadPool") == 0) // -ThreadPool [-Threads static_threads] [-Priority default_priority] - { - arg_shifter.consume_arg (); - - int static_threads = 1; - - if (arg_shifter.cur_arg_strncasecmp ("-Threads") == 0) - { - arg_shifter.consume_arg (); - - current_arg = arg_shifter.get_current (); - - static_threads = ACE_OS::atoi (current_arg); - - arg_shifter.consume_arg (); - } - - if (arg_shifter.cur_arg_strncasecmp ("-Priority") == 0) - { - arg_shifter.consume_arg (); - - current_arg = arg_shifter.get_current (); - - default_priority = ACE_OS::atoi (current_arg); - - arg_shifter.consume_arg (); - } - - NotifyExt::ThreadPoolParams tp_params - = { NotifyExt::CLIENT_PROPAGATED, default_priority, - 0, static_threads, 0, default_priority, 0, 0, 0 }; - - qos.length (1); - qos[0].name = CORBA::string_dup (NotifyExt::ThreadPool); - qos[0].value <<= tp_params; - - } /* ThreadPool */ - else if (arg_shifter.cur_arg_strncasecmp ("-Lanes") == 0) // -Lanes lane_count -Lane prio static_thr dy_thr - { - arg_shifter.consume_arg (); - - current_arg = arg_shifter.get_current (); - int lanecount = ACE_OS::atoi (current_arg); - - arg_shifter.consume_arg (); - - NotifyExt::ThreadPoolLanesParams tpl_params; - - tpl_params.priority_model = NotifyExt::CLIENT_PROPAGATED; - tpl_params.server_priority = default_priority; - tpl_params.stacksize = 0; - tpl_params.lanes.length (lanecount); - tpl_params.allow_borrowing = 0; - tpl_params.allow_request_buffering = 0; - tpl_params.max_buffered_requests = 0; - tpl_params.max_request_buffer_size = 0; - - int l_index = 0; - //parse lane values ... - while (arg_shifter.is_anything_left ()) - { - if (arg_shifter.cur_arg_strncasecmp ("-Lane") == 0) - { - arg_shifter.consume_arg (); - - // read priority - tpl_params.lanes[l_index].lane_priority = ACE_OS::atoi (arg_shifter.get_current ()); - arg_shifter.consume_arg (); - - // static thread count - tpl_params.lanes[l_index].static_threads = ACE_OS::atoi (arg_shifter.get_current ()); - arg_shifter.consume_arg (); - - // dynamic thread count - tpl_params.lanes[l_index].dynamic_threads = ACE_OS::atoi (arg_shifter.get_current ()); - arg_shifter.consume_arg (); - - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, "QoS Parser parsed lane: - %d, %d, %d\n", - tpl_params.lanes[l_index].lane_priority, tpl_params.lanes[l_index].static_threads, tpl_params.lanes[l_index].dynamic_threads)); - l_index++; - } - else - break; - } /* while -- lane values */ - - qos.length (1); - qos[0].name = CORBA::string_dup (NotifyExt::ThreadPoolLanes); - qos[0].value <<= tpl_params; - - } /* ThreadPoolLane */ -} |