TAO/tao/RTCORBA/RT_Mutex.cpp

   1 #include "tao/RTCORBA/RT_Mutex.h"
   2
   3 #if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
   4
   5 #include "tao/RTCORBA/RT_ORB.h"
   6 #include "tao/SystemException.h"
   7 #include "ace/OS_NS_sys_time.h"
   8
   9 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  10
  11 TAO_RT_Mutex::~TAO_RT_Mutex ()
  12 {
  13 }
  14
  15 void
  16 TAO_RT_Mutex::lock ()
  17 {
  18   if (this->mu_.acquire () != 0)
  19     throw ::CORBA::INTERNAL ();
  20 }
  21
  22 void
  23 TAO_RT_Mutex::unlock ()
  24 {
  25   if (this->mu_.release () != 0)
  26     throw ::CORBA::INTERNAL ();
  27 }
  28
  29 CORBA::Boolean
  30 TAO_RT_Mutex::try_lock (TimeBase::TimeT wait_time)
  31 {
  32   int result;
  33
  34   if (wait_time == 0)
  35     // No wait.
  36     result = this->mu_.tryacquire ();
  37   else
  38     {
  39       // Wait for the specified amount of time before giving up.
  40       // (wait_time units are 100ns.  See TimeBase.pidl)
  41       TimeBase::TimeT seconds = wait_time / 10000000u;
  42       TimeBase::TimeT microseconds = (wait_time % 10000000u) / 10;
  43
  44       ACE_Time_Value relative_time (ACE_U64_TO_U32 (seconds),
  45                                     ACE_U64_TO_U32 (microseconds));
  46
  47       ACE_Time_Value absolute_time =
  48         relative_time +
  49         ACE_OS::gettimeofday ();
  50
  51       result = this->mu_.acquire (absolute_time);
  52     }
  53
  54   if (result == 0)
  55     return 1;
  56   else if (result == -1 &&
  57            (errno == ETIME ||
  58             errno == EBUSY))
  59     return 0;
  60   else
  61     // Some really bad error.
  62     throw ::CORBA::INTERNAL ();
  63 }
  64
  65 const char *
  66 TAO_RT_Mutex::name () const
  67 {
  68   return 0;
  69 }
  70
  71 ///////////////////////////////////////////////////////////////////////////////
  72 #if (TAO_HAS_NAMED_RT_MUTEXES == 1)
  73 TAO_Named_RT_Mutex::TAO_Named_RT_Mutex (const char *name)
  74   : name_ (name)
  75 {
  76 }
  77
  78 const char *
  79 TAO_Named_RT_Mutex::name () const
  80 {
  81   return this->name_.c_str ();
  82 }
  83 #endif /* TAO_HAS_NAMED_RT_MUTEXES == 1 */
  84
  85 ///////////////////////////////////////////////////////////////////////////////
  86
  87 TAO_END_VERSIONED_NAMESPACE_DECL
  88
  89 #endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */