diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Sched/Reconfig_Scheduler_T.h')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Sched/Reconfig_Scheduler_T.h | 483 |
1 files changed, 0 insertions, 483 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Sched/Reconfig_Scheduler_T.h b/TAO/orbsvcs/orbsvcs/Sched/Reconfig_Scheduler_T.h deleted file mode 100644 index caf527cf57f..00000000000 --- a/TAO/orbsvcs/orbsvcs/Sched/Reconfig_Scheduler_T.h +++ /dev/null @@ -1,483 +0,0 @@ -/* -*- C++ -*- */ -// $Id$ -// ============================================================================ -// -// = LIBRARY -// orbsvcs -// -// = FILENAME -// Reconfig_Scheduler_T.h -// -// = AUTHOR -// Chris Gill <cdgill@cs.wustl.edu> -// -// ============================================================================ - -#ifndef TAO_RECONFIG_SCHEDULER_T_H -#define TAO_RECONFIG_SCHEDULER_T_H - -#include "ace/inc_user_config.h" - -// The templatized method parameters needed by this file are -// hopelessly broken on pre-2.8 versions of g++ -#if (! defined (__GNUC__)) || (__GNUC__ > 2) || \ -(__GNUC__ == 2 && defined (__GNUC_MINOR__) && __GNUC_MINOR__ >= 8) - -#include "Reconfig_Scheduler.h" - -#if !defined (ACE_LACKS_PRAGMA_ONCE) -# pragma once -#endif /* ACE_LACKS_PRAGMA_ONCE */ - -template <class RECONFIG_SCHED_STRATEGY, class ACE_LOCK> -class TAO_Reconfig_Scheduler : - public POA_RtecScheduler::Scheduler - // = TITLE - // A servant for RtecScheduler::Scheduler that can be initialized - // and run solely with precomputed scheduling information, but is also - // designed to perform efficient recomputation of scheduling info - // in the face of run-time changes to RT_Infos in the schedule. - // - // = DESCRIPTION - // This class implements the TAO scheduling service. It has - // the ability to accept and use precomputed scheduling information - // with deterministic performance once the schedule is fully configured. - // It also provides efficient and flexible lookup and computation - // during schedule configuration, so that it can be used during - // both schedule configuration and run-time phases of operation. - // -{ -public: - - typedef ACE_Hash_Map_Manager_Ex<RtecScheduler::handle_t, - RtecScheduler::RT_Info*, - ACE_Hash<RtecScheduler::handle_t>, - ACE_Equal_To<RtecScheduler::handle_t>, - ACE_LOCK> RT_INFO_MAP; - // Type of map used for O(1) lookup of RT_Infos by their handles. - - typedef ACE_RB_Tree<const char *, - RtecScheduler::RT_Info*, - ACE_Less_Than<const char *>, - ACE_LOCK> RT_INFO_TREE; - // Type of tree used for O(log n) lookup of RT_Infos by their names. - - typedef ACE_Hash_Map_Manager_Ex<RtecScheduler::Preemption_Priority_t, - RtecScheduler::Config_Info*, - ACE_Hash<RtecScheduler::Preemption_Priority_t>, - ACE_Equal_To<RtecScheduler::Preemption_Priority_t>, - ACE_LOCK> CONFIG_INFO_MAP; - // Type of map used for O(1) lookup of Config_Infos by their priorities. - - typedef ACE_Hash_Map_Manager_Ex<RtecScheduler::handle_t, - RtecScheduler::Dependency_Set*, - ACE_Hash<RtecScheduler::handle_t>, - ACE_Equal_To<RtecScheduler::handle_t>, - ACE_LOCK> DEPENDENCY_SET_MAP; - // Type of map used for O(1) lookup of RT_Info - // dependency sets by caller or called handle. - - TAO_Reconfig_Scheduler (int enforce_schedule_stability = 0); - // Default constructor. - - TAO_Reconfig_Scheduler (int config_count, - ACE_Scheduler_Factory::POD_Config_Info config_info[], - int entry_count, - ACE_Scheduler_Factory::POD_RT_Info rt_info[], - int dependency_count, - ACE_Scheduler_Factory::POD_Dependency_Info dependency_info[], - u_long stability_flags, - int enforce_schedule_stability = 0); - // Constructor. Initialize the scheduler from POD_Config_Info, POD_RT_Info, - // and POD_Dependency arrays, plus schedule stability flags. - - int init (int config_count, - ACE_Scheduler_Factory::POD_Config_Info config_info[], - int rt_info_count, - ACE_Scheduler_Factory::POD_RT_Info rt_info[], - int dependency_count, - ACE_Scheduler_Factory::POD_Dependency_Info dependency_info[], - u_long stability_flags, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::DUPLICATE_NAME, - RtecScheduler::UNKNOWN_TASK, - RtecScheduler::SYNCHRONIZATION_FAILURE, - RtecScheduler::INTERNAL)); - // Initializes the scheduler with the passed information. - - void close (CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK, - RtecScheduler::SYNCHRONIZATION_FAILURE)); - // Closes the scheduler, releasing all current resources. - - virtual RtecScheduler::handle_t create (const char * entry_point, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::DUPLICATE_NAME, - RtecScheduler::INTERNAL, - RtecScheduler::SYNCHRONIZATION_FAILURE)); - // Create an RT_Info. If it does not exist, a new RT_Info is - // created and inserted into the schedule, and the handle of the new - // RT_Info is returned. If the RT_Info already exists, an exception - // is thrown. - - virtual RtecScheduler::handle_t lookup (const char * entry_point, - CORBA::Environment &_env) - ACE_THROW_SPEC((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK, - RtecScheduler::SYNCHRONIZATION_FAILURE)); - // Lookup a handle for an RT_Info, and return its handle, or an error - // value if it's not present. - - virtual RtecScheduler::RT_Info* get (RtecScheduler::handle_t handle, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK, - RtecScheduler::SYNCHRONIZATION_FAILURE)); - // Return a pointer to the RT_Info corresponding to the passed handle. - - virtual void set (RtecScheduler::handle_t handle, - RtecScheduler::Criticality_t criticality, - RtecScheduler::Time time, - RtecScheduler::Time typical_time, - RtecScheduler::Time cached_time, - RtecScheduler::Period_t period, - RtecScheduler::Importance_t importance, - RtecScheduler::Quantum_t quantum, - CORBA::Long threads, - RtecScheduler::Info_Type_t info_type, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK, - RtecScheduler::INTERNAL, - RtecScheduler::SYNCHRONIZATION_FAILURE)); - // Set characteristics of the RT_Info corresponding to the passed handle. - - virtual void priority (RtecScheduler::handle_t handle, - RtecScheduler::OS_Priority& o_priority, - RtecScheduler::Preemption_Subpriority_t& p_subpriority, - RtecScheduler::Preemption_Priority_t& p_priority, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK, - RtecScheduler::SYNCHRONIZATION_FAILURE, - RtecScheduler::NOT_SCHEDULED)); - // Returns the priority and subpriority values assigned to an RT_Info, - // based on its handle. - - virtual void entry_point_priority (const char * entry_point, - RtecScheduler::OS_Priority& o_priority, - RtecScheduler::Preemption_Subpriority_t& p_subpriority, - RtecScheduler::Preemption_Priority_t& p_priority, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK, - RtecScheduler::SYNCHRONIZATION_FAILURE, - RtecScheduler::NOT_SCHEDULED)); - // Returns the priority and subpriority values assigned to an RT_Info, - // based on its entry point name. - - virtual void add_dependency (RtecScheduler::handle_t handle, - RtecScheduler::handle_t dependency, - CORBA::Long number_of_calls, - RtecScheduler::Dependency_Type_t dependency_type, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::SYNCHRONIZATION_FAILURE, - RtecScheduler::UNKNOWN_TASK)); - // This method registers a dependency between two RT_Infos. - - virtual void compute_scheduling (CORBA::Long minimum_priority, - CORBA::Long maximum_priority, - RtecScheduler::RT_Info_Set_out infos, - RtecScheduler::Config_Info_Set_out configs, - RtecScheduler::Scheduling_Anomaly_Set_out anomalies, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::UTILIZATION_BOUND_EXCEEDED, - RtecScheduler::SYNCHRONIZATION_FAILURE, - RtecScheduler::INSUFFICIENT_THREAD_PRIORITY_LEVELS, - RtecScheduler::TASK_COUNT_MISMATCH, - RtecScheduler::INTERNAL, - RtecScheduler::DUPLICATE_NAME)); - // If information has been added or changed since the last stable - // schedule was computed, this method causes scheduling information - // to be computed for all registered RT_Infos. If the schedule is - // already stable, this is a no-op. - - virtual void dispatch_configuration (RtecScheduler::Preemption_Priority_t p_priority, - RtecScheduler::OS_Priority& o_priority, - RtecScheduler::Dispatching_Type_t & d_type, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::NOT_SCHEDULED, - RtecScheduler::SYNCHRONIZATION_FAILURE, - RtecScheduler::UNKNOWN_PRIORITY_LEVEL)); - // Provides the thread priority and queue type for the given priority level. - - virtual RtecScheduler::Preemption_Priority_t last_scheduled_priority (CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::SYNCHRONIZATION_FAILURE, - RtecScheduler::NOT_SCHEDULED)); - // Returns the last priority number assigned to an operation in the - // schedule. The number returned is one less than the total number - // of scheduled priorities. All scheduled priorities range from 0 - // to the number returned, inclusive. - - // = Accessors that allow controlled relaxations of encapsulation. - - RECONFIG_SCHED_STRATEGY & sched_strategy (); - // Accesses scheduling strategy for the reconfig scheduler. - - CONFIG_INFO_MAP & config_info_map (); - // Accesses map for O(1) lookup of Config_Infos by priority level. - - long config_info_count (); - // Returns the number of config infos, which is also the number of - // assigned priority levels. - - RT_INFO_MAP & rt_info_map (); - // Accesses map for O(1) lookup of RT_Infos by handle. - - long rt_info_count (); - // Returns the number of registered RT_Infos. - - RT_INFO_TREE & rt_info_tree (); - // Accesses tree for O(log n) lookup of RT_Infos by name. - - DEPENDENCY_SET_MAP & calling_dependency_set_map (); - // Accesses map for O(1) lookup of RT_Info dependency - // set by the caller operation's handle. - - DEPENDENCY_SET_MAP & called_dependency_set_map (); - // Accesses map for O(1) lookup of RT_Info dependency - // set by the called operation's handle. - - int dependency_count (); - // Returns the number of dependencies in the dependency lists of all RT_Infos. - // This is used when traversing the dependency graph. - -protected: - - // @@ TO DO: use a memento to save and restore scheduler state without - // breaking encapsulation, particularly of these flags. - - enum Stability_Flags - { - // This should always be zero. - SCHED_ALL_STABLE = 0x00UL, - - // Individual stability flags, each of - // which should have a distinct bit value. - - // Utilization may need to be recomputed. - SCHED_UTILIZATION_NOT_STABLE = 0x01UL, - - // Priorities may need to be recomputed. - SCHED_PRIORITY_NOT_STABLE = 0x02UL, - - // Characteristics may need to be repropagated. - SCHED_PROPAGATION_NOT_STABLE = 0x04UL, - - // This should be the disjunction of - // all the individual stability flags. - SCHED_NONE_STABLE = - SCHED_UTILIZATION_NOT_STABLE | - SCHED_PRIORITY_NOT_STABLE | - SCHED_PROPAGATION_NOT_STABLE - }; - // Flags indicating stability conditions of schedule. - - virtual RtecScheduler::RT_Info * create_i (const char * entry_point, - RtecScheduler::handle_t handle, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::DUPLICATE_NAME, - RtecScheduler::INTERNAL)); - // Internal method to create an RT_Info. If it does not exist, - // a new RT_Info is created and inserted into the schedule, - // and the handle of the new RT_Info is returned. - // If the RT_Info already exists, an exception is thrown. - - virtual void set_i (RtecScheduler::RT_Info *rt_info, - RtecScheduler::Criticality_t criticality, - RtecScheduler::Time time, - RtecScheduler::Time typical_time, - RtecScheduler::Time cached_time, - RtecScheduler::Period_t period, - RtecScheduler::Importance_t importance, - RtecScheduler::Quantum_t quantum, - CORBA::Long threads, - RtecScheduler::Info_Type_t info_type); - // Internal method to set characteristics of the passed RT_Info. - - virtual RtecScheduler::handle_t lookup_i (const char * entry_point, - CORBA::Environment &_env) - ACE_THROW_SPEC((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK)); - // Internal method to look up a handle for an RT_Info, and return - // its handle, or an exception if it's not present. - - virtual void priority_i (RtecScheduler::handle_t handle, - RtecScheduler::OS_Priority& o_priority, - RtecScheduler::Preemption_Subpriority_t& p_subpriority, - RtecScheduler::Preemption_Priority_t& p_priority, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK, - RtecScheduler::NOT_SCHEDULED)); - // Internal method to return the priority and subpriority - // values assigned to an RT_Info, based on its handle. - - virtual void add_dependency_i (RtecScheduler::handle_t handle, - RtecScheduler::handle_t dependency, - CORBA::Long number_of_calls, - RtecScheduler::Dependency_Type_t dependency_type, - CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::INTERNAL, - RtecScheduler::UNKNOWN_TASK)); - // Internal method that registers a dependency between two RT_Infos. - // Assumes it is being called with all locks held, and does *not* - // set any schedule stability flags. - - virtual void map_dependency_i (RtecScheduler::handle_t key, - RtecScheduler::handle_t handle, - ACE_TYPENAME TAO_Reconfig_Scheduler<RECONFIG_SCHED_STRATEGY, ACE_LOCK>::DEPENDENCY_SET_MAP &map, - CORBA::Long number_of_calls, - RtecScheduler::Dependency_Type_t dependency_type, - CORBA::Environment &env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::UNKNOWN_TASK)); - // This method installs a dependency in a dependency set map. - - - virtual void dfs_traverse_i (CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::INTERNAL)); - // Traverses dependency graph, assigning a topological ordering. - // Resets DFS map entries, do DFS traversal, constructs DFS map. - - virtual void detect_cycles_i (CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::INTERNAL, - RtecScheduler::CYCLIC_DEPENDENCIES)); - // Sorts an array of RT_info handles in topological order, then - // checks for loops, marks unresolved remote dependencies. - - virtual void propagate_characteristics_i (CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::INTERNAL, - RtecScheduler::UNRESOLVED_LOCAL_DEPENDENCIES, - RtecScheduler::THREAD_SPECIFICATION)); - // Propagates effective execution time and period, sets total frame size. - - virtual void assign_priorities_i (CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::INTERNAL, - RtecScheduler::DUPLICATE_NAME)); - // Sort operations by urgency (done by strategy), then - // assign priorities and subpriorities in one pass. - // Sets last scheduled priority. - - virtual void compute_utilization_i (CORBA::Environment &_env) - ACE_THROW_SPEC ((CORBA::SystemException, - RtecScheduler::INTERNAL)); - // Compute utilization, set last feasible priority. - - static void init_rt_info (RtecScheduler::RT_Info &rt_info) - ACE_THROW_SPEC (()); - // Helper method to give an RT_Info some reasonable default values - - - - // = Protected class members. - - RECONFIG_SCHED_STRATEGY sched_strategy_; - // Scheduling strategy for the reconfig scheduler. - - CONFIG_INFO_MAP config_info_map_; - // Map for O(1) lookup of Config_Infos by priority level. - - long config_info_count_; - // The number of config infos, which is also the number of priority - // levels. - - RT_INFO_MAP rt_info_map_; - // Map for O(1) lookup of RT_Infos by handle. - - long rt_info_count_; - // The number of registered RT_Infos. - - RT_INFO_TREE rt_info_tree_; - // Tree for O(log n) lookup of RT_Infos by name. - - DEPENDENCY_SET_MAP calling_dependency_set_map_; - // Map for O(1) lookup of RT_Info dependency - // set by the caller operation's handle. - - DEPENDENCY_SET_MAP called_dependency_set_map_; - // Map for O(1) lookup of RT_Info dependency - // set by the called operation's handle. - - RtecScheduler::handle_t next_handle_; - // Next RT_Info descriptor handle to allocate. The first handle is - // always 1. - - TAO_Reconfig_Scheduler_Entry ** entry_ptr_array_; - // Array of pointers to scheduling entries. This - // array is maintained by the methods that create - // scheduling entries, and sorted in topological - // order and then priority order at various points - // during schedule computation. - - long entry_ptr_array_size_; - // Size of the array of scheduling entry pointers. - - u_long stability_flags_; - // Flags indicating whether a stable schedule has been computed - // since the last addition or modification of information, and which - // parts of the schedule are unstable. - - int enforce_schedule_stability_; - // Indicates whether the scheduler should enforce stability by - // throwing an exception: otherwise for operations where this - // matters, it will simply return a default value if nothing - // has been generated. - - int dependency_count_; - // The number of dependencies in the dependency lists of all RT_Infos. - // This is used when traversing the dependency graph. - - RtecScheduler::Preemption_Priority_t last_scheduled_priority_; - // Stores the last priority for which an operation can be scheduled - - CORBA::Double noncritical_utilization_; - // Utilization by noncritical tasks. - - CORBA::Double critical_utilization_; - // Utilization by critical tasks. - - ACE_LOCK mutex_; - // Mutual exclusion lock for the scheduler itself. This is needed to - // synchronize updates and accesses to scheduling information. -}; - -#if defined (__ACE_INLINE__) -#include "Reconfig_Scheduler_T.i" -#endif /* __ACE_INLINE__ */ - - -#if defined (ACE_TEMPLATES_REQUIRE_SOURCE) -#include "Reconfig_Scheduler_T.cpp" -#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */ - -#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA) -#pragma implementation ("Reconfig_Scheduler_T.cpp") -#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */ - -#endif /* __GNUC__ */ - -#endif /* TAO_RECONFIG_SCHEDULER_T_H */ |