#include <RWLocks.h>

Public Member Functions
	write_lock (const T *cat)

	~write_lock ()

void	unlock ()

Private Member Functions
template<typename inner_type >
void	lock_catalog (const inner_type *cat)

Private Attributes
const T *	catalog

heavyai::unique_lock < heavyai::shared_mutex >	lock

heavyai::unique_lock < heavyai::DistributedSharedMutex >	dlock

bool	holds_lock

Detailed Description

template<typename T>
class Catalog_Namespace::write_lock< T >

Definition at line 130 of file RWLocks.h.

Constructor & Destructor Documentation

template<typename T >

Catalog_Namespace::write_lock< T >::write_lock ( const T * cat )

inline

Definition at line 153 of file RWLocks.h.

References Catalog_Namespace::write_lock< T >::lock_catalog().

153 : catalog(cat), holds_lock(false) { lock_catalog(cat); }

cat

std::string cat(Ts &&...args)

Definition: StringTransform.h:41

Catalog_Namespace::write_lock::lock_catalog

void lock_catalog(const inner_type *cat)

Definition: RWLocks.h:137

Catalog_Namespace::write_lock::holds_lock

bool holds_lock

Definition: RWLocks.h:134

Catalog_Namespace::write_lock::catalog

const T * catalog

Definition: RWLocks.h:131

Here is the call graph for this function:

template<typename T >

Catalog_Namespace::write_lock< T >::~write_lock ( )

inline

Definition at line 155 of file RWLocks.h.

References Catalog_Namespace::write_lock< T >::unlock().

155 { unlock(); }

Catalog_Namespace::write_lock::unlock

void unlock()

Definition: RWLocks.h:157

Here is the call graph for this function:

Member Function Documentation

template<typename T >

template<typename inner_type >

void Catalog_Namespace::write_lock< T >::lock_catalog ( const inner_type * cat )

inlineprivate

Definition at line 137 of file RWLocks.h.

References Catalog_Namespace::write_lock< T >::dlock, g_multi_instance, Catalog_Namespace::write_lock< T >::holds_lock, and Catalog_Namespace::write_lock< T >::lock.

Referenced by Catalog_Namespace::write_lock< T >::write_lock().

                                            {
     std::thread::id tid = std::this_thread::get_id();
 
     if (cat->thread_holding_write_lock != tid) {
       if (!g_multi_instance) {
         lock = heavyai::unique_lock<heavyai::shared_mutex>(cat->sharedMutex_);
       } else {
         dlock =
             heavyai::unique_lock<heavyai::DistributedSharedMutex>(*cat->dcatalogMutex_);
       }
       cat->thread_holding_write_lock = tid;
       holds_lock = true;
     }
   }

Here is the caller graph for this function:

template<typename T >

void Catalog_Namespace::write_lock< T >::unlock ( )

inline

Definition at line 157 of file RWLocks.h.

References Catalog_Namespace::write_lock< T >::catalog, Catalog_Namespace::write_lock< T >::dlock, g_multi_instance, Catalog_Namespace::write_lock< T >::holds_lock, and Catalog_Namespace::write_lock< T >::lock.

Referenced by Catalog_Namespace::Catalog::createDashboard(), Catalog_Namespace::Catalog::replaceDashboard(), Catalog_Namespace::Catalog::setUncappedTableEpoch(), and Catalog_Namespace::write_lock< T >::~write_lock().

                 {
     if (holds_lock) {
       std::thread::id no_thread;
       catalog->thread_holding_write_lock = no_thread;
       if (!g_multi_instance) {
         lock.unlock();
       } else {
         dlock.unlock();
       }
       holds_lock = false;
     }
   }