TAO/tao/RTCORBA/Continuous_Priority_Mapping.cpp

   1 #include "tao/RTCORBA/Continuous_Priority_Mapping.h"
   2
   3 #if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
   4
   5 #include "ace/Sched_Params.h"
   6
   7 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   8
   9 TAO_Continuous_Priority_Mapping::TAO_Continuous_Priority_Mapping (int policy)
  10   :  policy_ (policy)
  11    , min_ (ACE_Sched_Params::priority_min (this->policy_))
  12    , max_ (ACE_Sched_Params::priority_max (this->policy_))
  13 {
  14 }
  15
  16 TAO_Continuous_Priority_Mapping::~TAO_Continuous_Priority_Mapping ()
  17 {
  18 }
  19
  20 CORBA::Boolean
  21 TAO_Continuous_Priority_Mapping::to_native (RTCORBA::Priority corba_priority,
  22                                             RTCORBA::NativePriority &native_priority)
  23 {
  24   if (corba_priority < 0)
  25     return false;
  26
  27 #if defined (ACE_WIN32)
  28
  29   int current_native_priority = this->min_;
  30   int next_native_priority;
  31   for (int i = 1; i <= corba_priority; ++i)
  32     {
  33       next_native_priority =
  34         ACE_Sched_Params::next_priority (this->policy_,
  35                                          current_native_priority);
  36
  37       if (next_native_priority == current_native_priority)
  38         return false;
  39
  40       current_native_priority = next_native_priority;
  41     }
  42
  43   native_priority = static_cast<RTCORBA::NativePriority> (current_native_priority);
  44   return true;
  45
  46 #else
  47   int native;
  48
  49   if (this->min_ < this->max_)
  50     {
  51       native = corba_priority + this->min_;
  52       if (native > this->max_)
  53         return false;
  54     }
  55   else if (this->min_ > this->max_)
  56     {
  57       native = this->min_ - corba_priority;
  58       if (native < this->max_)
  59         return false;
  60     }
  61   else
  62     {
  63       // There is only one native priority.
  64       if (corba_priority != 0)
  65         return false;
  66
  67       native = this->min_;
  68     }
  69
  70   native_priority = native;
  71
  72   return true;
  73
  74 #endif /* ACE_WIN32 */
  75
  76 }
  77
  78 CORBA::Boolean
  79 TAO_Continuous_Priority_Mapping::to_CORBA (RTCORBA::NativePriority native_priority,
  80                                            RTCORBA::Priority &corba_priority)
  81 {
  82 #if defined (ACE_WIN32)
  83
  84   int current_native_priority = this->min_;
  85   for (corba_priority = 0; ; ++corba_priority)
  86     {
  87       if (current_native_priority == native_priority)
  88         return true;
  89
  90       else if (current_native_priority == this->max_)
  91         return false;
  92
  93       else
  94         current_native_priority =
  95           ACE_Sched_Params::next_priority (this->policy_,
  96                                            current_native_priority);
  97     }
  98
  99 #else
 100
 101   if (this->min_ < this->max_)
 102     {
 103       if (native_priority < this->min_
 104           || native_priority > this->max_)
 105         return false;
 106       corba_priority = native_priority - this->min_;
 107     }
 108   else if (this->min_ > this->max_)
 109     {
 110       if (native_priority > this->min_
 111           || native_priority < this->max_)
 112         return false;
 113       corba_priority = this->min_ - native_priority;
 114     }
 115   else if (this->min_ == this->max_)
 116     {
 117       if (native_priority != this->min_)
 118         return false;
 119       corba_priority = 0;
 120     }
 121
 122   return true;
 123
 124 #endif /* ACE_WIN32 */
 125
 126 }
 127
 128 TAO_END_VERSIONED_NAMESPACE_DECL
 129
 130 #endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */