[PATCH 01/12] Add RTEMS thread API
Gedare Bloom
gedare at rtems.org
Thu Dec 21 15:49:18 UTC 2017
I don't quite understand why this is called 'thread', when everything
appears to be synchronization related.
On Thu, Dec 21, 2017 at 9:09 AM, Sebastian Huber
<sebastian.huber at embedded-brains.de> wrote:
> Update #2843.
> ---
> cpukit/Makefile.am | 1 +
> cpukit/include/rtems/thread.h | 280 +++++++++++++++++++++++++++
> cpukit/preinstall.am | 4 +
> cpukit/score/src/semaphore.c | 99 +++++++++-
> testsuites/sptests/Makefile.am | 1 +
> testsuites/sptests/configure.ac | 1 +
> testsuites/sptests/spthread01/Makefile.am | 19 ++
> testsuites/sptests/spthread01/init.c | 249 ++++++++++++++++++++++++
> testsuites/sptests/spthread01/spthread01.doc | 11 ++
> testsuites/sptests/spthread01/spthread01.scn | 0
> 10 files changed, 662 insertions(+), 3 deletions(-)
> create mode 100644 cpukit/include/rtems/thread.h
> create mode 100644 testsuites/sptests/spthread01/Makefile.am
> create mode 100644 testsuites/sptests/spthread01/init.c
> create mode 100644 testsuites/sptests/spthread01/spthread01.doc
> create mode 100644 testsuites/sptests/spthread01/spthread01.scn
>
> diff --git a/cpukit/Makefile.am b/cpukit/Makefile.am
> index d317fbba1c..3c149696ed 100644
> --- a/cpukit/Makefile.am
> +++ b/cpukit/Makefile.am
> @@ -258,6 +258,7 @@ include_rtems_HEADERS += libmisc/untar/untar.h
> ## fsmount
> include_rtems_HEADERS += libmisc/fsmount/fsmount.h
>
> +include_rtems_HEADERS += include/rtems/thread.h
> include_rtems_HEADERS += include/rtems/tm27-default.h
>
> ## Driver manager
> diff --git a/cpukit/include/rtems/thread.h b/cpukit/include/rtems/thread.h
> new file mode 100644
> index 0000000000..e1c47c5703
> --- /dev/null
> +++ b/cpukit/include/rtems/thread.h
> @@ -0,0 +1,280 @@
> +/*
> + * Copyright (c) 2017 embedded brains GmbH. All rights reserved.
> + *
> + * embedded brains GmbH
> + * Dornierstr. 4
> + * 82178 Puchheim
> + * Germany
> + * <rtems at embedded-brains.de>
> + *
> + * 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_THREAD_H
> +#define _RTEMS_THREAD_H
> +
> +#include <sys/lock.h>
> +#include <errno.h>
> +#include <stdint.h>
> +
> +__BEGIN_DECLS
> +
> +typedef struct _Mutex_Control rtems_mutex;
> +
> +#define RTEMS_MUTEX_INITIALIZER( name ) _MUTEX_NAMED_INITIALIZER( name )
> +
> +static __inline void rtems_mutex_init( rtems_mutex *mutex, const char *name )
> +{
> + _Mutex_Initialize_named( mutex, name );
> +}
> +
> +static __inline const char *rtems_mutex_get_name( const rtems_mutex *mutex )
> +{
> + return mutex->_Queue._name;
> +}
> +
> +static __inline void rtems_mutex_set_name( rtems_mutex *mutex, const char *name )
> +{
> + mutex->_Queue._name = name;
> +}
> +
> +static __inline void rtems_mutex_lock( rtems_mutex *mutex )
> +{
> + _Mutex_Acquire( mutex );
> +}
> +
> +static __inline void rtems_mutex_unlock( rtems_mutex *mutex )
> +{
> + _Mutex_Release( mutex );
> +}
> +
> +static __inline void rtems_mutex_destroy( rtems_mutex *mutex )
> +{
> + _Mutex_Destroy( mutex );
> +}
> +
> +typedef struct _Mutex_recursive_Control rtems_recursive_mutex;
> +
> +#define RTEMS_RECURSIVE_MUTEX_INITIALIZER( name ) \
> + _MUTEX_RECURSIVE_NAMED_INITIALIZER( name )
> +
> +static __inline void rtems_recursive_mutex_init(
> + rtems_recursive_mutex *mutex, const char *name
> +)
> +{
> + _Mutex_recursive_Initialize_named( mutex, name );
> +}
> +
> +static __inline const char *rtems_recursive_mutex_get_name(
> + const rtems_recursive_mutex *mutex
> +)
> +{
> + return mutex->_Mutex._Queue._name;
> +}
> +
> +static __inline void rtems_recursive_mutex_set_name(
> + rtems_recursive_mutex *mutex, const char *name
> +)
> +{
> + mutex->_Mutex._Queue._name = name;
> +}
> +
> +static __inline void rtems_recursive_mutex_lock(
> + rtems_recursive_mutex *mutex
> +)
> +{
> + _Mutex_recursive_Acquire( mutex );
> +}
> +
> +static __inline void rtems_recursive_mutex_unlock(
> + rtems_recursive_mutex *mutex
> +)
> +{
> + _Mutex_recursive_Release( mutex );
> +}
> +
> +static __inline void rtems_recursive_mutex_destroy(
> + rtems_recursive_mutex *mutex
> +)
> +{
> + _Mutex_recursive_Destroy( mutex );
> +}
> +
> +typedef struct _Condition_Control rtems_condition_variable;
> +
> +#define RTEMS_CONDITION_VARIABLE_INITIALIZER( name ) \
> + _CONDITION_NAMED_INITIALIZER( name )
> +
> +static __inline void rtems_condition_variable_init(
> + rtems_condition_variable *condition_variable,
> + const char *name
> +)
> +{
> + _Condition_Initialize_named( condition_variable, name );
> +}
> +
> +static __inline const char *rtems_condition_variable_get_name(
> + const rtems_condition_variable *condition_variable
> +)
> +{
> + return condition_variable->_Queue._name;
> +}
> +
> +static __inline void rtems_condition_variable_set_name(
> + rtems_condition_variable *condition_variable,
> + const char *name
> +)
> +{
> + condition_variable->_Queue._name = name;
> +}
> +
> +static __inline void rtems_condition_variable_wait(
> + rtems_condition_variable *condition_variable,
> + rtems_mutex *mutex
> +)
> +{
> + _Condition_Wait( condition_variable, mutex );
> +}
> +
> +static __inline void rtems_condition_variable_signal(
> + rtems_condition_variable *condition_variable
> +)
> +{
> + _Condition_Broadcast( condition_variable );
> +}
> +
> +static __inline void rtems_condition_variable_broadcast(
> + rtems_condition_variable *condition_variable
> +)
> +{
> + _Condition_Broadcast( condition_variable );
> +}
> +
> +static __inline void rtems_condition_variable_destroy(
> + rtems_condition_variable *condition_variable
> +)
> +{
> + _Condition_Destroy( condition_variable );
> +}
> +
> +typedef struct _Semaphore_Control rtems_counting_semaphore;
> +
> +#define RTEMS_COUNTING_SEMAPHORE_INITIALIZER( name, value ) \
> + _SEMAPHORE_NAMED_INITIALIZER( name, value )
> +
> +static __inline void rtems_counting_semaphore_init(
> + rtems_counting_semaphore *counting_semaphore,
> + const char *name,
> + unsigned int value
> +)
> +{
> + _Semaphore_Initialize_named( counting_semaphore, name, value );
> +}
> +
> +static __inline const char *rtems_counting_semaphore_get_name(
> + const rtems_counting_semaphore *counting_semaphore
> +)
> +{
> + return counting_semaphore->_Queue._name;
> +}
> +
> +static __inline void rtems_counting_semaphore_set_name(
> + rtems_counting_semaphore *counting_semaphore,
> + const char *name
> +)
> +{
> + counting_semaphore->_Queue._name = name;
> +}
> +
> +static __inline void rtems_counting_semaphore_wait(
> + rtems_counting_semaphore *counting_semaphore
> +)
> +{
> + _Semaphore_Wait( counting_semaphore );
> +}
> +
> +static __inline void rtems_counting_semaphore_post(
> + rtems_counting_semaphore *counting_semaphore
> +)
> +{
> + _Semaphore_Post( counting_semaphore );
> +}
> +
> +static __inline void rtems_counting_semaphore_destroy(
> + rtems_counting_semaphore *counting_semaphore
> +)
> +{
> + _Semaphore_Destroy( counting_semaphore );
> +}
> +
> +typedef struct {
> + struct _Semaphore_Control Semaphore;
> +} rtems_binary_semaphore;
> +
> +#define RTEMS_BINARY_SEMAPHORE_INITIALIZER( name ) \
> + { _SEMAPHORE_NAMED_INITIALIZER( name, 0 ) }
> +
> +static __inline void rtems_binary_semaphore_init(
> + rtems_binary_semaphore *binary_semaphore,
> + const char *name
> +)
> +{
> + _Semaphore_Initialize_named( &binary_semaphore->Semaphore, name, 0 );
> +}
> +
> +static __inline const char *rtems_binary_semaphore_get_name(
> + const rtems_binary_semaphore *binary_semaphore
> +)
> +{
> + return binary_semaphore->Semaphore._Queue._name;
> +}
> +
> +static __inline void rtems_binary_semaphore_set_name(
> + rtems_binary_semaphore *binary_semaphore,
> + const char *name
> +)
> +{
> + binary_semaphore->Semaphore._Queue._name = name;
> +}
> +
> +static __inline void rtems_binary_semaphore_wait(
> + rtems_binary_semaphore *binary_semaphore
> +)
> +{
> + _Semaphore_Wait( &binary_semaphore->Semaphore );
> +}
> +
> +static __inline int rtems_binary_semaphore_wait_timed_ticks(
> + rtems_binary_semaphore *binary_semaphore,
> + uint32_t ticks
> +)
> +{
> + return _Semaphore_Wait_timed_ticks( &binary_semaphore->Semaphore, ticks );
> +}
> +
> +static __inline int rtems_binary_semaphore_try_wait(
> + rtems_binary_semaphore *binary_semaphore
> +)
> +{
> + return _Semaphore_Try_wait( &binary_semaphore->Semaphore );
> +}
> +
> +static __inline void rtems_binary_semaphore_post(
> + rtems_binary_semaphore *binary_semaphore
> +)
> +{
> + _Semaphore_Post_binary( &binary_semaphore->Semaphore );
> +}
> +
> +static __inline void rtems_binary_semaphore_destroy(
> + rtems_binary_semaphore *binary_semaphore
> +)
> +{
> + _Semaphore_Destroy( &binary_semaphore->Semaphore );
> +}
> +
> +__END_DECLS
> +
> +#endif /* _RTEMS_THREAD_H */
> diff --git a/cpukit/preinstall.am b/cpukit/preinstall.am
> index fd26535031..d347e94593 100644
> --- a/cpukit/preinstall.am
> +++ b/cpukit/preinstall.am
> @@ -565,6 +565,10 @@ $(PROJECT_INCLUDE)/rtems/fsmount.h: libmisc/fsmount/fsmount.h $(PROJECT_INCLUDE)
> $(INSTALL_DATA) $< $(PROJECT_INCLUDE)/rtems/fsmount.h
> PREINSTALL_FILES += $(PROJECT_INCLUDE)/rtems/fsmount.h
>
> +$(PROJECT_INCLUDE)/rtems/thread.h: include/rtems/thread.h $(PROJECT_INCLUDE)/rtems/$(dirstamp)
> + $(INSTALL_DATA) $< $(PROJECT_INCLUDE)/rtems/thread.h
> +PREINSTALL_FILES += $(PROJECT_INCLUDE)/rtems/thread.h
> +
> $(PROJECT_INCLUDE)/rtems/tm27-default.h: include/rtems/tm27-default.h $(PROJECT_INCLUDE)/rtems/$(dirstamp)
> $(INSTALL_DATA) $< $(PROJECT_INCLUDE)/rtems/tm27-default.h
> PREINSTALL_FILES += $(PROJECT_INCLUDE)/rtems/tm27-default.h
> diff --git a/cpukit/score/src/semaphore.c b/cpukit/score/src/semaphore.c
> index 4edd25a387..f76ee332a4 100644
> --- a/cpukit/score/src/semaphore.c
> +++ b/cpukit/score/src/semaphore.c
> @@ -1,5 +1,5 @@
> /*
> - * Copyright (c) 2015 embedded brains GmbH. All rights reserved.
> + * Copyright (c) 2015, 2017 embedded brains GmbH. All rights reserved.
> *
> * embedded brains GmbH
> * Dornierstr. 4
> @@ -18,8 +18,9 @@
>
> #include <rtems/score/semaphoreimpl.h>
> #include <rtems/score/statesimpl.h>
> +#include <rtems/score/threadimpl.h>
>
> -#include <limits.h>
> +#include <errno.h>
>
> RTEMS_STATIC_ASSERT(
> offsetof( Sem_Control, Queue )
> @@ -71,6 +72,66 @@ void _Semaphore_Wait( struct _Semaphore_Control *_sem )
> }
> }
>
> +int _Semaphore_Wait_timed_ticks( struct _Semaphore_Control *_sem, uint32_t ticks )
> +{
> + Sem_Control *sem;
> + ISR_Level level;
> + Thread_queue_Context queue_context;
> + Thread_Control *executing;
> + unsigned int count;
> +
> + sem = _Sem_Get( _sem );
> + _Thread_queue_Context_initialize( &queue_context );
> + _Thread_queue_Context_ISR_disable( &queue_context, level );
> + executing = _Sem_Queue_acquire_critical( sem, &queue_context );
> +
> + count = sem->count;
> + if ( __predict_true( count > 0 ) ) {
> + sem->count = count - 1;
> + _Sem_Queue_release( sem, level, &queue_context );
> + return 0;
> + } else {
> + _Thread_queue_Context_set_thread_state(
> + &queue_context,
> + STATES_WAITING_FOR_SEMAPHORE
> + );
> + _Thread_queue_Context_set_enqueue_timeout_ticks( &queue_context, ticks );
> + _Thread_queue_Context_set_ISR_level( &queue_context, level );
> + _Thread_queue_Enqueue(
> + &sem->Queue.Queue,
> + SEMAPHORE_TQ_OPERATIONS,
> + executing,
> + &queue_context
> + );
> + return STATUS_GET_POSIX( _Thread_Wait_get_status( executing ) );
> + }
> +}
> +
> +int _Semaphore_Try_wait( struct _Semaphore_Control *_sem )
> +{
> + Sem_Control *sem;
> + ISR_Level level;
> + Thread_queue_Context queue_context;
> + unsigned int count;
> + int eno;
> +
> + sem = _Sem_Get( _sem );
> + _Thread_queue_Context_initialize( &queue_context );
> + _Thread_queue_Context_ISR_disable( &queue_context, level );
> + _Sem_Queue_acquire_critical( sem, &queue_context );
> +
> + count = sem->count;
> + if ( __predict_true( count > 0 ) ) {
> + sem->count = count - 1;
> + eno = 0;
> + } else {
> + eno = EAGAIN;
> + }
> +
> + _Sem_Queue_release( sem, level, &queue_context );
> + return eno;
> +}
> +
> void _Semaphore_Post( struct _Semaphore_Control *_sem )
> {
> Sem_Control *sem;
> @@ -85,7 +146,6 @@ void _Semaphore_Post( struct _Semaphore_Control *_sem )
>
> heads = sem->Queue.Queue.heads;
> if ( __predict_true( heads == NULL ) ) {
> - _Assert( sem->count < UINT_MAX );
> ++sem->count;
> _Sem_Queue_release( sem, level, &queue_context );
> } else {
> @@ -104,3 +164,36 @@ void _Semaphore_Post( struct _Semaphore_Control *_sem )
> );
> }
> }
> +
> +void _Semaphore_Post_binary( struct _Semaphore_Control *_sem )
> +{
> + Sem_Control *sem;
> + ISR_Level level;
> + Thread_queue_Context queue_context;
> + Thread_queue_Heads *heads;
> +
> + sem = _Sem_Get( _sem );
> + _Thread_queue_Context_initialize( &queue_context );
> + _Thread_queue_Context_ISR_disable( &queue_context, level );
> + _Sem_Queue_acquire_critical( sem, &queue_context );
> +
> + heads = sem->Queue.Queue.heads;
> + if ( __predict_true( heads == NULL ) ) {
> + sem->count = 1;
> + _Sem_Queue_release( sem, level, &queue_context );
> + } else {
> + const Thread_queue_Operations *operations;
> + Thread_Control *first;
> +
> + _Thread_queue_Context_set_ISR_level( &queue_context, level );
> + operations = SEMAPHORE_TQ_OPERATIONS;
> + first = ( *operations->first )( heads );
> +
> + _Thread_queue_Extract_critical(
> + &sem->Queue.Queue,
> + operations,
> + first,
> + &queue_context
> + );
> + }
> +}
> diff --git a/testsuites/sptests/Makefile.am b/testsuites/sptests/Makefile.am
> index 00f7571902..561d2d73e0 100644
> --- a/testsuites/sptests/Makefile.am
> +++ b/testsuites/sptests/Makefile.am
> @@ -33,6 +33,7 @@ _SUBDIRS = \
> spsignal_err01 spport_err01 spmsgq_err01 spmsgq_err02 spsem_err01 \
> spsem_err02 sptask_err01 spevent_err03 sptask_err03 sptask_err02 \
> sptask_err04 spclock_err01
> +_SUBDIRS += spthread01
> _SUBDIRS += spconsole01
> _SUBDIRS += spintrcritical24
> _SUBDIRS += spfatal29
> diff --git a/testsuites/sptests/configure.ac b/testsuites/sptests/configure.ac
> index 6a303b25c5..84619282b9 100644
> --- a/testsuites/sptests/configure.ac
> +++ b/testsuites/sptests/configure.ac
> @@ -36,6 +36,7 @@ AM_CONDITIONAL(HAS_SMP,test "$rtems_cv_RTEMS_SMP" = "yes")
>
> # Explicitly list all Makefiles here
> AC_CONFIG_FILES([Makefile
> +spthread01/Makefile
> sptls04/Makefile
> spconsole01/Makefile
> spintrcritical24/Makefile
> diff --git a/testsuites/sptests/spthread01/Makefile.am b/testsuites/sptests/spthread01/Makefile.am
> new file mode 100644
> index 0000000000..f9e14cb380
> --- /dev/null
> +++ b/testsuites/sptests/spthread01/Makefile.am
> @@ -0,0 +1,19 @@
> +rtems_tests_PROGRAMS = spthread01
> +spthread01_SOURCES = init.c
> +
> +dist_rtems_tests_DATA = spthread01.scn spthread01.doc
> +
> +include $(RTEMS_ROOT)/make/custom/@RTEMS_BSP at .cfg
> +include $(top_srcdir)/../automake/compile.am
> +include $(top_srcdir)/../automake/leaf.am
> +
> +AM_CPPFLAGS += -I$(top_srcdir)/../support/include
> +
> +LINK_OBJS = $(spthread01_OBJECTS)
> +LINK_LIBS = $(spthread01_LDLIBS)
> +
> +spthread01$(EXEEXT): $(spthread01_OBJECTS) $(spthread01_DEPENDENCIES)
> + @rm -f spthread01$(EXEEXT)
> + $(make-exe)
> +
> +include $(top_srcdir)/../automake/local.am
> diff --git a/testsuites/sptests/spthread01/init.c b/testsuites/sptests/spthread01/init.c
> new file mode 100644
> index 0000000000..4c5bfc12e1
> --- /dev/null
> +++ b/testsuites/sptests/spthread01/init.c
> @@ -0,0 +1,249 @@
> +/*
> + * Copyright (c) 2017 embedded brains GmbH. All rights reserved.
> + *
> + * embedded brains GmbH
> + * Dornierstr. 4
> + * 82178 Puchheim
> + * Germany
> + * <rtems at embedded-brains.de>
> + *
> + * The license and distribution terms for this file may be
> + * found in the file LICENSE in this distribution or at
> + * http://www.rtems.com/license/LICENSE.
> + */
> +
> +#ifdef HAVE_CONFIG_H
> +#include "config.h"
> +#endif
> +
> +#include <rtems/thread.h>
> +#include <rtems.h>
> +
> +#include <string.h>
> +
> +#include <tmacros.h>
> +
> +const char rtems_test_name[] = "SPTHREAD 1";
> +
> +static void test_mutex(void)
> +{
> + rtems_mutex a = RTEMS_MUTEX_INITIALIZER("a");
> + const char *name;
> +
> + name = rtems_mutex_get_name(&a);
> + rtems_test_assert(strcmp(name, "a") == 0);
> +
> + rtems_mutex_set_name(&a, "b");
> +
> + name = rtems_mutex_get_name(&a);
> + rtems_test_assert(strcmp(name, "b") == 0);
> +
> + rtems_mutex_destroy(&a);
> +
> + rtems_mutex_init(&a, "c");
> +
> + name = rtems_mutex_get_name(&a);
> + rtems_test_assert(strcmp(name, "c") == 0);
> +
> + rtems_mutex_lock(&a);
> +
> + rtems_mutex_unlock(&a);
> +
> + rtems_mutex_destroy(&a);
> +}
> +
> +static void test_recursive_mutex(void)
> +{
> + rtems_recursive_mutex a = RTEMS_RECURSIVE_MUTEX_INITIALIZER("a");
> + const char *name;
> +
> + name = rtems_recursive_mutex_get_name(&a);
> + rtems_test_assert(strcmp(name, "a") == 0);
> +
> + rtems_recursive_mutex_set_name(&a, "b");
> +
> + name = rtems_recursive_mutex_get_name(&a);
> + rtems_test_assert(strcmp(name, "b") == 0);
> +
> + rtems_recursive_mutex_destroy(&a);
> +
> + rtems_recursive_mutex_init(&a, "c");
> +
> + name = rtems_recursive_mutex_get_name(&a);
> + rtems_test_assert(strcmp(name, "c") == 0);
> +
> + rtems_recursive_mutex_lock(&a);
> +
> + rtems_recursive_mutex_lock(&a);
> +
> + rtems_recursive_mutex_unlock(&a);
> +
> + rtems_recursive_mutex_unlock(&a);
> +
> + rtems_recursive_mutex_destroy(&a);
> +}
> +
> +typedef struct {
> + rtems_mutex mtx;
> + rtems_condition_variable cnd;
> +} signal_context;
> +
> +static void signal_task(rtems_task_argument arg)
> +{
> + signal_context *s;
> +
> + s = (signal_context *) arg;
> + rtems_mutex_lock(&s->mtx);
> + rtems_condition_variable_signal(&s->cnd);
> + rtems_mutex_unlock(&s->mtx);
> +}
> +
> +static void test_condition_variable(void)
> +{
> + rtems_condition_variable a = RTEMS_CONDITION_VARIABLE_INITIALIZER("a");
> + signal_context s;
> + const char *name;
> + rtems_status_code sc;
> + rtems_id id;
> +
> + name = rtems_condition_variable_get_name(&a);
> + rtems_test_assert(strcmp(name, "a") == 0);
> +
> + rtems_condition_variable_set_name(&a, "b");
> +
> + name = rtems_condition_variable_get_name(&a);
> + rtems_test_assert(strcmp(name, "b") == 0);
> +
> + rtems_condition_variable_destroy(&a);
> +
> + rtems_mutex_init(&s.mtx, "d");
> + rtems_condition_variable_init(&s.cnd, "c");
> +
> + name = rtems_condition_variable_get_name(&s.cnd);
> + rtems_test_assert(strcmp(name, "c") == 0);
> +
> + rtems_condition_variable_signal(&s.cnd);
> +
> + rtems_condition_variable_broadcast(&s.cnd);
> +
> + rtems_mutex_lock(&s.mtx);
> +
> + sc = rtems_task_create(
> + rtems_build_name('C', 'O', 'N', 'D'),
> + 2,
> + RTEMS_MINIMUM_STACK_SIZE,
> + RTEMS_DEFAULT_MODES,
> + RTEMS_DEFAULT_ATTRIBUTES,
> + &id
> + );
> + rtems_test_assert(sc == RTEMS_SUCCESSFUL);
> +
> + sc = rtems_task_start(id, signal_task, (rtems_task_argument) &s);
> + rtems_test_assert(sc == RTEMS_SUCCESSFUL);
> +
> + rtems_condition_variable_wait(&s.cnd, &s.mtx);
> +
> + sc = rtems_task_delete(id);
> + rtems_test_assert(sc == RTEMS_SUCCESSFUL);
> +
> + rtems_mutex_unlock(&s.mtx);
> +
> + rtems_condition_variable_destroy(&s.cnd);
> + rtems_mutex_destroy(&s.mtx);
> +}
> +
> +static void test_counting_semaphore(void)
> +{
> + rtems_counting_semaphore a = RTEMS_COUNTING_SEMAPHORE_INITIALIZER("a", 1);
> + const char *name;
> +
> + name = rtems_counting_semaphore_get_name(&a);
> + rtems_test_assert(strcmp(name, "a") == 0);
> +
> + rtems_counting_semaphore_set_name(&a, "b");
> +
> + name = rtems_counting_semaphore_get_name(&a);
> + rtems_test_assert(strcmp(name, "b") == 0);
> +
> + rtems_counting_semaphore_destroy(&a);
> +
> + rtems_counting_semaphore_init(&a, "c", 0);
> +
> + name = rtems_counting_semaphore_get_name(&a);
> + rtems_test_assert(strcmp(name, "c") == 0);
> +
> + rtems_counting_semaphore_post(&a);
> +
> + rtems_counting_semaphore_wait(&a);
> +
> + rtems_counting_semaphore_destroy(&a);
> +}
> +
> +static void test_binary_semaphore(void)
> +{
> + rtems_binary_semaphore a = RTEMS_BINARY_SEMAPHORE_INITIALIZER("a");
> + const char *name;
> + int eno;
> +
> + name = rtems_binary_semaphore_get_name(&a);
> + rtems_test_assert(strcmp(name, "a") == 0);
> +
> + rtems_binary_semaphore_set_name(&a, "b");
> +
> + name = rtems_binary_semaphore_get_name(&a);
> + rtems_test_assert(strcmp(name, "b") == 0);
> +
> + rtems_binary_semaphore_destroy(&a);
> +
> + rtems_binary_semaphore_init(&a, "c");
> +
> + name = rtems_binary_semaphore_get_name(&a);
> + rtems_test_assert(strcmp(name, "c") == 0);
> +
> + eno = rtems_binary_semaphore_try_wait(&a);
> + rtems_test_assert(eno == EAGAIN);
> +
> + eno = rtems_binary_semaphore_wait_timed_ticks(&a, 1);
> + rtems_test_assert(eno == ETIMEDOUT);
> +
> + rtems_binary_semaphore_post(&a);
> +
> + rtems_binary_semaphore_wait(&a);
> +
> + rtems_binary_semaphore_post(&a);
> +
> + eno = rtems_binary_semaphore_try_wait(&a);
> + rtems_test_assert(eno == 0);
> +
> + rtems_binary_semaphore_post(&a);
> +
> + eno = rtems_binary_semaphore_wait_timed_ticks(&a, 1);
> + rtems_test_assert(eno == 0);
> +
> + rtems_binary_semaphore_destroy(&a);
> +}
> +
> +static void Init(rtems_task_argument arg)
> +{
> + TEST_BEGIN();
> +
> + test_mutex();
> + test_recursive_mutex();
> + test_condition_variable();
> + test_counting_semaphore();
> + test_binary_semaphore();
> +
> + TEST_END();
> + rtems_test_exit(0);
> +}
> +
> +#define CONFIGURE_APPLICATION_NEEDS_CLOCK_DRIVER
> +#define CONFIGURE_APPLICATION_NEEDS_SIMPLE_CONSOLE_DRIVER
> +
> +#define CONFIGURE_MAXIMUM_TASKS 2
> +
> +#define CONFIGURE_RTEMS_INIT_TASKS_TABLE
> +
> +#define CONFIGURE_INIT
> +
> +#include <rtems/confdefs.h>
> diff --git a/testsuites/sptests/spthread01/spthread01.doc b/testsuites/sptests/spthread01/spthread01.doc
> new file mode 100644
> index 0000000000..b1cd716cfa
> --- /dev/null
> +++ b/testsuites/sptests/spthread01/spthread01.doc
> @@ -0,0 +1,11 @@
> +This file describes the directives and concepts tested by this test set.
> +
> +test set name: spthread01
> +
> +directives:
> +
> + TBD
> +
> +concepts:
> +
> + TBD
> diff --git a/testsuites/sptests/spthread01/spthread01.scn b/testsuites/sptests/spthread01/spthread01.scn
> new file mode 100644
> index 0000000000..e69de29bb2
> --
> 2.12.3
>
> _______________________________________________
> devel mailing list
> devel at rtems.org
> http://lists.rtems.org/mailman/listinfo/devel
More information about the devel
mailing list