// $Id$ // This program performa a simple scheduler configuration run, // and dumps the results of one scheduling into a C++ header file. #include "ace/Sched_Params.h" #include "ace/Get_Opt.h" #include "orbsvcs/CosNamingC.h" #include "orbsvcs/Scheduler_Factory.h" #include "orbsvcs/Naming/Naming_Client.h" #include "orbsvcs/Naming/Naming_Server.h" ACE_RCSID (Sched_Conf, Sched_Conf, "$Id$") const char* service_name = "ScheduleService"; const char* format_string = " {%-12s, %d, %d, %d, %d, %8d, " " static_cast (%d), " " static_cast (%d), " " %d, %d, %3d, %d, %d, " "static_cast (%d)}\n"; int parse_args (int argc, char *argv []) { ACE_Get_Opt get_opt (argc, argv, "n:"); int opt; while ((opt = get_opt ()) != EOF) { switch (opt) { case 'n': service_name = get_opt.opt_arg (); break; case '?': default: ACE_DEBUG ((LM_DEBUG, "Usage: %s " "-n service_name " "\n", argv[0])); return -1; } } return 0; } int main (int argc, char *argv[]) { if (parse_args (argc, argv) != 0) { return 1; } // create initial data for supplier and consumer operations const int operation_count = 16; ACE_Scheduler_Factory::POD_RT_Info config_infos[operation_count] = { // 20 Hz high criticality supplier { "high_20_S", // entry point 0, // handle 5000, // worst case execution time 5000, // typical execution time (unused) 5000, // cached execution time 500000, // period (100 ns) RtecScheduler::HIGH_CRITICALITY, // criticality RtecScheduler::LOW_IMPORTANCE, // importance 0, // quantum (unused) 1, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 20 Hz low criticality supplier { "low_20_S", // entry point 0, // handle 5000, // worst case execution time 5000, // typical execution time (unused) 5000, // cached execution time 500000, // period (100 ns) RtecScheduler::LOW_CRITICALITY, // criticality RtecScheduler::HIGH_IMPORTANCE, // importance 0, // quantum (unused) 1, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 10 Hz high criticality supplier { "high_10_S", // entry point 0, // handle 10000, // worst case execution time 10000, // typical execution time (unused) 10000, // cached execution time 1000000, // period (100 ns) RtecScheduler::HIGH_CRITICALITY, // criticality RtecScheduler::LOW_IMPORTANCE, // importance 0, // quantum (unused) 1, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 10 Hz low criticality supplier { "low_10_S", // entry point 0, // handle 10000, // worst case execution time 10000, // typical execution time (unused) 10000, // cached execution time 1000000, // period (100 ns) RtecScheduler::LOW_CRITICALITY, // criticality RtecScheduler::HIGH_IMPORTANCE, // importance 0, // quantum (unused) 1, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 5 Hz high criticality supplier { "high_05_S", // entry point 0, // handle 20000, // worst case execution time 20000, // typical execution time (unused) 20000, // cached execution time 2000000, // period (100 ns) RtecScheduler::HIGH_CRITICALITY, // criticality RtecScheduler::LOW_IMPORTANCE, // importance 0, // quantum (unused) 1, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 5 Hz low criticality supplier { "low_05_S", // entry point 0, // handle 20000, // worst case execution time 20000, // typical execution time (unused) 20000, // cached execution time 2000000, // period (100 ns) RtecScheduler::LOW_CRITICALITY, // criticality RtecScheduler::HIGH_IMPORTANCE, // importance 0, // quantum (unused) 1, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler:: RT_INFO_ENABLED }, // 1 Hz high criticality supplier (declares a rate but no threads) { "high_01_S", // entry point 0, // handle 100000, // worst case execution time 100000, // typical execution time (unused) 100000, // cached execution time 10000000, // period (100 ns) RtecScheduler::HIGH_CRITICALITY, // criticality RtecScheduler::LOW_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 1 Hz low criticality supplier (remote dependant: scheduler should warn) { "low_01_S", // entry point 0, // handle 100000, // worst case execution time 100000, // typical execution time (unused) 100000, // cached execution time 10000000, // period (100 ns) RtecScheduler::LOW_CRITICALITY, // criticality RtecScheduler::HIGH_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 20 Hz high criticality consumer { "high_20_C", // entry point 0, // handle 0, // worst case execution time 0, // typical execution time (unused) 0, // cached execution time 0, // period (zero) RtecScheduler::HIGH_CRITICALITY, // criticality RtecScheduler::LOW_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 20 Hz low criticality consumer { "low_20_C", // entry point 0, // handle 0, // worst case execution time 0, // typical execution time (unused) 0, // cached execution time 0, // period (zero) RtecScheduler::LOW_CRITICALITY, // criticality RtecScheduler::HIGH_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 10 Hz high criticality consumer { "high_10_C", // entry point 0, // handle 0, // worst case execution time 0, // typical execution time (unused) 0, // cached execution time 0, // period (zero) RtecScheduler::HIGH_CRITICALITY, // criticality RtecScheduler::LOW_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 10 Hz low criticality consumer { "low_10_C", // entry point 0, // handle 0, // worst case execution time 0, // typical execution time (unused) 0, // cached execution time 0, // period (zero) RtecScheduler::LOW_CRITICALITY, // criticality RtecScheduler::HIGH_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 5 Hz high criticality consumer { "high_05_C", // entry point 0, // handle 0, // worst case execution time 0, // typical execution time (unused) 0, // cached execution time 0, // period (zero) RtecScheduler::HIGH_CRITICALITY, // criticality RtecScheduler::LOW_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 5 Hz low criticality consumer { "low_05_C", // entry point 0, // handle 0, // worst case execution time 0, // typical execution time (unused) 0, // cached execution time 0, // period (zero) RtecScheduler::LOW_CRITICALITY, // criticality RtecScheduler::HIGH_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 1 Hz high criticality consumer { "high_01_C", // entry point 0, // handle 0, // worst case execution time 0, // typical execution time (unused) 0, // cached execution time 0, // period (zero) RtecScheduler::HIGH_CRITICALITY, // criticality RtecScheduler::LOW_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED }, // 1 Hz low criticality consumer { "low_01_C", // entry point 0, // handle 0, // worst case execution time 0, // typical execution time (unused) 0, // cached execution time 0, // period (zero) RtecScheduler::LOW_CRITICALITY, // criticality RtecScheduler::HIGH_IMPORTANCE, // importance 0, // quantum (unused) 0, // threads 0, // OS priority 0, // Preemption subpriority 0, // Preemption priority RtecScheduler::OPERATION, // info type RtecScheduler::RT_INFO_ENABLED } }; 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; // Initialize the naming services TAO_Naming_Client my_name_client; if (my_name_client.init (orb.in ()) != 0) ACE_ERROR_RETURN ((LM_ERROR, " (%P|%t) Unable to initialize " "the TAO_Naming_Client. \n"), -1); CosNaming::NamingContext_var context = my_name_client.get_context (); if (ACE_Scheduler_Factory::use_config (context.in (), service_name) < 0) ACE_ERROR_RETURN ((LM_ERROR, " (%P|%t) Unable to bind to the scheduling service.\n"), 1); // Create and initialize RT_Infos in the scheduler, make second // half of array depend on first half. for (int i = 0; i < operation_count; ++i) { // create the RT_Info config_infos[i].handle = ACE_Scheduler_Factory::server ()->create (config_infos[i].entry_point ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // initialize the RT_Info ACE_Scheduler_Factory::server ()-> set (config_infos[i].handle, static_cast (config_infos[i].criticality), config_infos[i].worst_case_execution_time, config_infos[i].typical_execution_time, config_infos[i].cached_execution_time, config_infos[i].period, static_cast (config_infos[i].importance), config_infos[i].quantum, config_infos[i].threads, static_cast (config_infos[i].info_type) ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // make operations in second half dependant on // operations in the first half of the array, // and have each called twice as a oneway call if (i >= (operation_count / 2)) { ACE_Scheduler_Factory::server ()-> add_dependency (config_infos[i].handle, config_infos[i - (operation_count / 2)].handle, 2, // number of calls RtecBase::ONE_WAY_CALL // type of dependency ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; } } RtecScheduler::RT_Info_Set_var infos; RtecScheduler::Dependency_Set_var deps; RtecScheduler::Config_Info_Set_var configs; RtecScheduler::Scheduling_Anomaly_Set_var anomalies; ACE_Scheduler_Factory::server ()->compute_scheduling (ACE_Sched_Params::priority_min (ACE_SCHED_FIFO, ACE_SCOPE_THREAD), ACE_Sched_Params::priority_max (ACE_SCHED_FIFO, ACE_SCOPE_THREAD), infos.out (), deps.out (), configs.out (), anomalies.out () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; ACE_Scheduler_Factory::dump_schedule (infos.in (), deps.in (), configs.in (), anomalies.in (), "Sched_Conf_Runtime.h", format_string); } ACE_CATCHANY { ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "SYS_EX"); } ACE_ENDTRY; return 0; }