summaryrefslogtreecommitdiff
path: root/TAO/tests/RTCORBA/common_args.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tests/RTCORBA/common_args.cpp')
-rw-r--r--TAO/tests/RTCORBA/common_args.cpp382
1 files changed, 0 insertions, 382 deletions
diff --git a/TAO/tests/RTCORBA/common_args.cpp b/TAO/tests/RTCORBA/common_args.cpp
deleted file mode 100644
index b80ca5720d0..00000000000
--- a/TAO/tests/RTCORBA/common_args.cpp
+++ /dev/null
@@ -1,382 +0,0 @@
-// $Id$
-
-#include "ace/Read_Buffer.h"
-#include "ace/Array_Base.h"
-#include "ace/OS_NS_stdio.h"
-#include "ace/OS_NS_math.h"
-
-typedef ACE_Array_Base<CORBA::ULong> ULong_Array;
-
-int
-get_priority_bands (const char *test_type,
- const char *bands_file,
- RTCORBA::RTORB_ptr rt_orb,
- CORBA::PolicyList &policies,
- int debug
- ACE_ENV_ARG_DECL)
-{
- //
- // Read bands from a file.
- //
- FILE* file =
- ACE_OS::fopen (bands_file, "r");
-
- if (file == 0)
- ACE_ERROR_RETURN ((LM_ERROR,
- "Cannot open file %s\n",
- bands_file),
- -1);
-
- ACE_Read_Buffer reader (file, 1);
-
- char *string =
- reader.read (EOF, ' ', '\0');
-
- // Check for empty bands file.
- if (string == 0)
- {
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "\n%s: No bands set!\n\n",
- test_type));
- return 0;
- }
-
- CORBA::ULong bands_length =
- (reader.replaced () + 1) / 2;
-
- RTCORBA::PriorityBands bands;
- bands.length (bands_length);
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "\n%s: There are %d bands: ",
- test_type,
- bands_length));
-
- int result = 1;
- char* working_string = string;
- for (CORBA::ULong i = 0; i < bands_length; ++i)
- {
- result = ::sscanf (working_string,
- "%hd",
- &bands[i].low);
- if (result == 0 || result == EOF)
- break;
-
- working_string += ACE_OS::strlen (working_string);
- working_string += 1;
-
- result = ::sscanf (working_string,
- "%hd",
- &bands[i].high);
- if (result == 0 || result == EOF)
- break;
-
- working_string += ACE_OS::strlen (working_string);
- working_string += 1;
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "[%d %d] ",
- bands[i].low,
- bands[i].high));
- }
-
- reader.alloc ()->free (string);
-
- if (result == 0 || result == EOF)
- ACE_ERROR_RETURN ((LM_ERROR,
- "Parsing error in file %s\n",
- bands_file),
- -1);
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "\n\n"));
-
- CORBA::Policy_var banded_connection_policy =
- rt_orb->create_priority_banded_connection_policy (bands
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- policies.length (policies.length () + 1);
- policies[policies.length () - 1] =
- banded_connection_policy;
-
- return 0;
-}
-
-int
-get_values (const char *test_type,
- const char *file_name,
- const char *name,
- ULong_Array &values,
- int debug)
-{
- //
- // Read lanes from a file.
- //
- FILE* file =
- ACE_OS::fopen (file_name, "r");
-
- if (file == 0)
- ACE_ERROR_RETURN ((LM_ERROR,
- "Cannot open file %s\n",
- file_name),
- -1);
-
- ACE_Read_Buffer reader (file, 1);
-
- char *string =
- reader.read (EOF, ' ', '\0');
-
- // Check for empty lanes file.
- if (string == 0)
- {
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "\n%s: No %s set!\n\n",
- test_type,
- name));
- return 0;
- }
-
- size_t length =
- reader.replaced () + 1;
-
- values.size (length);
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "\n%s: There are %d %s: ",
- test_type,
- length,
- name));
-
- int result = 1;
- char* working_string = string;
- for (CORBA::ULong i = 0; i < length; ++i)
- {
- result = ::sscanf (working_string,
- "%ul",
- &values[i]);
- if (result == 0 || result == EOF)
- break;
-
- working_string += ACE_OS::strlen (working_string);
- working_string += 1;
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "[%u] ",
- values[i]));
- }
-
- reader.alloc ()->free (string);
-
- if (result == 0 || result == EOF)
- ACE_ERROR_RETURN ((LM_ERROR,
- "Parsing error in file %s\n",
- file_name),
- -1);
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "\n\n"));
-
- return 0;
-}
-
-int
-get_priority_lanes (const char *test_type,
- const char *lanes_file,
- RTCORBA::RTORB_ptr rt_orb,
- CORBA::ULong stacksize,
- CORBA::ULong static_threads,
- CORBA::ULong dynamic_threads,
- CORBA::Boolean allow_request_buffering,
- CORBA::ULong max_buffered_requests,
- CORBA::ULong max_request_buffer_size,
- CORBA::Boolean allow_borrowing,
- CORBA::PolicyList &policies,
- int debug
- ACE_ENV_ARG_DECL)
-{
- ULong_Array priorities;
- int result =
- get_values (test_type,
- lanes_file,
- "lanes",
- priorities,
- debug);
- if (result != 0 ||
- priorities.size () == 0)
- return result;
-
- RTCORBA::ThreadpoolLanes lanes;
- lanes.length (priorities.size ());
-
- for (CORBA::ULong i = 0;
- i < priorities.size ();
- ++i)
- {
- lanes[i].lane_priority = priorities[i];
- lanes[i].static_threads = static_threads;
- lanes[i].dynamic_threads = dynamic_threads;
- }
-
- RTCORBA::ThreadpoolId threadpool_id =
- rt_orb->create_threadpool_with_lanes (stacksize,
- lanes,
- allow_borrowing,
- allow_request_buffering,
- max_buffered_requests,
- max_request_buffer_size
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- CORBA::Policy_var threadpool_policy =
- rt_orb->create_threadpool_policy (threadpool_id
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- policies.length (policies.length () + 1);
- policies[policies.length () - 1] =
- threadpool_policy;
-
- return 0;
-}
-
-int
-get_protocols (const char *test_type,
- const char *lanes_file,
- RTCORBA::RTORB_ptr rt_orb,
- CORBA::PolicyList &policies,
- int debug
- ACE_ENV_ARG_DECL)
-{
- ULong_Array protocol_values;
- int result =
- get_values (test_type,
- lanes_file,
- "protocols",
- protocol_values,
- debug);
- if (result != 0 ||
- protocol_values.size () == 0)
- return result;
-
- RTCORBA::ProtocolList protocols;
- protocols.length (protocol_values.size ());
-
- for (CORBA::ULong i = 0;
- i < protocol_values.size ();
- ++i)
- {
- protocols[i].protocol_type =
- protocol_values[i];
- protocols[i].transport_protocol_properties =
- RTCORBA::ProtocolProperties::_nil ();
- protocols[i].orb_protocol_properties =
- RTCORBA::ProtocolProperties::_nil ();
- }
-
- CORBA::Policy_var protocol_policy =
- rt_orb->create_client_protocol_policy (protocols
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- policies.length (policies.length () + 1);
- policies[policies.length () - 1] =
- protocol_policy;
-
- return 0;
-}
-
-void
-get_auto_priority_lanes_and_bands (CORBA::ULong number_of_lanes,
- RTCORBA::RTORB_ptr rt_orb,
- CORBA::ULong stacksize,
- CORBA::ULong static_threads,
- CORBA::ULong dynamic_threads,
- CORBA::Boolean allow_request_buffering,
- CORBA::ULong max_buffered_requests,
- CORBA::ULong max_request_buffer_size,
- CORBA::Boolean allow_borrowing,
- CORBA::PolicyList &policies,
- int debug
- ACE_ENV_ARG_DECL)
-{
- RTCORBA::ThreadpoolLanes lanes;
- lanes.length (number_of_lanes);
-
- RTCORBA::PriorityBands bands;
- bands.length (number_of_lanes);
-
- CORBA::Short priority_range =
- RTCORBA::maxPriority - RTCORBA::minPriority;
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "\nUsing %d lanes\n",
- number_of_lanes));
-
- for (CORBA::ULong i = 0;
- i < number_of_lanes;
- ++i)
- {
- CORBA::Short high_priority =
- CORBA::Short (
- ACE_OS::floor ((priority_range /
- double (number_of_lanes)) *
- (i + 1)));
-
- CORBA::Short low_priority =
- CORBA::Short (
- ACE_OS::ceil ((priority_range /
- double (number_of_lanes)) *
- i));
-
- lanes[i].lane_priority = high_priority;
- lanes[i].static_threads = static_threads;
- lanes[i].dynamic_threads = dynamic_threads;
-
- bands[i].high = high_priority;
- bands[i].low = low_priority;
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "%d: [%d %d] ",
- i + 1,
- low_priority,
- high_priority));
- }
-
- if (debug)
- ACE_DEBUG ((LM_DEBUG,
- "\n\n"));
-
- RTCORBA::ThreadpoolId threadpool_id =
- rt_orb->create_threadpool_with_lanes (stacksize,
- lanes,
- allow_borrowing,
- allow_request_buffering,
- max_buffered_requests,
- max_request_buffer_size
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- policies.length (policies.length () + 1);
- policies[policies.length () - 1] =
- rt_orb->create_priority_banded_connection_policy (bands
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- policies.length (policies.length () + 1);
- policies[policies.length () - 1] =
- rt_orb->create_threadpool_policy (threadpool_id
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-}
-
View Lorry Controller Status