summaryrefslogtreecommitdiff
path: root/Kokyu/Kokyu_dsrt.h
diff options
context:
space:
mode:
authorvenkita <venkita@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2003-07-25 23:41:55 +0000
committervenkita <venkita@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2003-07-25 23:41:55 +0000
commitd2c9289b2dc52324413eab4363e7f2cbef1f07ee (patch)
tree0c2d30977f52d7860362ff76b28ecc4d9a158421 /Kokyu/Kokyu_dsrt.h
parenta9886196297b83689fa1ad00642af7d2a5c5fa72 (diff)
downloadATCD-d2c9289b2dc52324413eab4363e7f2cbef1f07ee.tar.gz
ChangeLogTag: Fri Jul 25 17:41:08 2003 Venkita Subramonian <venkita@cse.wustl.edu>
Diffstat (limited to 'Kokyu/Kokyu_dsrt.h')
-rw-r--r--Kokyu/Kokyu_dsrt.h187
1 files changed, 187 insertions, 0 deletions
diff --git a/Kokyu/Kokyu_dsrt.h b/Kokyu/Kokyu_dsrt.h
new file mode 100644
index 00000000000..df4e36e323a
--- /dev/null
+++ b/Kokyu/Kokyu_dsrt.h
@@ -0,0 +1,187 @@
+/* -*- C++ -*- */
+/**
+ * @file Kokyu_dsrt.h
+ *
+ * $Id$
+ *
+ * @author Venkita Subramonian (venkita@cs.wustl.edu)
+ *
+ */
+
+#ifndef KOKYU_DSRT_H
+#define KOKYU_DSRT_H
+#include "ace/pre.h"
+
+//#if !defined (ACE_LACKS_PRAGMA_ONCE)
+//# pragma once
+//#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "kokyu_export.h"
+#include "Kokyu_defs.h"
+
+namespace Kokyu
+{
+ enum DSRT_Sched_Type_t
+ {
+ DSRT_FP,
+ DSRT_MUF,
+ DSRT_MIF
+ };
+
+ struct DSRT_ConfigInfo
+ {
+ DSRT_Sched_Type_t sched_strategy_;
+ };
+
+ template <class DSRT_Scheduler_Traits> class DSRT_Dispatcher_Impl;
+
+ /**
+ * @class DSRT_Dispatcher
+ *
+ * @brief Interface class for dynamic scheduling of threads
+ *
+ * The responsibility of this class is to forward all methods to
+ * its delegation/implementation class, e.g.,
+ * @c Default_DSRT_Dispatcher_Impl. This class follows the pImpl idiom
+ * or the bridge pattern to separate the implementation from the interface.
+ * DSRT_Dispatcher is the class that users will be using to achieve
+ * dynamic scheduling of threads.
+ */
+ template <class DSRT_Scheduler_Traits>
+ class Kokyu_Export DSRT_Dispatcher : private non_copyable
+ {
+ public:
+ typedef typename DSRT_Scheduler_Traits::Guid_t Guid_t;
+ typedef typename DSRT_Scheduler_Traits::QoSDescriptor_t DSRT_QoSDescriptor;
+
+ // = Scheduling methods.
+
+ /// Schedule a thread dynamically based on the qos info supplied.
+ int schedule (Guid_t guid, const DSRT_QoSDescriptor&);
+
+ /// Update the schedule for a thread. This could alter the current schedule.
+ int update_schedule (Guid_t guid, const DSRT_QoSDescriptor&);
+
+ /// Inform the scheduler that the caller thread is about to
+ /// block. This could alter the current schedule.
+ int update_schedule (Guid_t guid, Kokyu::Block_Flag_t flag);
+
+ /// Cancel the schedule for a thread. This could alter the current schedule.
+ int cancel_schedule (Guid_t guid);
+
+ /// Supply this interface with an appropriate implementation.
+ void implementation (DSRT_Dispatcher_Impl<DSRT_Scheduler_Traits>*);
+
+ // = Termination methods.
+
+ /// Shut down the dispatcher. The dispatcher will stop processing requests.
+ int shutdown ();
+
+ /// Non virtual destructor. Read as <b><i>this class not available
+ /// for inheritance<i></b>.
+ ~DSRT_Dispatcher ();
+
+ private:
+ /// Auto ptr to the implementation. Implementation will be created on the
+ /// heap and deleted automatically when the dispatcher object is destructed.
+ auto_ptr<DSRT_Dispatcher_Impl<DSRT_Scheduler_Traits> > dispatcher_impl_;
+ };
+
+
+ /**
+ * @class DSRT_Dispatcher_Factory
+ *
+ * @brief Factory class to create one of the dispatcher interface
+ * objects - for events or DSRT threads.
+ *
+ * Factory class creates a dispatcher or DSRT dispatcher and configures
+ * the interface object with the appropriate implementation.
+ */
+
+ template <class DSRT_Scheduler_Traits>
+ class Kokyu_Export DSRT_Dispatcher_Factory : private non_copyable
+ {
+ public:
+ typedef auto_ptr<DSRT_Dispatcher<DSRT_Scheduler_Traits> > DSRT_Dispatcher_Auto_Ptr;
+
+ /**
+ * Create a dispatcher for dynamic dispatching of threads.
+ * This will be used to dynamic scheduling of distributable threads for
+ * DSRTCORBA. The caller is responsible for freeing the memory.
+ *
+ * @param config Configuration information for the DSRT dispatcher.
+ *
+ * @return Auto pointer to the DSRT dispatcher.
+ */
+ static DSRT_Dispatcher_Auto_Ptr create_DSRT_dispatcher (const DSRT_ConfigInfo&);
+ };
+
+ /**
+ * @class MIF_Sched_Strategy
+ *
+ * @brief Strategy class implementing Maximum Importance First
+ * reordering strategy.
+ *
+ */
+ template <class QoSDescriptor>
+ class MIF_Comparator
+ {
+ public:
+ typedef typename QoSDescriptor::Importance_t Importance_t;
+
+ int operator ()(const QoSDescriptor& qos1,
+ const QoSDescriptor& qos2);
+ };
+
+ /**
+ * @class Fixed_Priority_Sched_Strategy
+ *
+ * @brief Strategy class implementing Fixed Priority reordering
+ * strategy.
+ *
+ */
+ template <class QoSDescriptor>
+ class Fixed_Priority_Comparator
+ {
+ public:
+ typedef typename QoSDescriptor::Priority_t Priority_t;
+
+ int operator ()(const QoSDescriptor& qos1,
+ const QoSDescriptor& qos2);
+ };
+
+ /**
+ * @class MUF_Sched_Strategy
+ *
+ * @brief Strategy class implementing Maximum Urgency First
+ * reordering strategy.
+ *
+ */
+ template <class QoSDescriptor>
+ class MUF_Comparator
+ {
+ public:
+ typedef typename QoSDescriptor::Criticality_t Criticality_t;
+ typedef typename QoSDescriptor::Time_t Time_t;
+
+ int operator ()(const QoSDescriptor& qos1,
+ const QoSDescriptor& qos2);
+ };
+
+
+} //end of namespace
+
+#if defined (__ACE_INLINE__)
+#include "Kokyu_dsrt.i"
+#endif /* __ACE_INLINE__ */
+
+#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
+#include "Kokyu_dsrt.cpp"
+#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */
+
+#if defined (ACE_TEMPLATES_REQUIRE_PRAGMA)
+#pragma implementation ("Kokyu_dsrt.cpp")
+#endif /* ACE_TEMPLATES_REQUIRE_PRAGMA */
+
+#include "ace/post.h"
+#endif /* KOKYU_DSRT_H */