#include <RWLocks.h>

Public Member Functions
	sqlite_lock (const T *cat)

	~sqlite_lock ()

void	unlock ()

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

Private Attributes
read_lock< T >	cat_read_lock

const T *	catalog

heavyai::unique_lock< std::mutex >	lock

heavyai::unique_lock < heavyai::DistributedSharedMutex >	dlock

bool	holds_lock

Detailed Description

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

Definition at line 82 of file RWLocks.h.

Constructor & Destructor Documentation

template<typename T >

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

inline

Definition at line 108 of file RWLocks.h.

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

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

Here is the call graph for this function:

template<typename T >

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

inline

Definition at line 112 of file RWLocks.h.

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

112 { unlock(); }

Catalog_Namespace::sqlite_lock::unlock

void unlock()

Definition: RWLocks.h:114

Here is the call graph for this function:

Member Function Documentation

template<typename T >

template<typename inner_type >

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

inlineprivate

Definition at line 92 of file RWLocks.h.

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

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

                                            {
     std::thread::id tid = std::this_thread::get_id();
 
     if (cat->thread_holding_sqlite_lock != tid) {
       if (!g_multi_instance) {
         lock = heavyai::unique_lock<std::mutex>(cat->sqliteMutex_);
       } else {
         dlock =
             heavyai::unique_lock<heavyai::DistributedSharedMutex>(*cat->dsqliteMutex_);
       }
       cat->thread_holding_sqlite_lock = tid;
       holds_lock = true;
     }
   }

Here is the caller graph for this function:

template<typename T >

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

inline

Definition at line 114 of file RWLocks.h.

References Catalog_Namespace::sqlite_lock< T >::catalog, Catalog_Namespace::sqlite_lock< T >::dlock, g_multi_instance, Catalog_Namespace::sqlite_lock< T >::holds_lock, Catalog_Namespace::sqlite_lock< T >::lock, and Catalog_Namespace::read_lock< T >::unlock().

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

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