diff options
Diffstat (limited to 'ace/Token.inl')
| -rw-r--r-- | ace/Token.inl | 38 |
1 files changed, 24 insertions, 14 deletions
diff --git a/ace/Token.inl b/ace/Token.inl index 5cea9866cea..d375789fbd1 100644 --- a/ace/Token.inl +++ b/ace/Token.inl @@ -1,14 +1,16 @@ -/* -*- C++ -*- */ +// -*- C++ -*- +// // $Id$ -#include "ace/Guard_T.h" - -// Token.i +#include "ace/config-macros.h" #if defined (ACE_HAS_THREADS) +#include "ace/Guard_T.h" #include "ace/Time_Value.h" +ACE_BEGIN_VERSIONED_NAMESPACE_DECL + ACE_INLINE int ACE_Token::queueing_strategy (void) { @@ -29,25 +31,25 @@ ACE_Token::remove (void) ACE_NOTSUP_RETURN (-1); } -ACE_INLINE int +ACE_INLINE int ACE_Token::tryacquire (void) { ACE_TRACE ("ACE_Token::tryacquire"); - return this->shared_acquire + return this->shared_acquire (0, 0, (ACE_Time_Value *) &ACE_Time_Value::zero, ACE_Token::WRITE_TOKEN); } -ACE_INLINE int +ACE_INLINE int ACE_Token::waiters (void) { ACE_TRACE ("ACE_Token::waiters"); ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, this->lock_, -1); - int ret = this->waiters_; + int const ret = this->waiters_; return ret; } -ACE_INLINE ACE_thread_t +ACE_INLINE ACE_thread_t ACE_Token::current_owner (void) { ACE_TRACE ("ACE_Token::current_owner"); @@ -118,9 +120,9 @@ ACE_Token::ACE_Token_Queue_Entry::wait (ACE_Time_Value *timeout, ACE_Thread_Mute { #if defined (ACE_TOKEN_USES_SEMAPHORE) lock.release (); - int retv = (timeout == 0 ? - this->cv_.acquire () : - this->cv_.acquire (*timeout)); + int const retv = (timeout == 0 ? + this->cv_.acquire () : + this->cv_.acquire (*timeout)); lock.acquire (); return retv; #else @@ -132,7 +134,7 @@ ACE_Token::ACE_Token_Queue_Entry::wait (ACE_Time_Value *timeout, ACE_Thread_Mute ACE_INLINE int ACE_Token::ACE_Token_Queue_Entry::signal (void) { - return + return #if defined (ACE_TOKEN_USES_SEMAPHORE) this->cv_.release (); #else @@ -140,8 +142,13 @@ ACE_Token::ACE_Token_Queue_Entry::signal (void) #endif /* ACE_TOKEN_USES_SEMAPHORE */ } +ACE_END_VERSIONED_NAMESPACE_DECL + #endif /* ACE_HAS_THREADS */ -/******************************************************************************/ + +/*****************************************************************************/ + +ACE_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE int ACE_Noop_Token::queueing_strategy (void) @@ -164,3 +171,6 @@ ACE_INLINE void ACE_Noop_Token::dump (void) const { } + +ACE_END_VERSIONED_NAMESPACE_DECL + |