diff options
Diffstat (limited to 'trunk/TAO/orbsvcs/tests/Sched_Conf/Sched_Conf_Runtime.cpp')
| -rw-r--r-- | trunk/TAO/orbsvcs/tests/Sched_Conf/Sched_Conf_Runtime.cpp | 175 |
1 files changed, 175 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/tests/Sched_Conf/Sched_Conf_Runtime.cpp b/trunk/TAO/orbsvcs/tests/Sched_Conf/Sched_Conf_Runtime.cpp new file mode 100644 index 00000000000..12692c53c26 --- /dev/null +++ b/trunk/TAO/orbsvcs/tests/Sched_Conf/Sched_Conf_Runtime.cpp @@ -0,0 +1,175 @@ +// $Id$ + +// This program exercises a run-time scheduler, +// using the config run generated C++ header file. + +#include "ace/Sched_Params.h" +#include "ace/Get_Opt.h" +#include "ace/OS_NS_string.h" +#include "tao/corba.h" + +#include "orbsvcs/CosNamingC.h" +#include "orbsvcs/Scheduler_Factory.h" +#include "orbsvcs/Naming/Naming_Server.h" + +#include "Sched_Conf_Runtime.h" + +ACE_RCSID(Sched_Conf, Sched_Conf_Runtime, "$Id$") + + + +int +main (int argc, char *argv[]) +{ + ACE_TRY_NEW_ENV + { + // Initialize ORB. + CORBA::ORB_var orb = + CORBA::ORB_init (argc, argv, "internet" ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + CORBA::Object_var poa_object = + orb->resolve_initial_references("RootPOA" ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (CORBA::is_nil(poa_object.in ())) + ACE_ERROR_RETURN ((LM_ERROR, + " (%P|%t) Unable to initialize the POA.\n"), + 1); + + PortableServer::POA_var root_poa = + PortableServer::POA::_narrow (poa_object.in() ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + PortableServer::POAManager_var poa_manager = + root_poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Store a pointer to the local run-time scheduler. + RtecScheduler::Scheduler_ptr runtime_scheduler = + ACE_Scheduler_Factory::server (); + + // Some useful variables for retrieving values from the scheduler. + RtecScheduler::RT_Info *rt_info = 0; + RtecScheduler::OS_Priority priority; + RtecScheduler::Preemption_Subpriority_t subpriority; + RtecScheduler::Preemption_Priority_t p_priority; + RtecScheduler::Dispatching_Type_t dispatching_type; + + for (int i = 0; i < infos_size; ++i) + { + // Make sure the correct handle is returned by the + // run-time scheduler's create and lookup methods. + ACE_ASSERT (infos [i].handle == + runtime_scheduler->create (infos [i].entry_point + ACE_ENV_ARG_PARAMETER)); + ACE_TRY_CHECK; + + ACE_ASSERT (infos [i].handle == + runtime_scheduler->lookup (infos [i].entry_point + ACE_ENV_ARG_PARAMETER)); + ACE_TRY_CHECK; + + // Make sure the values in the RT_Info returned by get are OK. + delete rt_info; + rt_info = runtime_scheduler->get (infos [i].handle + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + ACE_ASSERT (rt_info != 0); + ACE_ASSERT (ACE_OS::strcmp (rt_info->entry_point, + infos [i].entry_point) == 0); + ACE_ASSERT (rt_info->handle == + infos [i].handle); + ACE_ASSERT (rt_info->worst_case_execution_time == + infos [i].worst_case_execution_time); + ACE_ASSERT (rt_info->typical_execution_time == + infos [i].typical_execution_time); + ACE_ASSERT (rt_info->cached_execution_time == + infos [i].cached_execution_time); + ACE_ASSERT (rt_info->period == + infos [i].period); + ACE_ASSERT (rt_info->criticality == + static_cast<RtecScheduler::Criticality_t> (infos [i].criticality)); + ACE_ASSERT (rt_info->importance == + static_cast<RtecScheduler::Importance_t> (infos [i].importance)); + ACE_ASSERT (rt_info->quantum == + infos [i].quantum); + ACE_ASSERT (rt_info->threads == + infos [i].threads); + ACE_ASSERT (rt_info->priority == + infos [i].priority); + ACE_ASSERT (rt_info->preemption_subpriority == + infos [i].static_subpriority); + ACE_ASSERT (rt_info->preemption_priority == + infos [i].preemption_priority); + ACE_ASSERT (rt_info->info_type == + static_cast<RtecScheduler::Info_Type_t> (infos [i].info_type)); + + // Make sure the values in the scheduler's internal RT_Info are OK. + // Scheduler will generate messages if any values don't match. + runtime_scheduler->set (infos [i].handle, + static_cast<RtecScheduler::Criticality_t> (infos [i].criticality), + infos [i].worst_case_execution_time, + infos [i].typical_execution_time, + infos [i].cached_execution_time, + infos [i].period, + static_cast<RtecScheduler::Importance_t> (infos [i].importance), + infos [i].quantum, + infos [i].threads, + static_cast<RtecScheduler::Info_Type_t> (infos [i].info_type) + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Make sure the correct priority values are returned. + runtime_scheduler->priority (infos [i].handle, + priority, + subpriority, + p_priority + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + ACE_ASSERT (priority == infos [i].priority); + ACE_ASSERT (subpriority == infos [i].static_subpriority); + ACE_ASSERT (p_priority == infos [i].preemption_priority); + runtime_scheduler->entry_point_priority (infos [i].entry_point, + priority, + subpriority, + p_priority + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + ACE_ASSERT (priority == infos [i].priority); + ACE_ASSERT (subpriority == infos [i].static_subpriority); + ACE_ASSERT (p_priority == infos [i].preemption_priority); + } + + for (int j = 0; j < configs_size; ++j) + { + // Make sure the correct preemption priority is stored. + ACE_ASSERT (j == configs [j].preemption_priority); + + // Make sure the correct queue configuration values are returned. + runtime_scheduler-> + dispatch_configuration (configs [j].preemption_priority, + priority, + dispatching_type + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + ACE_ASSERT (priority == configs [j].thread_priority); + ACE_ASSERT (dispatching_type == configs [j].dispatching_type); + + } + } + ACE_CATCHANY + { + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "SYS_EX"); + } + ACE_ENDTRY; + + return 0; +} |