diff options
| -rw-r--r-- | cpukit/score/Makefile.am | 2 | ||||
| -rw-r--r-- | cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h | 144 | ||||
| -rw-r--r-- | cpukit/score/preinstall.am | 4 | ||||
| -rw-r--r-- | cpukit/score/src/schedulerpriorityaffinitysmp.c | 80 |
4 files changed, 230 insertions, 0 deletions
diff --git a/cpukit/score/Makefile.am b/cpukit/score/Makefile.am index a09ddc3f09..07cb52022b 100644 --- a/cpukit/score/Makefile.am +++ b/cpukit/score/Makefile.am @@ -109,6 +109,7 @@ endif if HAS_SMP include_rtems_score_HEADERS += include/rtems/score/atomic.h include_rtems_score_HEADERS += include/rtems/score/cpustdatomic.h +include_rtems_score_HEADERS += include/rtems/score/schedulerpriorityaffinitysmp.h include_rtems_score_HEADERS += include/rtems/score/schedulersimplesmp.h endif @@ -125,6 +126,7 @@ endif if HAS_SMP libscore_a_SOURCES += src/profilingsmplock.c +libscore_a_SOURCES += src/schedulerpriorityaffinitysmp.c libscore_a_SOURCES += src/schedulerprioritysmp.c libscore_a_SOURCES += src/schedulersimplesmp.c libscore_a_SOURCES += src/smp.c diff --git a/cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h b/cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h new file mode 100644 index 0000000000..124d0c3ff8 --- /dev/null +++ b/cpukit/score/include/rtems/score/schedulerpriorityaffinitysmp.h @@ -0,0 +1,144 @@ +/** + * @file + * + * @ingroup ScoreSchedulerPriorityAffinitySMP + * + * @brief Deterministic Priority Affinity SMP Scheduler API + */ + +/* + * COPYRIGHT (c) 2014. + * On-Line Applications Research Corporation (OAR). + * + * The license and distribution terms for this file may be + * found in the file LICENSE in this distribution or at + * http://www.rtems.org/license/LICENSE. + */ + +#ifndef _RTEMS_SCORE_SCHEDULERPRIORITYAFFINITYSMP_H +#define _RTEMS_SCORE_SCHEDULERPRIORITYAFFINITYSMP_H + +#include <rtems/score/scheduler.h> +#include <rtems/score/schedulerpriority.h> +#include <rtems/score/schedulersmp.h> +#include <rtems/score/schedulerprioritysmp.h> +#include <rtems/score/cpuset.h> + +#ifdef __cplusplus +extern "C" { +#endif /* __cplusplus */ + +/** + * @defgroup ScoreSchedulerPriorityAffinitySMP Deterministic Priority Affinity SMP Scheduler + * + * @ingroup ScoreScheduler + * + * This is an extension of the Deterministic Priority SMP Scheduler. which + * is an implementation of the global fixed priority scheduler (G-FP). + * It adds thread to core affinity support. + * + * @note This is the first iteration of this scheduler. It currently tracks + * the requested affinity to exercise the Scheduler Framework but it + * does not honor that affinity in assigning threads to cores. This + * will be added in a subsequent revision. + * @{ + */ + +/** + * @brief Entry points for the Deterministic Priority Affinity SMP Scheduler. + */ +#define SCHEDULER_PRIORITY_AFFINITY_SMP_ENTRY_POINTS \ + { \ + _Scheduler_priority_SMP_Initialize, \ + _Scheduler_priority_SMP_Schedule, \ + _Scheduler_priority_SMP_Yield, \ + _Scheduler_priority_SMP_Block, \ + _Scheduler_priority_SMP_Enqueue_fifo, \ + _Scheduler_priority_affinity_SMP_Allocate, \ + _Scheduler_priority_Free, \ + _Scheduler_priority_SMP_Update, \ + _Scheduler_priority_SMP_Enqueue_fifo, \ + _Scheduler_priority_SMP_Enqueue_lifo, \ + _Scheduler_priority_SMP_Extract, \ + _Scheduler_priority_Priority_compare, \ + _Scheduler_default_Release_job, \ + _Scheduler_default_Tick, \ + _Scheduler_priority_SMP_Start_idle, \ + _Scheduler_priority_affinity_SMP_Get_affinity, \ + _Scheduler_priority_affinity_SMP_Set_affinity \ + } + +/** + * @brief Allocates @a the_thread->scheduler. + * + * This routine allocates @a the_thread->scheduler. + * + * @param[in] the_thread is the thread the scheduler is allocating + * management memory for + */ +void * _Scheduler_priority_affinity_SMP_Allocate( Thread_Control *the_thread ); + +/** + * @brief Get affinity for the priority affinity smp scheduler. + * + * @param[in] thread The associated thread. + * @param[in] cpusetsize The size of the cpuset. + * @param[in,out] cpuset The associated affinity set. + * + * @retval 0 Successfully got cpuset + * @retval -1 The cpusetsize is invalid for the system + */ +bool _Scheduler_priority_affinity_SMP_Get_affinity( + Thread_Control *thread, + size_t cpusetsize, + cpu_set_t *cpuset +); + +/** + * @brief Set affinity for the priority affinity smp scheduler. + * + * @param[in] thread The associated thread. + * @param[in] cpusetsize The size of the cpuset. + * @param[in] cpuset Affinity new affinity set. + * + * @retval 0 Successful + */ +bool _Scheduler_priority_affinity_SMP_Set_affinity( + Thread_Control *thread, + size_t cpusetsize, + cpu_set_t *cpuset +); + +/** + * This structure handles affinity specific data of a thread. + * + * @note The attribute priority_sched_info must remain + * the first element in the structure so that the + * Scheduler_priority_XXX methods will continue to + * function. + */ +typedef struct { + + /** + * Data for the Priority Scheduler. + */ + Scheduler_priority_Per_thread Priority_sched_info; + + /** + * Pointer to corresponding Thread Control Block. + */ + Thread_Control *thread; + + /** + * Structure containing affinity set data and size + */ + CPU_set_Control Affinity; +} Scheduler_priority_affinity_SMP_Per_thread; + +/** @} */ + +#ifdef __cplusplus +} +#endif /* __cplusplus */ + +#endif /* _RTEMS_SCORE_SCHEDULERPRIORITYSMP_H */ diff --git a/cpukit/score/preinstall.am b/cpukit/score/preinstall.am index 68ded43c0b..efbe37dbfc 100644 --- a/cpukit/score/preinstall.am +++ b/cpukit/score/preinstall.am @@ -386,6 +386,10 @@ $(PROJECT_INCLUDE)/rtems/score/cpustdatomic.h: include/rtems/score/cpustdatomic. $(INSTALL_DATA) $< $(PROJECT_INCLUDE)/rtems/score/cpustdatomic.h PREINSTALL_FILES += $(PROJECT_INCLUDE)/rtems/score/cpustdatomic.h +$(PROJECT_INCLUDE)/rtems/score/schedulerpriorityaffinitysmp.h: include/rtems/score/schedulerpriorityaffinitysmp.h $(PROJECT_INCLUDE)/rtems/score/$(dirstamp) + $(INSTALL_DATA) $< $(PROJECT_INCLUDE)/rtems/score/schedulerpriorityaffinitysmp.h +PREINSTALL_FILES += $(PROJECT_INCLUDE)/rtems/score/schedulerpriorityaffinitysmp.h + $(PROJECT_INCLUDE)/rtems/score/schedulersimplesmp.h: include/rtems/score/schedulersimplesmp.h $(PROJECT_INCLUDE)/rtems/score/$(dirstamp) $(INSTALL_DATA) $< $(PROJECT_INCLUDE)/rtems/score/schedulersimplesmp.h PREINSTALL_FILES += $(PROJECT_INCLUDE)/rtems/score/schedulersimplesmp.h diff --git a/cpukit/score/src/schedulerpriorityaffinitysmp.c b/cpukit/score/src/schedulerpriorityaffinitysmp.c new file mode 100644 index 0000000000..6d7dd3b7d9 --- /dev/null +++ b/cpukit/score/src/schedulerpriorityaffinitysmp.c @@ -0,0 +1,80 @@ +/** + * @file + * + * @brief Deterministic Priority Affinity SMP Scheduler Implementation + * + * @ingroup ScoreSchedulerPriorityAffinitySMP + */ + +/* + * COPYRIGHT (c) 2014. + * On-Line Applications Research Corporation (OAR). + * + * The license and distribution terms for this file may be + * found in the file LICENSE in this distribution or at + * http://www.rtems.org/license/LICENSE. + */ + +#if HAVE_CONFIG_H + #include "config.h" +#endif + +#include <rtems/score/schedulerpriorityaffinitysmp.h> +#include <rtems/score/schedulerpriorityimpl.h> +#include <rtems/score/schedulersmpimpl.h> +#include <rtems/score/wkspace.h> +#include <rtems/score/cpusetimpl.h> + +RTEMS_INLINE_ROUTINE Scheduler_priority_affinity_SMP_Per_thread * +_Scheduler_priority_affinity_Get_scheduler_info( Thread_Control *thread ) +{ + return ( Scheduler_priority_affinity_SMP_Per_thread * ) thread->scheduler_info; +} + +void * _Scheduler_priority_affinity_SMP_Allocate( Thread_Control *the_thread ) +{ + Scheduler_priority_affinity_SMP_Per_thread *info = + _Workspace_Allocate( sizeof( *info ) ); + + info->Affinity = *_CPU_set_Default(); + info->Affinity.set = &info->Affinity.preallocated; + + the_thread->scheduler_info = info; + + return info; +} + +bool _Scheduler_priority_affinity_SMP_Get_affinity( + Thread_Control *thread, + size_t cpusetsize, + cpu_set_t *cpuset +) +{ + Scheduler_priority_affinity_SMP_Per_thread *info = + _Scheduler_priority_affinity_Get_scheduler_info(thread); + + if ( info->Affinity.setsize != cpusetsize ) { + return false; + } + + CPU_COPY( cpuset, info->Affinity.set ); + return true; +} + +bool _Scheduler_priority_affinity_SMP_Set_affinity( + Thread_Control *thread, + size_t cpusetsize, + cpu_set_t *cpuset +) +{ + Scheduler_priority_affinity_SMP_Per_thread *info = + _Scheduler_priority_affinity_Get_scheduler_info(thread); + + if ( ! _CPU_set_Is_valid( cpuset, cpusetsize ) ) { + return false; + } + + CPU_COPY( info->Affinity.set, cpuset ); + + return true; +} |