summaryrefslogtreecommitdiffstats
path: root/cpukit/score/include
diff options
context:
space:
mode:
authorSebastian Huber <sebastian.huber@embedded-brains.de>2016-06-09 21:30:40 +0200
committerSebastian Huber <sebastian.huber@embedded-brains.de>2016-06-22 14:37:11 +0200
commit99fc1d1d1b44e70a0bed4c94a514bd3f3b5df64f (patch)
tree3d290aed9fb42872d1ec6457025eb66a7303dec5 /cpukit/score/include
parentscore: Modify release job scheduler operation (diff)
downloadrtems-99fc1d1d1b44e70a0bed4c94a514bd3f3b5df64f.tar.bz2
score: Rework EDF scheduler
Use inline red-black tree insert. Do not use shifting priorities since this is not supported by the thread queues. Due to the 32-bit Priority_Control this currently limits the uptime to 49days with a 1ms clock tick. Update #2173.
Diffstat (limited to 'cpukit/score/include')
-rw-r--r--cpukit/score/include/rtems/score/scheduleredf.h25
-rw-r--r--cpukit/score/include/rtems/score/scheduleredfimpl.h107
2 files changed, 88 insertions, 44 deletions
diff --git a/cpukit/score/include/rtems/score/scheduleredf.h b/cpukit/score/include/rtems/score/scheduleredf.h
index feaa2efa62..4eb5f49d4b 100644
--- a/cpukit/score/include/rtems/score/scheduleredf.h
+++ b/cpukit/score/include/rtems/score/scheduleredf.h
@@ -35,7 +35,7 @@ extern "C" {
*/
/**@{*/
-#define SCHEDULER_EDF_MAXIMUM_PRIORITY 255
+#define SCHEDULER_EDF_MAXIMUM_PRIORITY 0x7fffffff
/**
* Entry points for the Earliest Deadline First Scheduler.
@@ -82,18 +82,6 @@ typedef struct {
} Scheduler_EDF_Context;
/**
- * @typedef Scheduler_EDF_Queue_state
- *
- * This enumeration distiguishes state of a thread with respect to the
- * ready queue.
- */
-typedef enum {
- SCHEDULER_EDF_QUEUE_STATE_NOT_PRESENTLY,
- SCHEDULER_EDF_QUEUE_STATE_YES,
- SCHEDULER_EDF_QUEUE_STATE_NEVER_HAS_BEEN
-} Scheduler_EDF_Queue_state;
-
-/**
* @brief Scheduler node specialization for EDF schedulers.
*/
typedef struct {
@@ -110,10 +98,17 @@ typedef struct {
* Rbtree node related to this thread.
*/
RBTree_Node Node;
+
+ /**
+ * @brief The thread priority used by this scheduler instance in case no job
+ * is released.
+ */
+ Priority_Control background_priority;
+
/**
- * State of the thread with respect to ready queue.
+ * @brief The thread priority currently used by this scheduler instance.
*/
- Scheduler_EDF_Queue_state queue_state;
+ Priority_Control current_priority;
} Scheduler_EDF_Node;
/**
diff --git a/cpukit/score/include/rtems/score/scheduleredfimpl.h b/cpukit/score/include/rtems/score/scheduleredfimpl.h
index e831caf9f9..7ff7aa2c12 100644
--- a/cpukit/score/include/rtems/score/scheduleredfimpl.h
+++ b/cpukit/score/include/rtems/score/scheduleredfimpl.h
@@ -44,44 +44,92 @@ RTEMS_INLINE_ROUTINE Scheduler_EDF_Node *_Scheduler_EDF_Thread_get_node(
return (Scheduler_EDF_Node *) _Scheduler_Thread_get_node( the_thread );
}
-int _Scheduler_EDF_Priority_compare (
- Priority_Control p1,
- Priority_Control p2
-);
+RTEMS_INLINE_ROUTINE bool _Scheduler_EDF_Less(
+ const void *left,
+ const RBTree_Node *right
+)
+{
+ const Priority_Control *the_left;
+ const Scheduler_EDF_Node *the_right;
+ Priority_Control prio_left;
+ Priority_Control prio_right;
+
+ the_left = left;
+ the_right = RTEMS_CONTAINER_OF( right, Scheduler_EDF_Node, Node );
+
+ prio_left = *the_left;
+ prio_right = the_right->current_priority;
+
+ return prio_left < prio_right;
+}
+
+RTEMS_INLINE_ROUTINE bool _Scheduler_EDF_Less_or_equal(
+ const void *left,
+ const RBTree_Node *right
+)
+{
+ const Priority_Control *the_left;
+ const Scheduler_EDF_Node *the_right;
+ Priority_Control prio_left;
+ Priority_Control prio_right;
-RBTree_Compare_result _Scheduler_EDF_Compare(
- const RBTree_Node* n1,
- const RBTree_Node* n2
-);
+ the_left = left;
+ the_right = RTEMS_CONTAINER_OF( right, Scheduler_EDF_Node, Node );
+
+ prio_left = *the_left;
+ prio_right = the_right->current_priority;
+
+ return prio_left <= prio_right;
+}
RTEMS_INLINE_ROUTINE void _Scheduler_EDF_Enqueue(
- const Scheduler_Control *scheduler,
- Thread_Control *the_thread
+ Scheduler_EDF_Context *context,
+ Scheduler_EDF_Node *node,
+ Priority_Control current_priority
)
{
- Scheduler_EDF_Context *context =
- _Scheduler_EDF_Get_context( scheduler );
- Scheduler_EDF_Node *node = _Scheduler_EDF_Thread_get_node( the_thread );
+ _RBTree_Insert_inline(
+ &context->Ready,
+ &node->Node,
+ &current_priority,
+ _Scheduler_EDF_Less
+ );
+}
- _RBTree_Insert(
+RTEMS_INLINE_ROUTINE void _Scheduler_EDF_Enqueue_first(
+ Scheduler_EDF_Context *context,
+ Scheduler_EDF_Node *node,
+ Priority_Control current_priority
+)
+{
+ _RBTree_Insert_inline(
&context->Ready,
&node->Node,
- _Scheduler_EDF_Compare,
- false
+ &current_priority,
+ _Scheduler_EDF_Less_or_equal
);
- node->queue_state = SCHEDULER_EDF_QUEUE_STATE_YES;
}
RTEMS_INLINE_ROUTINE void _Scheduler_EDF_Extract(
+ Scheduler_EDF_Context *context,
+ Scheduler_EDF_Node *node
+)
+{
+ _RBTree_Extract( &context->Ready, &node->Node );
+}
+
+RTEMS_INLINE_ROUTINE void _Scheduler_EDF_Extract_body(
const Scheduler_Control *scheduler,
Thread_Control *the_thread
)
{
- Scheduler_EDF_Context *context =
- _Scheduler_EDF_Get_context( scheduler );
- Scheduler_EDF_Node *node = _Scheduler_EDF_Thread_get_node( the_thread );
+ Scheduler_EDF_Context *context;
+ Scheduler_EDF_Node *node;
- _RBTree_Extract( &context->Ready, &node->Node );
+ context = _Scheduler_EDF_Get_context( scheduler );
+ node = _Scheduler_EDF_Thread_get_node( the_thread );
+
+ _Scheduler_EDF_Extract( context, node );
}
RTEMS_INLINE_ROUTINE void _Scheduler_EDF_Schedule_body(
@@ -90,16 +138,17 @@ RTEMS_INLINE_ROUTINE void _Scheduler_EDF_Schedule_body(
bool force_dispatch
)
{
- Scheduler_EDF_Context *context =
- _Scheduler_EDF_Get_context( scheduler );
- RBTree_Node *first = _RBTree_Minimum( &context->Ready );
- Scheduler_EDF_Node *node =
- RTEMS_CONTAINER_OF( first, Scheduler_EDF_Node, Node );
- Thread_Control *heir = node->thread;
+ Scheduler_EDF_Context *context;
+ RBTree_Node *first;
+ Scheduler_EDF_Node *node;
+
+ (void) the_thread;
- ( void ) the_thread;
+ context = _Scheduler_EDF_Get_context( scheduler );
+ first = _RBTree_Minimum( &context->Ready );
+ node = RTEMS_CONTAINER_OF( first, Scheduler_EDF_Node, Node );
- _Scheduler_Update_heir( heir, force_dispatch );
+ _Scheduler_Update_heir( node->thread, force_dispatch );
}
/**@}*/