[PATCH 03/10] posix: Use _Objects_Get_local() for semaphores

Sebastian Huber sebastian.huber at embedded-brains.de
Thu Apr 21 07:20:07 UTC 2016


This simplifies the code since the object location is no longer used.
Remove superfluous header includes.
---
 cpukit/posix/include/rtems/posix/semaphoreimpl.h | 11 ++---
 cpukit/posix/src/semaphorewaitsupp.c             | 60 +++++++++---------------
 cpukit/posix/src/semclose.c                      | 40 ++++++----------
 cpukit/posix/src/semdestroy.c                    | 51 ++++++++------------
 cpukit/posix/src/semgetvalue.c                   | 45 +++++-------------
 cpukit/posix/src/sempost.c                       | 44 +++++------------
 6 files changed, 83 insertions(+), 168 deletions(-)

diff --git a/cpukit/posix/include/rtems/posix/semaphoreimpl.h b/cpukit/posix/include/rtems/posix/semaphoreimpl.h
index d726761..6ec8480 100644
--- a/cpukit/posix/include/rtems/posix/semaphoreimpl.h
+++ b/cpukit/posix/include/rtems/posix/semaphoreimpl.h
@@ -60,17 +60,14 @@ RTEMS_INLINE_ROUTINE void _POSIX_Semaphore_Free (
   _Objects_Free( &_POSIX_Semaphore_Information, &the_semaphore->Object );
 }
 
-RTEMS_INLINE_ROUTINE POSIX_Semaphore_Control *
-_POSIX_Semaphore_Get_interrupt_disable(
-  sem_t             *id,
-  Objects_Locations *location,
+RTEMS_INLINE_ROUTINE POSIX_Semaphore_Control *_POSIX_Semaphore_Get(
+  const sem_t       *id,
   ISR_lock_Context  *lock_context
 )
 {
-  return (POSIX_Semaphore_Control *) _Objects_Get_isr_disable(
+  return (POSIX_Semaphore_Control *) _Objects_Get_local(
+    (Objects_Id) *id,
     &_POSIX_Semaphore_Information,
-    (Objects_Id)*id,
-    location,
     lock_context
   );
 }
diff --git a/cpukit/posix/src/semaphorewaitsupp.c b/cpukit/posix/src/semaphorewaitsupp.c
index cf8fe63..84ebe3d 100644
--- a/cpukit/posix/src/semaphorewaitsupp.c
+++ b/cpukit/posix/src/semaphorewaitsupp.c
@@ -18,18 +18,10 @@
 #include "config.h"
 #endif
 
-#include <stdarg.h>
-
-#include <errno.h>
-#include <fcntl.h>
-#include <pthread.h>
 #include <semaphore.h>
-#include <limits.h>
 
-#include <rtems/system.h>
-#include <rtems/score/threadimpl.h>
 #include <rtems/posix/semaphoreimpl.h>
-#include <rtems/seterr.h>
+#include <rtems/score/threadimpl.h>
 
 THREAD_WAIT_QUEUE_OBJECT_ASSERT(
   POSIX_Semaphore_Control,
@@ -43,43 +35,33 @@ int _POSIX_Semaphore_Wait_support(
 )
 {
   POSIX_Semaphore_Control *the_semaphore;
-  Objects_Locations        location;
   Thread_Control          *executing;
   ISR_lock_Context         lock_context;
 
-  the_semaphore = _POSIX_Semaphore_Get_interrupt_disable(
-    sem,
-    &location,
-    &lock_context
-  );
-  switch ( location ) {
+  the_semaphore = _POSIX_Semaphore_Get( sem, &lock_context );
 
-    case OBJECTS_LOCAL:
-      executing = _Thread_Executing;
-      _CORE_semaphore_Seize(
-        &the_semaphore->Semaphore,
-        executing,
-        the_semaphore->Object.id,
-        blocking,
-        timeout,
-        &lock_context
-      );
+  if ( the_semaphore == NULL ) {
+    rtems_set_errno_and_return_minus_one( EINVAL );
+  }
 
-      if ( !executing->Wait.return_code )
-        return 0;
+  executing = _Thread_Executing;
 
-      rtems_set_errno_and_return_minus_one(
-        _POSIX_Semaphore_Translate_core_semaphore_return_code(
-          executing->Wait.return_code
-        )
-      );
+  _CORE_semaphore_Seize(
+    &the_semaphore->Semaphore,
+    executing,
+    the_semaphore->Object.id,
+    blocking,
+    timeout,
+    &lock_context
+  );
 
-#if defined(RTEMS_MULTIPROCESSING)
-    case OBJECTS_REMOTE:
-#endif
-    case OBJECTS_ERROR:
-      break;
+  if ( executing->Wait.return_code == CORE_SEMAPHORE_STATUS_SUCCESSFUL ) {
+    return 0;
   }
 
-  rtems_set_errno_and_return_minus_one( EINVAL );
+  rtems_set_errno_and_return_minus_one(
+    _POSIX_Semaphore_Translate_core_semaphore_return_code(
+      executing->Wait.return_code
+    )
+  );
 }
diff --git a/cpukit/posix/src/semclose.c b/cpukit/posix/src/semclose.c
index 1468c7f..3f18ff1 100644
--- a/cpukit/posix/src/semclose.c
+++ b/cpukit/posix/src/semclose.c
@@ -26,36 +26,24 @@ int sem_close(
   sem_t *sem
 )
 {
-  POSIX_Semaphore_Control          *the_semaphore;
-  Objects_Locations                 location;
-  ISR_lock_Context                  lock_context;
+  POSIX_Semaphore_Control *the_semaphore;
+  ISR_lock_Context         lock_context;
 
   _Objects_Allocator_lock();
-  the_semaphore = _POSIX_Semaphore_Get_interrupt_disable(
-    sem,
-    &location,
+  the_semaphore = _POSIX_Semaphore_Get( sem, &lock_context );
+
+  if ( the_semaphore == NULL ) {
+    _Objects_Allocator_unlock();
+    rtems_set_errno_and_return_minus_one( EINVAL );
+  }
+
+  _CORE_semaphore_Acquire_critical(
+    &the_semaphore->Semaphore,
     &lock_context
   );
-  switch ( location ) {
-
-    case OBJECTS_LOCAL:
-      _CORE_semaphore_Acquire_critical(
-        &the_semaphore->Semaphore,
-        &lock_context
-      );
-      the_semaphore->open_count -= 1;
-      _POSIX_Semaphore_Delete( the_semaphore, &lock_context );
-      _Objects_Allocator_unlock();
-      return 0;
-
-#if defined(RTEMS_MULTIPROCESSING)
-    case OBJECTS_REMOTE:
-#endif
-    case OBJECTS_ERROR:
-      break;
-  }
+  the_semaphore->open_count -= 1;
+  _POSIX_Semaphore_Delete( the_semaphore, &lock_context );
 
   _Objects_Allocator_unlock();
-
-  rtems_set_errno_and_return_minus_one( EINVAL );
+  return 0;
 }
diff --git a/cpukit/posix/src/semdestroy.c b/cpukit/posix/src/semdestroy.c
index 7511699..5264472 100644
--- a/cpukit/posix/src/semdestroy.c
+++ b/cpukit/posix/src/semdestroy.c
@@ -26,44 +26,31 @@ int sem_destroy(
   sem_t *sem
 )
 {
-  POSIX_Semaphore_Control          *the_semaphore;
-  Objects_Locations                 location;
-  ISR_lock_Context                  lock_context;
+  POSIX_Semaphore_Control *the_semaphore;
+  ISR_lock_Context         lock_context;
 
   _Objects_Allocator_lock();
-  the_semaphore = _POSIX_Semaphore_Get_interrupt_disable(
-    sem,
-    &location,
-    &lock_context
-  );
-  switch ( location ) {
+  the_semaphore = _POSIX_Semaphore_Get( sem, &lock_context );
 
-    case OBJECTS_LOCAL:
-      _CORE_semaphore_Acquire_critical(
-        &the_semaphore->Semaphore,
-        &lock_context
-      );
+  if ( the_semaphore == NULL ) {
+    _Objects_Allocator_unlock();
+    rtems_set_errno_and_return_minus_one( EINVAL );
+  }
 
-      /*
-       *  Undefined operation on a named semaphore. Release the object
-       *  and fall to the EINVAL return at the bottom.
-       */
-      if ( the_semaphore->named ) {
-        _CORE_semaphore_Release( &the_semaphore->Semaphore, &lock_context );
-      } else {
-        _POSIX_Semaphore_Delete( the_semaphore, &lock_context );
-        _Objects_Allocator_unlock();
-        return 0;
-      }
+  _CORE_semaphore_Acquire_critical(
+    &the_semaphore->Semaphore,
+    &lock_context
+  );
 
-#if defined(RTEMS_MULTIPROCESSING)
-    case OBJECTS_REMOTE:
-#endif
-    case OBJECTS_ERROR:
-      break;
+  if ( the_semaphore->named ) {
+    /* Undefined operation on a named semaphore */
+    _CORE_semaphore_Release( &the_semaphore->Semaphore, &lock_context );
+    _Objects_Allocator_unlock();
+    rtems_set_errno_and_return_minus_one( EINVAL );
   }
 
-  _Objects_Allocator_unlock();
+  _POSIX_Semaphore_Delete( the_semaphore, &lock_context );
 
-  rtems_set_errno_and_return_minus_one( EINVAL );
+  _Objects_Allocator_unlock();
+  return 0;
 }
diff --git a/cpukit/posix/src/semgetvalue.c b/cpukit/posix/src/semgetvalue.c
index f895266..63e3823 100644
--- a/cpukit/posix/src/semgetvalue.c
+++ b/cpukit/posix/src/semgetvalue.c
@@ -18,49 +18,30 @@
 #include "config.h"
 #endif
 
-#include <stdarg.h>
-
-#include <errno.h>
-#include <fcntl.h>
-#include <pthread.h>
 #include <semaphore.h>
-#include <limits.h>
 
-#include <rtems/system.h>
 #include <rtems/posix/semaphoreimpl.h>
-#include <rtems/seterr.h>
 
 int sem_getvalue(
   sem_t  *__restrict sem,
   int    *__restrict sval
 )
 {
-  POSIX_Semaphore_Control          *the_semaphore;
-  Objects_Locations                 location;
-  ISR_lock_Context                  lock_context;
-
-  the_semaphore = _POSIX_Semaphore_Get_interrupt_disable(
-    sem,
-    &location,
-    &lock_context
-  );
-  switch ( location ) {
+  POSIX_Semaphore_Control *the_semaphore;
+  ISR_lock_Context         lock_context;
 
-    case OBJECTS_LOCAL:
-      /*
-       * Assume a relaxed atomic load of the value on SMP configurations.
-       * Thus, there is no need to acquire a lock.
-       */
-      *sval = _CORE_semaphore_Get_count( &the_semaphore->Semaphore );
-      _ISR_lock_ISR_enable( &lock_context );
-      return 0;
+  the_semaphore = _POSIX_Semaphore_Get( sem, &lock_context );
 
-#if defined(RTEMS_MULTIPROCESSING)
-    case OBJECTS_REMOTE:
-#endif
-    case OBJECTS_ERROR:
-      break;
+  if ( the_semaphore == NULL ) {
+    rtems_set_errno_and_return_minus_one( EINVAL );
   }
 
-  rtems_set_errno_and_return_minus_one( EINVAL );
+  /*
+   * Assume a relaxed atomic load of the value on SMP configurations.
+   * Thus, there is no need to acquire a lock.
+   */
+  *sval = _CORE_semaphore_Get_count( &the_semaphore->Semaphore );
+
+  _ISR_lock_ISR_enable( &lock_context );
+  return 0;
 }
diff --git a/cpukit/posix/src/sempost.c b/cpukit/posix/src/sempost.c
index 8e8cce9..13c0132 100644
--- a/cpukit/posix/src/sempost.c
+++ b/cpukit/posix/src/sempost.c
@@ -18,48 +18,28 @@
 #include "config.h"
 #endif
 
-#include <stdarg.h>
-
-#include <errno.h>
-#include <fcntl.h>
-#include <pthread.h>
 #include <semaphore.h>
-#include <limits.h>
 
-#include <rtems/system.h>
 #include <rtems/posix/semaphoreimpl.h>
-#include <rtems/seterr.h>
 
 int sem_post(
   sem_t  *sem
 )
 {
-  POSIX_Semaphore_Control          *the_semaphore;
-  Objects_Locations                 location;
-  ISR_lock_Context                  lock_context;
-
-  the_semaphore = _POSIX_Semaphore_Get_interrupt_disable(
-    sem,
-    &location,
-    &lock_context
-  );
-  switch ( location ) {
+  POSIX_Semaphore_Control *the_semaphore;
+  ISR_lock_Context         lock_context;
 
-    case OBJECTS_LOCAL:
-      _CORE_semaphore_Surrender(
-        &the_semaphore->Semaphore,
-        NULL,
-        0,
-        &lock_context
-      );
-      return 0;
+  the_semaphore = _POSIX_Semaphore_Get( sem, &lock_context );
 
-#if defined(RTEMS_MULTIPROCESSING)
-    case OBJECTS_REMOTE:
-#endif
-    case OBJECTS_ERROR:
-      break;
+  if ( the_semaphore == NULL ) {
+    rtems_set_errno_and_return_minus_one( EINVAL );
   }
 
-  rtems_set_errno_and_return_minus_one( EINVAL );
+  _CORE_semaphore_Surrender(
+    &the_semaphore->Semaphore,
+    NULL,
+    0,
+    &lock_context
+  );
+  return 0;
 }
-- 
1.8.4.5




More information about the devel mailing list