[rtems commit] posix: Add dynamic pthread get and set affinity.
Jennifer Averett
jennifer at rtems.org
Fri Mar 7 15:08:50 UTC 2014
Module: rtems
Branch: master
Commit: dd0017c13510c51d979618c499d501417599abcc
Changeset: http://git.rtems.org/rtems/commit/?id=dd0017c13510c51d979618c499d501417599abcc
Author: Jennifer Averett <jennifer.averett at oarcorp.com>
Date: Mon Feb 10 10:01:31 2014 -0600
posix: Add dynamic pthread get and set affinity.
This patch adds the following methods:
+ pthread_get_affinity_np
+ pthread_set_affinity_np
---
cpukit/posix/Makefile.am | 3 +-
cpukit/posix/src/pthreadgetaffinitynp.c | 68 ++++++++++++++++++++++++++++++
cpukit/posix/src/pthreadsetaffinitynp.c | 69 +++++++++++++++++++++++++++++++
3 files changed, 139 insertions(+), 1 deletions(-)
diff --git a/cpukit/posix/Makefile.am b/cpukit/posix/Makefile.am
index 13f698c..9dc8820 100644
--- a/cpukit/posix/Makefile.am
+++ b/cpukit/posix/Makefile.am
@@ -145,7 +145,8 @@ libposix_a_SOURCES += src/pthreadattrcompare.c
if HAS_SMP
## PTHREAD_AFFINITY_C_FILES
libposix_a_SOURCES += src/pthreadattrsetaffinitynp.c \
- src/pthreadattrgetaffinitynp.c
+ src/pthreadattrgetaffinitynp.c src/pthreadgetaffinitynp.c \
+ src/pthreadsetaffinitynp.c
endif
## PSIGNAL_C_FILES
diff --git a/cpukit/posix/src/pthreadgetaffinitynp.c b/cpukit/posix/src/pthreadgetaffinitynp.c
new file mode 100644
index 0000000..e92f800
--- /dev/null
+++ b/cpukit/posix/src/pthreadgetaffinitynp.c
@@ -0,0 +1,68 @@
+/**
+ * @file
+ *
+ * @brief Pthread Get Affinity
+ * @ingroup POSIXAPI
+ */
+
+/*
+ * 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
+
+#if HAVE_DECL_PTHREAD_GETAFFINITY_NP
+
+#define _GNU_SOURCE
+#include <pthread.h>
+#include <errno.h>
+
+#include <rtems/posix/pthreadimpl.h>
+#include <rtems/posix/priorityimpl.h>
+#include <rtems/score/threadimpl.h>
+
+int pthread_getaffinity_np(
+ const pthread_t id,
+ size_t cpusetsize,
+ cpu_set_t *cpuset
+)
+{
+ Objects_Locations location;
+ Thread_Control *the_thread;
+ int error;
+
+ if ( !cpuset )
+ return EFAULT;
+
+ the_thread = _Thread_Get( id, &location );
+ switch ( location ) {
+
+ case OBJECTS_LOCAL:
+ error = 0;
+ if ( cpusetsize != the_thread->affinity.setsize )
+ error = EINVAL;
+ else
+ CPU_COPY( cpuset, the_thread->affinity.set );
+
+ _Objects_Put( &the_thread->Object );
+ return error;
+ break;
+
+#if defined(RTEMS_MULTIPROCESSING)
+ case OBJECTS_REMOTE:
+#endif
+ case OBJECTS_ERROR:
+ break;
+ }
+ return ESRCH;
+}
+
+#endif
diff --git a/cpukit/posix/src/pthreadsetaffinitynp.c b/cpukit/posix/src/pthreadsetaffinitynp.c
new file mode 100644
index 0000000..f186935
--- /dev/null
+++ b/cpukit/posix/src/pthreadsetaffinitynp.c
@@ -0,0 +1,69 @@
+/**
+ * @file
+ *
+ * @brief Pthread Set Affinity
+ * @ingroup POSIXAPI
+ */
+
+/*
+ * 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
+
+#if HAVE_DECL_PTHREAD_SETAFFINITY_NP
+
+#define _GNU_SOURCE
+#include <pthread.h>
+#include <errno.h>
+
+#include <rtems/posix/pthreadimpl.h>
+#include <rtems/posix/priorityimpl.h>
+#include <rtems/score/threadimpl.h>
+#include <rtems/score/cpusetimpl.h>
+
+int pthread_setaffinity_np(
+ pthread_t id,
+ size_t cpusetsize,
+ const cpu_set_t *cpuset)
+{
+ Objects_Locations location;
+ POSIX_API_Control *api;
+ Thread_Control *the_thread;
+ int error;
+
+ if ( !cpuset )
+ return EFAULT;
+
+ error = _CPU_set_Is_valid( cpuset, cpusetsize );
+ if ( error != 0 )
+ return EINVAL;
+
+ the_thread = _Thread_Get( id, &location );
+ switch ( location ) {
+
+ case OBJECTS_LOCAL:
+ api = the_thread->API_Extensions[ THREAD_API_POSIX ];
+ CPU_COPY( the_thread->affinity.set, cpuset );
+ CPU_COPY( api->Attributes.affinityset, cpuset );
+ _Objects_Put( &the_thread->Object );
+ return 0;
+ break;
+
+#if defined(RTEMS_MULTIPROCESSING)
+ case OBJECTS_REMOTE:
+#endif
+ case OBJECTS_ERROR:
+ break;
+ }
+
+ return ESRCH;
+}
+#endif
More information about the vc
mailing list