lmdb_transaction.cpp

Go to the documentation of this file.

#include "barretenberg/lmdblib/lmdb_transaction.hpp"
#include "barretenberg/lmdblib/lmdb_environment.hpp"
#include "barretenberg/lmdblib/lmdb_helpers.hpp"
#include <cstdint>
#include <utility>
 
namespace bb::lmdblib {
LMDBTransaction::LMDBTransaction(std::shared_ptr<LMDBEnvironment> env, bool readOnly)
    : _environment(std::move(env))
    , _id(_environment->getNextId())
    , state(TransactionState::OPEN)
{
    MDB_txn* p = nullptr;
    const std::string name("mdb_txn_begin");
    call_lmdb_func(name, mdb_txn_begin, _environment->underlying(), p, readOnly ? MDB_RDONLY : 0U, &_transaction);
}
 
LMDBTransaction::~LMDBTransaction() = default;
 
MDB_txn* LMDBTransaction::underlying() const
{
    return _transaction;
}
 
uint64_t LMDBTransaction::id() const
{
    return _id;
}
 
void LMDBTransaction::abort()
{
    if (state != TransactionState::OPEN) {
        return;
    }
    call_lmdb_func(mdb_txn_abort, _transaction);
    state = TransactionState::ABORTED;
}
 
bool LMDBTransaction::get_value(std::vector<uint8_t>& key, std::vector<uint8_t>& data, const LMDBDatabase& db) const
{
    return lmdb_queries::get_value(key, data, db, *this);
}
 
bool LMDBTransaction::get_value(std::vector<uint8_t>& key, uint64_t& data, const LMDBDatabase& db) const
{
    return lmdb_queries::get_value(key, data, db, *this);
}
} // namespace bb::lmdblib