cryptonote::mdb_txn_safe Struct Reference

#include <db_lmdb.h>

Collaboration diagram for cryptonote::mdb_txn_safe:

Public Member Functions
	mdb_txn_safe (const bool check=true)
	~mdb_txn_safe ()
void	commit (std::string message="")
void	abort ()
void	uncheck ()
	operator MDB_txn * ()
	operator MDB_txn ** ()
uint64_t	num_active_tx () const

Static Public Member Functions
static void	prevent_new_txns ()
static void	wait_no_active_txns ()
static void	allow_new_txns ()

Public Attributes
mdb_threadinfo *	m_tinfo
MDB_txn *	m_txn
bool	m_batch_txn = false
bool	m_check

Static Public Attributes
static std::atomic< uint64_t >	num_active_txns {0}
static std::atomic_flag	creation_gate = ATOMIC_FLAG_INIT

Detailed Description

Definition at line 137 of file db_lmdb.h.

Constructor & Destructor Documentation

mdb_txn_safe()

cryptonote::mdb_txn_safe::mdb_txn_safe

(

const bool

check = true

)

Definition at line 400 of file db_lmdb.cpp.

                                           : m_txn(NULL), m_tinfo(NULL), m_check(check)
{
  if (check)
  {
    while (creation_gate.test_and_set());
    num_active_txns++;
    creation_gate.clear();
  }
}

~mdb_txn_safe()

cryptonote::mdb_txn_safe::~mdb_txn_safe

(

)

Definition at line 410 of file db_lmdb.cpp.

{
  if (!m_check)
    return;
  LOG_PRINT_L3("mdb_txn_safe: destructor");
  if (m_tinfo != nullptr)
  {
    mdb_txn_reset(m_tinfo->m_ti_rtxn);
    memset(&m_tinfo->m_ti_rflags, 0, sizeof(m_tinfo->m_ti_rflags));
  } else if (m_txn != nullptr)
  {
    if (m_batch_txn) // this is a batch txn and should have been handled before this point for safety
    {
      LOG_PRINT_L0("WARNING: mdb_txn_safe: m_txn is a batch txn and it's not NULL in destructor - calling mdb_txn_abort()");
    }
    else
    {
      // Example of when this occurs: a lookup fails, so a read-only txn is
      // aborted through this destructor. However, successful read-only txns
      // ideally should have been committed when done and not end up here.
      //
      // NOTE: not sure if this is ever reached for a non-batch write
      // transaction, but it's probably not ideal if it did.
      LOG_PRINT_L3("mdb_txn_safe: m_txn not NULL in destructor - calling mdb_txn_abort()");
    }
    mdb_txn_abort(m_txn);
  }
  num_active_txns--;
}

Here is the call graph for this function:

Member Function Documentation

abort()

void cryptonote::mdb_txn_safe::abort

(

)

Definition at line 461 of file db_lmdb.cpp.

{
  LOG_PRINT_L3("mdb_txn_safe: abort()");
  if(m_txn != nullptr)
  {
    mdb_txn_abort(m_txn);
    m_txn = nullptr;
  }
  else
  {
    LOG_PRINT_L0("WARNING: mdb_txn_safe: abort() called, but m_txn is NULL");
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

allow_new_txns()

void cryptonote::mdb_txn_safe::allow_new_txns ( )

static

Definition at line 490 of file db_lmdb.cpp.

{
  creation_gate.clear();
}

commit()

void cryptonote::mdb_txn_safe::commit

(

std::string

message = ""

)

Definition at line 446 of file db_lmdb.cpp.

{
  if (message.size() == 0)
  {
    message = "Failed to commit a transaction to the db";
  }
 
  if (auto result = mdb_txn_commit(m_txn))
  {
    m_txn = nullptr;
    throw0(DB_ERROR(lmdb_error(message + ": ", result).c_str()));
  }
  m_txn = nullptr;
}

Here is the call graph for this function:

Here is the caller graph for this function:

num_active_tx()

uint64_t cryptonote::mdb_txn_safe::num_active_tx

(

)

const

Definition at line 475 of file db_lmdb.cpp.

{
  return num_active_txns;
}

operator MDB_txn *()

cryptonote::mdb_txn_safe::operator MDB_txn * ( )

inline

Definition at line 151 of file db_lmdb.h.

  {
    return m_txn;
  }

operator MDB_txn **()

cryptonote::mdb_txn_safe::operator MDB_txn ** ( )

inline

Definition at line 156 of file db_lmdb.h.

  {
    return &m_txn;
  }

prevent_new_txns()

void cryptonote::mdb_txn_safe::prevent_new_txns ( )

static

Definition at line 480 of file db_lmdb.cpp.

{
  while (creation_gate.test_and_set());
}

uncheck()

void cryptonote::mdb_txn_safe::uncheck

(

)

Definition at line 440 of file db_lmdb.cpp.

{
  num_active_txns--;
  m_check = false;
}

wait_no_active_txns()

void cryptonote::mdb_txn_safe::wait_no_active_txns ( )

static

Definition at line 485 of file db_lmdb.cpp.

{
  while (num_active_txns > 0);
}

Member Data Documentation

creation_gate

std::atomic_flag cryptonote::mdb_txn_safe::creation_gate = ATOMIC_FLAG_INIT

static

Definition at line 174 of file db_lmdb.h.

m_batch_txn

bool cryptonote::mdb_txn_safe::m_batch_txn = false

Definition at line 169 of file db_lmdb.h.

m_check

bool cryptonote::mdb_txn_safe::m_check

Definition at line 170 of file db_lmdb.h.

m_tinfo

mdb_threadinfo* cryptonote::mdb_txn_safe::m_tinfo

Definition at line 167 of file db_lmdb.h.

m_txn

MDB_txn* cryptonote::mdb_txn_safe::m_txn

Definition at line 168 of file db_lmdb.h.

num_active_txns

std::atomic< uint64_t > cryptonote::mdb_txn_safe::num_active_txns {0}

static

Definition at line 171 of file db_lmdb.h.

---

The documentation for this struct was generated from the following files:

• /home/abuild/rpmbuild/BUILD/electroneum-4.0.0.0/src/blockchain_db/lmdb/db_lmdb.h
• /home/abuild/rpmbuild/BUILD/electroneum-4.0.0.0/src/blockchain_db/lmdb/db_lmdb.cpp