1 files changed, 119 insertions, 0 deletions
diff --git a/TAO/examples/RTScheduling/DT_Creator.h b/TAO/examples/RTScheduling/DT_Creator.h
new file mode 100644
index 00000000000..0c6b5af90ac
--- /dev/null
+++ b/TAO/examples/RTScheduling/DT_Creator.h
@@ -0,0 +1,119 @@
+//$Id$
+
+#ifndef DT_CREATOR_H
+#define DT_CREATOR_H
+
+#include "POA_Holder.h"
+#include "Job_i.h"
+#include "Synch_i.h"
+#include "rtschedtestlib_export.h"
+
+#include "tao/RTScheduling/RTScheduler.h"
+#include "orbsvcs/CosNamingC.h"
+
+#include "ace/Service_Config.h"
+#include "ace/Service_Object.h"
+#include "ace/Arg_Shifter.h"
+
+class Thread_Task;
+class Task;
+
+typedef Thread_Task **DT_LIST;
+typedef POA_Holder **POA_LIST;
+typedef Job_i **JOB_LIST;
+
+class RTSCHEDTESTLIB_Export DT_Creator : public ACE_Service_Object
+{
+ public:
+  DT_Creator (void);
+
+  virtual ~DT_Creator (void);
+
+  int init (int argc, char *argv []);
+
+  int dt_task_init (ACE_Arg_Shifter& arg_shifter);
+
+  virtual void create_distributable_threads (RTScheduling::Current_ptr  current);
+
+  void activate_poa_list (void);
+  void activate_job_list (void);
+  void activate_schedule (void);
+
+  virtual void yield (int suspend_time,
+          Thread_Task* task) = 0;
+
+  virtual void wait (void) = 0;
+
+  virtual CORBA::Policy_ptr sched_param (int importance) = 0;
+
+  virtual Thread_Task* create_thr_task (int importance,
+          int start_time,
+          int load,
+          int iter,
+          int dist,
+          char *job_name) = 0;
+  //  virtual Task* task (void) = 0;
+
+  /// Resolve the naming service.
+  int resolve_naming_service (void);
+
+  int dt_count (void);
+
+  void dt_ended (void);
+  void job_ended (void);
+
+  void check_ifexit (void);
+
+  void log_msg (char* msg);
+
+  void orb (CORBA::ORB_ptr);
+  CORBA::ORB_ptr orb (void);
+
+  ACE_Time_Value* base_time (void);
+  void base_time (ACE_Time_Value*);
+
+  ACE_hrtime_t base_hr_time (void);
+
+  virtual int total_load (void) = 0;
+
+  RTScheduling::Current_ptr current (void);
+
+  Synch_i* synch (void);
+
+  void register_synch_obj (void);
+
+  int activate_root_poa (void);
+
+ protected:
+
+
+  DT_LIST dt_list_;
+  POA_LIST poa_list_;
+  JOB_LIST job_list_;
+  //Fixed_Priority_Scheduler* scheduler_;
+  int dt_count_;
+  int poa_count_;
+  int job_count_;
+  CORBA::ORB_var orb_;
+  /// Mutex to serialize access to our internal state.
+  ACE_Lock* state_lock_;
+  ACE_Lock* shutdown_lock_;
+  int active_dt_count_;
+  int active_job_count_;
+  char** log;
+  ACE_Time_Value* base_time_;
+  RTScheduling::Current_var current_;
+  /// RT ORB
+  RTCORBA::RTORB_var rt_orb_;
+  /// Reference to the root poa.
+  PortableServer::POA_var root_poa_;
+  /// A naming context.
+  CosNaming::NamingContextExt_var naming_;
+  char* file_name_;
+  char* log_file_name_;
+  ACE_UINT32 gsf_;
+  Synch_i* synch_;
+};
+
+
+#endif /*DT_CREATOR_H*/