dep/ACE_wrappers/ace/Condition_T.inl

   1 // -*- C++ -*-
   2 //
   3 // $Id: Condition_T.inl 80826 2008-03-04 14:51:23Z wotte $
   4
   5 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   6
   7 template<class MUTEX> ACE_INLINE int
   8 ACE_Condition<MUTEX>::remove (void)
   9 {
  10   // ACE_TRACE ("ACE_Condition<MUTEX>::remove");
  11
  12   // cond_destroy() is called in a loop if the condition variable is
  13   // BUSY.  This avoids a condition where a condition is signaled and
  14   // because of some timing problem, the thread that is to be signaled
  15   // has called the cond_wait routine after the signal call.  Since
  16   // the condition signal is not queued in any way, deadlock occurs.
  17
  18   int result = 0;
  19
  20   while ((result = ACE_OS::cond_destroy (&this->cond_)) == -1
  21           && errno == EBUSY)
  22     {
  23       ACE_OS::cond_broadcast (&this->cond_);
  24       ACE_OS::thr_yield ();
  25     }
  26
  27   return result;
  28 }
  29
  30 template<class MUTEX> ACE_INLINE MUTEX &
  31 ACE_Condition<MUTEX>::mutex (void)
  32 {
  33   // ACE_TRACE ("ACE_Condition<MUTEX>::mutex");
  34   return this->mutex_;
  35 }
  36
  37 template <class MUTEX> ACE_INLINE int
  38 ACE_Condition<MUTEX>::signal (void)
  39 {
  40 // ACE_TRACE ("ACE_Condition<MUTEX>::signal");
  41   return ACE_OS::cond_signal (&this->cond_);
  42 }
  43
  44 template <class MUTEX> ACE_INLINE int
  45 ACE_Condition<MUTEX>::broadcast (void)
  46 {
  47 // ACE_TRACE ("ACE_Condition<MUTEX>::broadcast");
  48   return ACE_OS::cond_broadcast (&this->cond_);
  49 }
  50
  51 ACE_END_VERSIONED_NAMESPACE_DECL