revised thread/process priority interface (merged in posix_thread_priority branch)

1 files changed, 245 insertions, 3 deletions

diff --git a/ace/Sched_Params.cpp b/ace/Sched_Params.cpp
index f26eb2b1570..4bd3edcdfb8 100644
--- a/ace/Sched_Params.cpp
+++ b/ace/Sched_Params.cpp
@@ -6,7 +6,7 @@
 //    ACE
 //
 // = FILENAME
-//    Scheduling_Params.cpp
+//    Sched_Params.cpp
 //
 // = CREATION DATE
 //    28 January 1997
@@ -19,9 +19,251 @@
 #define ACE_BUILD_DLL
 
 #include "ace/ACE.h"
-#include "ace/Scheduling_Params.h"
+#include "ace/Sched_Params.h"
 
 #if !defined (__ACE_INLINE__)
-#include "ace/Scheduling_Params.i"
+#include "ace/Sched_Params.i"
 #endif /* __ACE_INLINE__ */
 
+#if defined (ACE_HAS_STHREADS)
+#include <sys/rtpriocntl.h>
+#include <sys/tspriocntl.h>
+#endif /* ACE_HAS_STHREADS */
+
+int
+ACE_Sched_Params::priority_min (const Policy policy,
+                                const int scope)
+{
+#if defined (ACE_HAS_STHREADS)
+  ACE_UNUSED_ARG (scope);
+
+  // Assume that ACE_SCHED_OTHER indicates Solaris TS class, and that
+  // other policies indicate Solaris RT class.
+
+  if (policy == ACE_SCHED_OTHER)
+    {
+      // Get the priority class ID and attributes.
+      pcinfo_t pcinfo;
+      ACE_OS::strcpy (pcinfo.pc_clname, "TS");
+      // The following is just to avoid Purify warnings about unitialized
+      // memory reads.
+      ACE_OS::memset (pcinfo.pc_clinfo, 0, PC_CLINFOSZ);
+
+      if (::priocntl (P_ALL /* ignored */,
+                      P_MYID /* ignored */,
+                      PC_GETCID,
+                      (char *) &pcinfo) == -1)
+        {
+          return -1;  // just hope that priority range wasn't configured
+                      // from -1 .. 1
+        }
+
+      // OK, now we've got the class ID in pcinfo.pc_cid.  In addition,
+      // the maximum configured time-share priority is in ((tsinfo_t *)
+      // pcinfo.pc_clinfo)->ts_maxupri.  The minimum priority is just
+      // the negative of that.
+
+      return -((tsinfo_t *) pcinfo.pc_clinfo)->ts_maxupri;
+    }
+  else
+    {
+      return 0;
+    }
+#elif defined (ACE_HAS_DCETHREADS) || defined(ACE_HAS_PTHREADS)
+
+#if defined (PRI_FIFO_MIN) && defined (PRI_RR_MIN) && defined (PRI_OTHER_MIN)
+  if (scope == ACE_SCOPE_THREAD)
+    {
+      // return the minimal priority of the given policy;
+      // default to ACE_SCHED_OTHER in case of invalid policy value
+      switch (policy)
+        {
+          case ACE_SCHED_FIFO:
+            return PRI_FIFO_MIN;
+          case ACE_SCHED_RR:
+            return PRI_RR_MIN;
+          case ACE_SCHED_OTHER:
+          default:
+            return PRI_OTHER_MIN;
+        }
+    }
+  else
+    {
+      return ::sched_get_priority_min (policy);
+    }
+#else
+  ACE_UNUSED_ARG (scope);
+  return ::sched_get_priority_min (policy);
+#endif /* (PRI_FIFO_MIN && PRI_RR_MIN && PRI_OTHER_MIN */
+
+#elif defined (ACE_HAS_WTHREADS)
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  return THREAD_PRIORITY_IDLE;
+#elif defined (VXWORKS)
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  return 255;
+#elif
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  ACE_NOTSUP_RETURN (-1);
+#endif /* ACE_HAS_STHREADS */
+}
+
+int
+ACE_Sched_Params::priority_max (const Policy policy,
+                                const int scope)
+{
+#if defined (ACE_HAS_STHREADS)
+  ACE_UNUSED_ARG (scope);
+
+  // Assume that ACE_SCHED_OTHER indicates Solaris TS class, and that
+  // other policies indicate Solaris RT class.
+
+  // Get the priority class ID and attributes.
+  pcinfo_t pcinfo;
+  ACE_OS::strcpy (pcinfo.pc_clname,
+                  policy == ACE_SCHED_OTHER  ?  "TS"  :  "RT");
+  // The following is just to avoid Purify warnings about unitialized
+  // memory reads.
+  ACE_OS::memset (pcinfo.pc_clinfo, 0, PC_CLINFOSZ);
+
+  if (::priocntl (P_ALL /* ignored */,
+                  P_MYID /* ignored */,
+                  PC_GETCID,
+                  (char *) &pcinfo) == -1)
+    {
+      return -1;
+    }
+
+  // OK, now we've got the class ID in pcinfo.pc_cid.  In addition,
+  // the maximum configured real-time priority is in ((rtinfo_t *)
+  // pcinfo.pc_clinfo)->rt_maxpri, or similarly for the TS class.
+
+  return policy == ACE_SCHED_OTHER
+      ? ((tsinfo_t *) pcinfo.pc_clinfo)->ts_maxupri
+      : ((rtinfo_t *) pcinfo.pc_clinfo)->rt_maxpri;
+#elif defined (ACE_HAS_DCETHREADS) || defined(ACE_HAS_PTHREADS)
+
+#if defined (PRI_FIFO_MAX) && defined (PRI_RR_MAX) && defined (PRI_OTHER_MAX)
+  if (scope == ACE_SCOPE_THREAD)
+    {
+      // return the maximal priority of the given policy;
+      // default to ACE_SCHED_OTHER in case of invalid policy value
+      switch (policy)
+        {
+          case ACE_SCHED_FIFO:
+            return PRI_FIFO_MAX;
+          case ACE_SCHED_RR:
+            return PRI_RR_MAX;
+          case ACE_SCHED_OTHER:
+          default:
+            return PRI_OTHER_MAX;
+        }
+    }
+  else
+    {
+      return ::sched_get_priority_max (policy);
+    }
+#else
+  ACE_UNUSED_ARG (scope);
+  return ::sched_get_priority_max (policy);
+#endif /* (PRI_FIFO_MAX && PRI_RR_MAX && PRI_OTHER_MAX */
+
+#elif defined (ACE_HAS_WTHREADS)
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  return THREAD_PRIORITY_TIME_CRITICAL;
+#elif defined (VXWORKS)
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  return 0;
+#elif
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  ACE_NOTSUP_RETURN (-1);
+#endif /* ACE_HAS_STHREADS */
+}
+
+int
+ACE_Sched_Params::next_priority (const Policy policy,
+                                 const int priority,
+                                 const int scope)
+{
+#if defined (VXWORKS)
+  ACE_UNUSED_ARG (policy);
+  return priority > priority_max (policy, scope)
+           ?  priority - 1
+           :  priority_max (policy, scope);
+#elif defined (ACE_HAS_WTHREADS)
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  switch (priority)
+    {
+      case THREAD_PRIORITY_IDLE:
+        return THREAD_PRIORITY_LOWEST;
+      case THREAD_PRIORITY_LOWEST:
+        return THREAD_PRIORITY_BELOW_NORMAL;
+      case THREAD_PRIORITY_BELOW_NORMAL:
+        return THREAD_PRIORITY_NORMAL;
+      case THREAD_PRIORITY_NORMAL:
+        return THREAD_PRIORITY_ABOVE_NORMAL;
+      case THREAD_PRIORITY_ABOVE_NORMAL:
+        return THREAD_PRIORITY_HIGHEST;
+      case THREAD_PRIORITY_HIGHEST:
+        return THREAD_PRIORITY_TIME_CRITICAL;
+      case THREAD_PRIORITY_TIME_CRITICAL:
+        return THREAD_PRIORITY_TIME_CRITICAL;
+    }
+#elif defined (ACE_HAS_THREADS)
+  // including STHREADS, DCETHREADS, and PTHREADS
+  const int max = priority_max (policy, scope);
+  return priority < max  ?  priority + 1  :  max;
+#elif
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  ACE_NOTSUP_RETURN (-1);
+#endif /* ACE_HAS_THREADS */
+}
+
+int
+ACE_Sched_Params::previous_priority (const Policy policy,
+                                     const int priority,
+                                     const int scope)
+{
+#if defined (VXWORKS)
+  ACE_UNUSED_ARG (policy);
+  return priority < priority_min (policy, scope)
+           ?  priority + 1
+           :  priority_min (policy, scope);
+#elif defined (ACE_HAS_WTHREADS)
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  switch (priority)
+    {
+      case THREAD_PRIORITY_IDLE:
+        return THREAD_PRIORITY_IDLE;
+      case THREAD_PRIORITY_IDLE:
+        return THREAD_PRIORITY_BELOW_NORMAL;
+      case THREAD_PRIORITY_BELOW_NORMAL:
+        return THREAD_PRIORITY_LOWEST;
+      case THREAD_PRIORITY_NORMAL:
+        return THREAD_PRIORITY_BELOW_NORMAL;
+      case THREAD_PRIORITY_ABOVE_NORMAL:
+        return THREAD_PRIORITY_NORMAL;
+      case THREAD_PRIORITY_HIGHEST:
+        return THREAD_PRIORITY_ABOVE_NORMAL;
+      case THREAD_PRIORITY_TIME_CRITICAL:
+        return THREAD_PRIORITY_HIGHEST;
+    }
+#elif defined (ACE_HAS_THREADS)
+  // including STHREADS, DCETHREADS, and PTHREADS
+  const int min = priority_min (policy, scope);
+  return priority > min  ?  priority - 1  :  min;
+#elif
+  ACE_UNUSED_ARG (policy);
+  ACE_UNUSED_ARG (scope);
+  ACE_NOTSUP_RETURN (-1);
+#endif /* ACE_HAS_THREADS */
+}