lockmgr::MutexTracker Class Reference

#include <LockMgrImpl.h>

Inheritance diagram for lockmgr::MutexTracker:

Collaboration diagram for lockmgr::MutexTracker:

Public Member Functions
	MutexTracker (std::unique_ptr< heavyai::DistributedSharedMutex > dmutex)
virtual void	lock ()
virtual bool	try_lock ()
virtual void	unlock ()
virtual void	lock_shared ()
virtual bool	try_lock_shared ()
virtual void	unlock_shared ()
virtual bool	isAcquired () const
Public Member Functions inherited from heavyai::SharedMutexInterface
virtual	~SharedMutexInterface ()
Public Member Functions inherited from heavyai::MutexInterface
virtual	~MutexInterface ()

Private Attributes
std::atomic< size_t >	ref_count_
MutexTypeBase	mutex_
std::unique_ptr < heavyai::DistributedSharedMutex >	dmutex_

Detailed Description

Definition at line 40 of file LockMgrImpl.h.

Constructor & Destructor Documentation

lockmgr::MutexTracker::MutexTracker ( std::unique_ptr< heavyai::DistributedSharedMutex >  dmutex )

inline

Definition at line 42 of file LockMgrImpl.h.

      : ref_count_(0u), dmutex_(std::move(dmutex)) {}

Member Function Documentation

virtual bool lockmgr::MutexTracker::isAcquired ( ) const

inlinevirtual

Definition at line 103 of file LockMgrImpl.h.

References ref_count_.

{ return ref_count_.load() > 0; }

virtual void lockmgr::MutexTracker::lock ( )

inlinevirtual

Implements heavyai::MutexInterface.

Definition at line 45 of file LockMgrImpl.h.

References dmutex_, g_multi_instance, mutex_, and ref_count_.

                      {
    ref_count_.fetch_add(1u);
    if (!g_multi_instance) {
      mutex_.lock();
    } else {
      dmutex_->lock();
    }
  }

virtual void lockmgr::MutexTracker::lock_shared ( )

inlinevirtual

Implements heavyai::SharedMutexInterface.

Definition at line 74 of file LockMgrImpl.h.

References dmutex_, g_multi_instance, mutex_, and ref_count_.

                             {
    ref_count_.fetch_add(1u);
    if (!g_multi_instance) {
      mutex_.lock_shared();
    } else {
      dmutex_->lock_shared();
    }
  }

virtual bool lockmgr::MutexTracker::try_lock ( )

inlinevirtual

Implements heavyai::MutexInterface.

Definition at line 53 of file LockMgrImpl.h.

References dmutex_, g_multi_instance, mutex_, and ref_count_.

                          {
    bool gotlock{false};
    if (!g_multi_instance) {
      gotlock = mutex_.try_lock();
    } else {
      gotlock = dmutex_->try_lock();
    }
    if (gotlock) {
      ref_count_.fetch_add(1u);
    }
    return gotlock;
  }

virtual bool lockmgr::MutexTracker::try_lock_shared ( )

inlinevirtual

Implements heavyai::SharedMutexInterface.

Definition at line 82 of file LockMgrImpl.h.

References dmutex_, g_multi_instance, mutex_, and ref_count_.

                                 {
    bool gotlock{false};
    if (!g_multi_instance) {
      gotlock = mutex_.try_lock_shared();
    } else {
      gotlock = dmutex_->try_lock_shared();
    }
    if (gotlock) {
      ref_count_.fetch_add(1u);
    }
    return gotlock;
  }

virtual void lockmgr::MutexTracker::unlock ( )

inlinevirtual

Implements heavyai::MutexInterface.

Definition at line 65 of file LockMgrImpl.h.

References dmutex_, g_multi_instance, mutex_, and ref_count_.

                        {
    if (!g_multi_instance) {
      mutex_.unlock();
    } else {
      dmutex_->unlock();
    }
    ref_count_.fetch_sub(1u);
  }

virtual void lockmgr::MutexTracker::unlock_shared ( )

inlinevirtual

Implements heavyai::SharedMutexInterface.

Definition at line 94 of file LockMgrImpl.h.

References dmutex_, g_multi_instance, mutex_, and ref_count_.

                               {
    if (!g_multi_instance) {
      mutex_.unlock_shared();
    } else {
      dmutex_->unlock_shared();
    }
    ref_count_.fetch_sub(1u);
  }

Member Data Documentation

std::unique_ptr<heavyai::DistributedSharedMutex> lockmgr::MutexTracker::dmutex_

private

Definition at line 108 of file LockMgrImpl.h.

Referenced by lock(), lock_shared(), try_lock(), try_lock_shared(), unlock(), and unlock_shared().

MutexTypeBase lockmgr::MutexTracker::mutex_

private

Definition at line 107 of file LockMgrImpl.h.

Referenced by lock(), lock_shared(), try_lock(), try_lock_shared(), unlock(), and unlock_shared().

std::atomic<size_t> lockmgr::MutexTracker::ref_count_

private

Definition at line 106 of file LockMgrImpl.h.

Referenced by isAcquired(), lock(), lock_shared(), try_lock(), try_lock_shared(), unlock(), and unlock_shared().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/LockMgr/LockMgrImpl.h