1 files changed, 92 insertions, 0 deletions
diff --git a/ACE/Kokyu/DSRT_Direct_Dispatcher_Impl_T.h b/ACE/Kokyu/DSRT_Direct_Dispatcher_Impl_T.h
new file mode 100644
index 00000000000..d4f93f37eca
--- /dev/null
+++ b/ACE/Kokyu/DSRT_Direct_Dispatcher_Impl_T.h
@@ -0,0 +1,92 @@
+/* -*- C++ -*- */
+/**
+ *  @file  DSRT_Direct_Dispatcher_Impl_T.h
+ *
+ *  $Id$
+ *
+ *  @author Venkita Subramonian (venkita@cs.wustl.edu)
+ *
+ */
+
+#ifndef DSRT_DIRECT_DISPATCHER_IMPL_T_H
+#define DSRT_DIRECT_DISPATCHER_IMPL_T_H
+#include /**/ "ace/pre.h"
+
+#include "ace/Task.h"
+
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+#include "ace/Copy_Disabled.h"
+#include "Kokyu_dsrt.h"
+#include "DSRT_Sched_Queue_T.h"
+#include "DSRT_Dispatcher_Impl_T.h"
+
+namespace Kokyu
+{
+  template<class DSRT_Scheduler_Traits>
+  class DSRT_Direct_Dispatcher_Impl :
+    public ACE_Task_Base,
+    public DSRT_Dispatcher_Impl<DSRT_Scheduler_Traits>,
+    public ACE_Copy_Disabled
+  {
+  public:
+    typedef typename
+    DSRT_Scheduler_Traits::Guid_t Guid_t;
+
+    typedef typename
+    DSRT_Scheduler_Traits::QoSDescriptor_t DSRT_QoSDescriptor;
+
+    DSRT_Direct_Dispatcher_Impl (ACE_Sched_Params::Policy sched_policy,
+                                 int sched_scope);
+
+    int init_i (const DSRT_ConfigInfo&);
+
+    /// Schedule a thread dynamically based on the qos info supplied.
+    int schedule_i (Guid_t, const DSRT_QoSDescriptor&);
+
+    /// Update the schedule for a thread. This could alter the current
+    /// schedule.
+    int update_schedule_i (Guid_t, const DSRT_QoSDescriptor&);
+
+    /// Inform the scheduler that the caller thread is about to
+    /// block. This could alter the current schedule.
+    int update_schedule_i (Guid_t, Block_Flag_t);
+
+    /// Cancel the schedule for a thread. This could alter the current
+    /// schedule.
+    int cancel_schedule_i (Guid_t);
+
+    /// Shut down the dispatcher. The dispatcher will stop processing
+    /// requests.
+    int shutdown_i ();
+
+  private:
+    typedef ACE_SYNCH_MUTEX cond_lock_t;
+    typedef ACE_SYNCH_CONDITION cond_t;
+
+    u_int sched_queue_modified_;
+    cond_lock_t sched_queue_modified_cond_lock_;
+    cond_t sched_queue_modified_cond_;
+
+  private:
+    int svc (void);
+  };
+
+}
+
+#if !defined (__ACE_INLINE__)
+//#include "DSRT_Direct_Dispatcher_Impl_T.i"
+#endif /* __ACE_INLINE__ */
+
+#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
+#include "DSRT_Direct_Dispatcher_Impl_T.cpp"
+#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */
+
+#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA)
+#pragma implementation ("DSRT_Direct_Dispatcher_Impl_T.cpp")
+#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */
+
+#include /**/ "ace/post.h"
+#endif /* DSRT_DIRECT_DISPATCHER_IMPL_T_H */