diff options
author | Sebastian Huber <sebastian.huber@embedded-brains.de> | 2016-08-03 15:41:31 +0200 |
---|---|---|
committer | Sebastian Huber <sebastian.huber@embedded-brains.de> | 2016-08-04 07:44:47 +0200 |
commit | 21bdca49eea9213cc31a497072d01192eed8675e (patch) | |
tree | fcfc8e0c3e4f7c38b7c7f06bc6d0076deb10edaf /cpukit | |
parent | score: Fix and simplify thread wait locks (diff) | |
download | rtems-21bdca49eea9213cc31a497072d01192eed8675e.tar.bz2 |
score: Indroduce cancel job scheduler operation
Do not use a deadline value of zero to indicate a job cancellation. Use
a dedicated scheduler operation for this.
Diffstat (limited to 'cpukit')
-rw-r--r-- | cpukit/rtems/src/ratemoncancel.c | 2 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/scheduler.h | 17 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/schedulercbs.h | 1 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/scheduleredf.h | 8 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/schedulerimpl.h | 14 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/schedulerpriority.h | 1 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h | 1 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/schedulerprioritysmp.h | 1 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/schedulersimple.h | 1 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/schedulersimplesmp.h | 1 | ||||
-rw-r--r-- | cpukit/score/include/rtems/score/schedulerstrongapa.h | 1 | ||||
-rw-r--r-- | cpukit/score/src/schedulerdefaultreleasejob.c | 9 | ||||
-rw-r--r-- | cpukit/score/src/scheduleredfreleasejob.c | 46 |
13 files changed, 94 insertions, 9 deletions
diff --git a/cpukit/rtems/src/ratemoncancel.c b/cpukit/rtems/src/ratemoncancel.c index af6b1ec4e3..41ba48856f 100644 --- a/cpukit/rtems/src/ratemoncancel.c +++ b/cpukit/rtems/src/ratemoncancel.c @@ -38,7 +38,7 @@ void _Rate_monotonic_Cancel( cpu_self = _Thread_Dispatch_disable_critical( lock_context ); _Rate_monotonic_Release( owner, lock_context ); - _Scheduler_Release_job( owner, 0 ); + _Scheduler_Cancel_job( owner ); _Thread_Dispatch_enable( cpu_self ); } diff --git a/cpukit/score/include/rtems/score/scheduler.h b/cpukit/score/include/rtems/score/scheduler.h index 120fdfd239..c8a7f87541 100644 --- a/cpukit/score/include/rtems/score/scheduler.h +++ b/cpukit/score/include/rtems/score/scheduler.h @@ -145,6 +145,12 @@ typedef struct { uint64_t ); + /** @see _Scheduler_Cancel_job() */ + void ( *cancel_job ) ( + const Scheduler_Control *, + Thread_Control * + ); + /** @see _Scheduler_Tick() */ void ( *tick )( const Scheduler_Control *, Thread_Control * ); @@ -535,6 +541,17 @@ void _Scheduler_default_Release_job( ); /** + * @brief Does nothing. + * + * @param[in] scheduler Unused. + * @param[in] the_thread Unused. + */ +void _Scheduler_default_Cancel_job( + const Scheduler_Control *scheduler, + Thread_Control *the_thread +); + +/** * @brief Performs tick operations depending on the CPU budget algorithm for * each executing thread. * diff --git a/cpukit/score/include/rtems/score/schedulercbs.h b/cpukit/score/include/rtems/score/schedulercbs.h index a46314c659..bfad633987 100644 --- a/cpukit/score/include/rtems/score/schedulercbs.h +++ b/cpukit/score/include/rtems/score/schedulercbs.h @@ -61,6 +61,7 @@ extern "C" { _Scheduler_CBS_Node_initialize, /* node initialize entry point */ \ _Scheduler_default_Node_destroy, /* node destroy entry point */ \ _Scheduler_CBS_Release_job, /* new period of task */ \ + _Scheduler_EDF_Cancel_job, /* cancel period of task */ \ _Scheduler_default_Tick, /* tick entry point */ \ _Scheduler_default_Start_idle /* start idle entry point */ \ SCHEDULER_OPERATION_DEFAULT_GET_SET_AFFINITY \ diff --git a/cpukit/score/include/rtems/score/scheduleredf.h b/cpukit/score/include/rtems/score/scheduleredf.h index de06344aa5..5d9b4359c4 100644 --- a/cpukit/score/include/rtems/score/scheduleredf.h +++ b/cpukit/score/include/rtems/score/scheduleredf.h @@ -61,6 +61,7 @@ extern "C" { _Scheduler_EDF_Node_initialize, /* node initialize entry point */ \ _Scheduler_default_Node_destroy, /* node destroy entry point */ \ _Scheduler_EDF_Release_job, /* new period of task */ \ + _Scheduler_EDF_Cancel_job, /* cancel period of task */ \ _Scheduler_default_Tick, /* tick entry point */ \ _Scheduler_default_Start_idle /* start idle entry point */ \ SCHEDULER_OPERATION_DEFAULT_GET_SET_AFFINITY \ @@ -227,12 +228,17 @@ Scheduler_Void_or_thread _Scheduler_EDF_Yield( * the job was cancelled or deleted, thus a running task * has to be suspended. */ -void _Scheduler_EDF_Release_job ( +void _Scheduler_EDF_Release_job( const Scheduler_Control *scheduler, Thread_Control *the_thread, uint64_t deadline ); +void _Scheduler_EDF_Cancel_job( + const Scheduler_Control *scheduler, + Thread_Control *the_thread +); + #ifdef __cplusplus } #endif diff --git a/cpukit/score/include/rtems/score/schedulerimpl.h b/cpukit/score/include/rtems/score/schedulerimpl.h index f8c29e215c..91fa178d20 100644 --- a/cpukit/score/include/rtems/score/schedulerimpl.h +++ b/cpukit/score/include/rtems/score/schedulerimpl.h @@ -508,6 +508,20 @@ RTEMS_INLINE_ROUTINE void _Scheduler_Release_job( } /** + * @brief Cancels a job of a thread with respect to the scheduler. + * + * @param[in] the_thread The thread. + */ +RTEMS_INLINE_ROUTINE void _Scheduler_Cancel_job( + Thread_Control *the_thread +) +{ + const Scheduler_Control *scheduler = _Scheduler_Get( the_thread ); + + ( *scheduler->Operations.cancel_job )( scheduler, the_thread ); +} + +/** * @brief Scheduler method invoked at each clock tick. * * This method is invoked at each clock tick to allow the scheduler diff --git a/cpukit/score/include/rtems/score/schedulerpriority.h b/cpukit/score/include/rtems/score/schedulerpriority.h index 9501e3d026..f3e805a43b 100644 --- a/cpukit/score/include/rtems/score/schedulerpriority.h +++ b/cpukit/score/include/rtems/score/schedulerpriority.h @@ -51,6 +51,7 @@ extern "C" { _Scheduler_priority_Node_initialize, /* node initialize entry point */ \ _Scheduler_default_Node_destroy, /* node destroy entry point */ \ _Scheduler_default_Release_job, /* new period of task */ \ + _Scheduler_default_Cancel_job, /* cancel period of task */ \ _Scheduler_default_Tick, /* tick entry point */ \ _Scheduler_default_Start_idle /* start idle entry point */ \ SCHEDULER_OPERATION_DEFAULT_GET_SET_AFFINITY \ diff --git a/cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h b/cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h index 763523aec3..317411ad7b 100644 --- a/cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h +++ b/cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h @@ -61,6 +61,7 @@ extern "C" { _Scheduler_priority_affinity_SMP_Node_initialize, \ _Scheduler_default_Node_destroy, \ _Scheduler_default_Release_job, \ + _Scheduler_default_Cancel_job, \ _Scheduler_default_Tick, \ _Scheduler_SMP_Start_idle, \ _Scheduler_priority_affinity_SMP_Get_affinity, \ diff --git a/cpukit/score/include/rtems/score/schedulerprioritysmp.h b/cpukit/score/include/rtems/score/schedulerprioritysmp.h index 97370ac510..6ae933f3f7 100644 --- a/cpukit/score/include/rtems/score/schedulerprioritysmp.h +++ b/cpukit/score/include/rtems/score/schedulerprioritysmp.h @@ -90,6 +90,7 @@ typedef struct { _Scheduler_priority_SMP_Node_initialize, \ _Scheduler_default_Node_destroy, \ _Scheduler_default_Release_job, \ + _Scheduler_default_Cancel_job, \ _Scheduler_default_Tick, \ _Scheduler_SMP_Start_idle \ SCHEDULER_OPERATION_DEFAULT_GET_SET_AFFINITY \ diff --git a/cpukit/score/include/rtems/score/schedulersimple.h b/cpukit/score/include/rtems/score/schedulersimple.h index 3fa4b333f9..22393790bc 100644 --- a/cpukit/score/include/rtems/score/schedulersimple.h +++ b/cpukit/score/include/rtems/score/schedulersimple.h @@ -51,6 +51,7 @@ extern "C" { _Scheduler_default_Node_initialize, /* node initialize entry point */ \ _Scheduler_default_Node_destroy, /* node destroy entry point */ \ _Scheduler_default_Release_job, /* new period of task */ \ + _Scheduler_default_Cancel_job, /* cancel period of task */ \ _Scheduler_default_Tick, /* tick entry point */ \ _Scheduler_default_Start_idle /* start idle entry point */ \ SCHEDULER_OPERATION_DEFAULT_GET_SET_AFFINITY \ diff --git a/cpukit/score/include/rtems/score/schedulersimplesmp.h b/cpukit/score/include/rtems/score/schedulersimplesmp.h index bbcdbdb03e..95176dc2c1 100644 --- a/cpukit/score/include/rtems/score/schedulersimplesmp.h +++ b/cpukit/score/include/rtems/score/schedulersimplesmp.h @@ -73,6 +73,7 @@ typedef struct { _Scheduler_simple_SMP_Node_initialize, \ _Scheduler_default_Node_destroy, \ _Scheduler_default_Release_job, \ + _Scheduler_default_Cancel_job, \ _Scheduler_default_Tick, \ _Scheduler_SMP_Start_idle \ SCHEDULER_OPERATION_DEFAULT_GET_SET_AFFINITY \ diff --git a/cpukit/score/include/rtems/score/schedulerstrongapa.h b/cpukit/score/include/rtems/score/schedulerstrongapa.h index 8390c2d3b9..2cc91835b2 100644 --- a/cpukit/score/include/rtems/score/schedulerstrongapa.h +++ b/cpukit/score/include/rtems/score/schedulerstrongapa.h @@ -90,6 +90,7 @@ typedef struct { _Scheduler_strong_APA_Node_initialize, \ _Scheduler_default_Node_destroy, \ _Scheduler_default_Release_job, \ + _Scheduler_default_Cancel_job, \ _Scheduler_default_Tick, \ _Scheduler_SMP_Start_idle \ SCHEDULER_OPERATION_DEFAULT_GET_SET_AFFINITY \ diff --git a/cpukit/score/src/schedulerdefaultreleasejob.c b/cpukit/score/src/schedulerdefaultreleasejob.c index db4ab0e8e1..439f6b2649 100644 --- a/cpukit/score/src/schedulerdefaultreleasejob.c +++ b/cpukit/score/src/schedulerdefaultreleasejob.c @@ -31,3 +31,12 @@ void _Scheduler_default_Release_job( (void) the_thread; (void) deadline; } + +void _Scheduler_default_Cancel_job( + const Scheduler_Control *scheduler, + Thread_Control *the_thread +) +{ + (void) scheduler; + (void) the_thread; +} diff --git a/cpukit/score/src/scheduleredfreleasejob.c b/cpukit/score/src/scheduleredfreleasejob.c index b35fb9d80e..26b303acc0 100644 --- a/cpukit/score/src/scheduleredfreleasejob.c +++ b/cpukit/score/src/scheduleredfreleasejob.c @@ -20,7 +20,7 @@ #include <rtems/score/scheduleredfimpl.h> -static bool _Scheduler_EDF_Priority_filter( +static bool _Scheduler_EDF_Release_job_filter( Thread_Control *the_thread, Priority_Control *new_priority_p, void *arg @@ -35,10 +35,6 @@ static bool _Scheduler_EDF_Priority_filter( current_priority = the_thread->current_priority; new_priority = *new_priority_p; - if ( new_priority == 0 ) { - new_priority = node->background_priority; - } - node->current_priority = new_priority; the_thread->real_priority = new_priority; @@ -54,9 +50,45 @@ void _Scheduler_EDF_Release_job( { _Thread_Change_priority( the_thread, - (Priority_Control) deadline, + deadline, + NULL, + _Scheduler_EDF_Release_job_filter, + true + ); +} + +static bool _Scheduler_EDF_Cancel_job_filter( + Thread_Control *the_thread, + Priority_Control *new_priority_p, + void *arg +) +{ + Scheduler_EDF_Node *node; + Priority_Control current_priority; + Priority_Control new_priority; + + node = _Scheduler_EDF_Thread_get_node( the_thread ); + + current_priority = _Thread_Get_priority( the_thread ); + new_priority = node->background_priority; + + node->current_priority = new_priority; + the_thread->real_priority = new_priority; + + return _Thread_Priority_less_than( current_priority, new_priority ) + || !_Thread_Owns_resources( the_thread ); +} + +void _Scheduler_EDF_Cancel_job( + const Scheduler_Control *scheduler, + Thread_Control *the_thread +) +{ + _Thread_Change_priority( + the_thread, + 0, NULL, - _Scheduler_EDF_Priority_filter, + _Scheduler_EDF_Cancel_job_filter, true ); } |