#include <RWLocks.h>

Public Member Functions
	read_lock (const T *cat)

	~read_lock ()

void	unlock ()

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

Private Attributes
const T *	catalog

heavyai::shared_lock < heavyai::shared_mutex >	lock

heavyai::shared_lock < heavyai::DistributedSharedMutex >	dlock

bool	holds_lock

Detailed Description

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

Definition at line 38 of file RWLocks.h.

Constructor & Destructor Documentation

template<typename T >

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

inline

Definition at line 61 of file RWLocks.h.

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

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

cat

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

Definition: StringTransform.h:41

Catalog_Namespace::read_lock::catalog

const T * catalog

Definition: RWLocks.h:39

Catalog_Namespace::read_lock::holds_lock

bool holds_lock

Definition: RWLocks.h:42

Catalog_Namespace::read_lock::lock_catalog

void lock_catalog(const inner_type *cat)

Definition: RWLocks.h:45

Here is the call graph for this function:

template<typename T >

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

inline

Definition at line 63 of file RWLocks.h.

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

63 { unlock(); }

Catalog_Namespace::read_lock::unlock

void unlock()

Definition: RWLocks.h:65

Here is the call graph for this function:

Member Function Documentation

template<typename T >

template<typename inner_type >

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

inlineprivate

Definition at line 45 of file RWLocks.h.

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

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

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

Here is the caller graph for this function:

template<typename T >

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

inline

Definition at line 65 of file RWLocks.h.

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

Referenced by Catalog_Namespace::Catalog::getMetadataForTable(), Catalog_Namespace::Catalog::getPhysicalTablesDescriptors(), Catalog_Namespace::SysCatalog::syncUserWithRemoteProvider(), Catalog_Namespace::sqlite_lock< T >::unlock(), and Catalog_Namespace::read_lock< T >::~read_lock().

                 {
     if (holds_lock) {
       T::thread_holds_read_lock = false;
       if (!g_multi_instance) {
         lock.unlock();
       } else {
         dlock.unlock();
       }
       holds_lock = false;
     }
   }