ACE/ace/Semaphore.inl

   1 // -*- C++ -*-
   2 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   3
   4 ACE_INLINE const ACE_sema_t &
   5 ACE_Semaphore::lock () const
   6 {
   7 // ACE_TRACE ("ACE_Semaphore::lock");
   8   return this->semaphore_;
   9 }
  10
  11 ACE_INLINE int
  12 ACE_Semaphore::remove ()
  13 {
  14 // ACE_TRACE ("ACE_Semaphore::remove");
  15   int result = 0;
  16   if (!this->removed_)
  17     {
  18       this->removed_ = true;
  19       result = ACE_OS::sema_destroy (&this->semaphore_);
  20     }
  21   return result;
  22 }
  23
  24 ACE_INLINE int
  25 ACE_Semaphore::acquire ()
  26 {
  27 // ACE_TRACE ("ACE_Semaphore::acquire");
  28   return ACE_OS::sema_wait (&this->semaphore_);
  29 }
  30
  31 ACE_INLINE int
  32 ACE_Semaphore::acquire (ACE_Time_Value &tv)
  33 {
  34 // ACE_TRACE ("ACE_Semaphore::acquire");
  35   return ACE_OS::sema_wait (&this->semaphore_, tv);
  36 }
  37
  38 ACE_INLINE int
  39 ACE_Semaphore::acquire (ACE_Time_Value *tv)
  40 {
  41 // ACE_TRACE ("ACE_Semaphore::acquire");
  42   return ACE_OS::sema_wait (&this->semaphore_, tv);
  43 }
  44
  45 ACE_INLINE int
  46 ACE_Semaphore::tryacquire ()
  47 {
  48 // ACE_TRACE ("ACE_Semaphore::tryacquire");
  49   return ACE_OS::sema_trywait (&this->semaphore_);
  50 }
  51
  52 ACE_INLINE int
  53 ACE_Semaphore::release ()
  54 {
  55 // ACE_TRACE ("ACE_Semaphore::release");
  56   return ACE_OS::sema_post (&this->semaphore_);
  57 }
  58
  59 ACE_INLINE int
  60 ACE_Semaphore::release (unsigned int release_count)
  61 {
  62 // ACE_TRACE ("ACE_Semaphore::release");
  63   return ACE_OS::sema_post (&this->semaphore_, release_count);
  64 }
  65
  66 // Acquire semaphore ownership.  This calls <acquire> and is only
  67 // here to make the <ACE_Semaphore> interface consistent with the
  68 // other synchronization APIs.
  69
  70 ACE_INLINE int
  71 ACE_Semaphore::acquire_read ()
  72 {
  73   return this->acquire ();
  74 }
  75
  76 // Acquire semaphore ownership.  This calls <acquire> and is only
  77 // here to make the <ACE_Semaphore> interface consistent with the
  78 // other synchronization APIs.
  79
  80 ACE_INLINE int
  81 ACE_Semaphore::acquire_write ()
  82 {
  83   return this->acquire ();
  84 }
  85
  86 // Conditionally acquire semaphore (i.e., won't block).  This calls
  87 // <tryacquire> and is only here to make the <ACE_Semaphore>
  88 // interface consistent with the other synchronization APIs.
  89
  90 ACE_INLINE int
  91 ACE_Semaphore::tryacquire_read ()
  92 {
  93   return this->tryacquire ();
  94 }
  95
  96 // Conditionally acquire semaphore (i.e., won't block).  This calls
  97 // <tryacquire> and is only here to make the <ACE_Semaphore>
  98 // interface consistent with the other synchronization APIs.
  99
 100 ACE_INLINE int
 101 ACE_Semaphore::tryacquire_write ()
 102 {
 103   return this->tryacquire ();
 104 }
 105
 106 // This is only here to make the <ACE_Semaphore> interface consistent
 107 // with the other synchronization APIs.  Assumes the caller has
 108 // already acquired the semaphore using one of the above calls, and
 109 // returns 0 (success) always.
 110 ACE_INLINE int
 111 ACE_Semaphore::tryacquire_write_upgrade ()
 112 {
 113   return 0;
 114 }
 115
 116 ACE_END_VERSIONED_NAMESPACE_DECL