TransactionLock.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/interfaces/memory/TransactionLock.h"
 
#include <memory>
 
#include "rogue/GilRelease.h"
#include "rogue/interfaces/memory/Transaction.h"
 
namespace rim = rogue::interfaces::memory;
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
namespace bp = boost::python;
#endif
 
rim::TransactionLockPtr rim::TransactionLock::create(rim::TransactionPtr tran) {
    rim::TransactionLockPtr tranLock = std::make_shared<rim::TransactionLock>(tran);
    return (tranLock);
}
 
rim::TransactionLock::TransactionLock(rim::TransactionPtr tran) {
    rogue::GilRelease noGil;
 
    tran_ = tran;
 
    while (tran_->isSubTransaction_) {
        rim::TransactionPtr parentTran = tran_->parentTransaction_.lock();
        if (parentTran)
            tran_ = parentTran;
        else
            break;
    }
    tran_->lock_.lock();
    locked_ = true;
}
 
void rim::TransactionLock::setup_python() {
#ifndef NO_PYTHON
 
    bp::class_<rim::TransactionLock, rim::TransactionLockPtr, boost::noncopyable>("TransactionLock", bp::no_init)
        .def("lock", &rim::TransactionLock::lock)
        .def("unlock", &rim::TransactionLock::unlock)
        .def("__enter__", &rim::TransactionLock::enter)
        .def("__exit__", &rim::TransactionLock::exit);
#endif
}
 
rim::TransactionLock::~TransactionLock() {
    if (locked_) tran_->lock_.unlock();
}
 
void rim::TransactionLock::lock() {
    if (!locked_) {
        rogue::GilRelease noGil;
        tran_->lock_.lock();
        locked_ = true;
    }
}
 
void rim::TransactionLock::unlock() {
    if (locked_) {
        tran_->lock_.unlock();
        locked_ = false;
    }
}
 
void rim::TransactionLock::enter() {}
 
void rim::TransactionLock::exit(void*, void*, void*) {}