diff options
Diffstat (limited to 'ACE/ace/Mutex.inl')
| -rw-r--r-- | ACE/ace/Mutex.inl | 186 |
1 files changed, 186 insertions, 0 deletions
diff --git a/ACE/ace/Mutex.inl b/ACE/ace/Mutex.inl new file mode 100644 index 00000000000..97ebf851da5 --- /dev/null +++ b/ACE/ace/Mutex.inl @@ -0,0 +1,186 @@ +// -*- C++ -*- +// +// $Id$ + + +#include "ace/OS_NS_sys_mman.h" + +ACE_BEGIN_VERSIONED_NAMESPACE_DECL + +ACE_INLINE int +ACE_Mutex::acquire_read (void) +{ +// ACE_TRACE ("ACE_Mutex::acquire_read"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_lock (this->process_lock_); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return ACE_OS::mutex_lock (&this->lock_); +} + +ACE_INLINE int +ACE_Mutex::acquire_write (void) +{ +// ACE_TRACE ("ACE_Mutex::acquire_write"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_lock (this->process_lock_); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return ACE_OS::mutex_lock (&this->lock_); +} + +ACE_INLINE int +ACE_Mutex::tryacquire_read (void) +{ +// ACE_TRACE ("ACE_Mutex::tryacquire_read"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_trylock (this->process_lock_); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return ACE_OS::mutex_trylock (&this->lock_); +} + +ACE_INLINE const ACE_mutex_t & +ACE_Mutex::lock (void) const +{ +// ACE_TRACE ("ACE_Mutex::lock"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return *this->process_lock_; +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return this->lock_; +} + +ACE_INLINE ACE_mutex_t & +ACE_Mutex::lock (void) +{ +// ACE_TRACE ("ACE_Mutex::lock"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return *this->process_lock_; +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return this->lock_; +} + +ACE_INLINE int +ACE_Mutex::tryacquire_write (void) +{ +// ACE_TRACE ("ACE_Mutex::tryacquire_write"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_trylock (this->process_lock_); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return ACE_OS::mutex_trylock (&this->lock_); +} + +ACE_INLINE int +ACE_Mutex::tryacquire_write_upgrade (void) +{ +// ACE_TRACE ("ACE_Mutex::tryacquire_write_upgrade"); + return 0; +} + +ACE_INLINE int +ACE_Mutex::acquire (void) +{ +// ACE_TRACE ("ACE_Mutex::acquire"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_lock (this->process_lock_); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return ACE_OS::mutex_lock (&this->lock_); +} + +ACE_INLINE int +ACE_Mutex::acquire (ACE_Time_Value &tv) +{ + // ACE_TRACE ("ACE_Mutex::acquire"); + #if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_lock (this->process_lock_, tv); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS*/ + return ACE_OS::mutex_lock (&this->lock_, tv); +} + +ACE_INLINE int +ACE_Mutex::acquire (ACE_Time_Value *tv) +{ + #if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_lock (this->process_lock_, tv); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS*/ + return ACE_OS::mutex_lock (&this->lock_, tv); +} + +ACE_INLINE int +ACE_Mutex::tryacquire (void) +{ +// ACE_TRACE ("ACE_Mutex::tryacquire"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_trylock (this->process_lock_); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return ACE_OS::mutex_trylock (&this->lock_); +} + +ACE_INLINE int +ACE_Mutex::release (void) +{ +// ACE_TRACE ("ACE_Mutex::release"); +#if defined (ACE_HAS_PTHREADS) || defined(ACE_HAS_STHREADS) + if (this->process_lock_) + return ACE_OS::mutex_unlock (this->process_lock_); +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return ACE_OS::mutex_unlock (&this->lock_); +} + +ACE_INLINE int +ACE_Mutex::remove (void) +{ +// ACE_TRACE ("ACE_Mutex::remove"); + int result = 0; +#if defined (ACE_HAS_PTHREADS) || defined (ACE_HAS_STHREADS) + // In the case of a interprocess mutex, the owner is the first + // process that created the shared memory object. In this case, the + // lockname_ pointer will be non-zero (points to allocated memory + // for the name). Owner or not, the memory needs to be unmapped + // from the process. If we are the owner, the file used for + // shm_open needs to be deleted as well. + if (this->process_lock_) + { + if (this->removed_ == false) + { + this->removed_ = true; + // Only destroy the lock if we're the ones who initialized + // it. + if (!this->lockname_) + ACE_OS::munmap ((void *) this->process_lock_, + sizeof (ACE_mutex_t)); + else + { + result = ACE_OS::mutex_destroy (this->process_lock_); + ACE_OS::munmap ((void *) this->process_lock_, + sizeof (ACE_mutex_t)); + ACE_OS::shm_unlink (this->lockname_); + ACE_OS::free ( + static_cast<void *> ( + const_cast<ACE_TCHAR *> (this->lockname_))); + } + } + } + else + { +#else /* !ACE_HAS_PTHREADS && !ACE_HAS_STHREADS */ + if (this->removed_ == false) + { + this->removed_ = true; + result = ACE_OS::mutex_destroy (&this->lock_); + } +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ +#if defined (ACE_HAS_PTHREADS) || defined (ACE_HAS_STHREADS) + } +#endif /* ACE_HAS_PTHREADS || ACE_HAS_STHREADS */ + return result; +} + +ACE_END_VERSIONED_NAMESPACE_DECL |