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.cpp370
1 files changed, 370 insertions, 0 deletions
diff --git a/TAO/tests/RTCORBA/common_args.cpp b/TAO/tests/RTCORBA/common_args.cpp
new file mode 100644
index 00000000000..4c72811ab86
--- /dev/null
+++ b/TAO/tests/RTCORBA/common_args.cpp
@@ -0,0 +1,370 @@
+// $Id$
+
+#include "ace/Read_Buffer.h"
+#include "ace/Array_Base.h"
+#include "ace/OS_NS_stdio.h"
+#include "ace/OS_NS_math.h"
+#include "ace/OS_NS_stdlib.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)
+{
+ //
+ // 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);
+
+ 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)
+ {
+ // sscanf with "%ul" doesn't seem to work properly on HP-UX. So,
+ // we will use strtoul instead.
+ char* endptr = 0;
+ values[i] = ACE_OS::strtoul (working_string, &endptr, 10);
+
+ if (endptr != working_string && endptr != 0 && *endptr != '\0')
+ {
+ result = 0;
+ 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)
+{
+ 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);
+
+ CORBA::Policy_var threadpool_policy =
+ rt_orb->create_threadpool_policy (threadpool_id);
+
+ 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)
+{
+ 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);
+
+ 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)
+{
+ 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);
+
+ policies.length (policies.length () + 1);
+ policies[policies.length () - 1] =
+ rt_orb->create_priority_banded_connection_policy (bands);
+
+ policies.length (policies.length () + 1);
+ policies[policies.length () - 1] =
+ rt_orb->create_threadpool_policy (threadpool_id);
+}
+
View Lorry Controller Status