TransactionTask Class Reference

#include <Transaction.h>

Public Member Functions
	TransactionTask (SQLTransaction trans)
	~TransactionTask ()
Public Member Functions inherited from SQLOperation
	SQLOperation ()
virtual	~SQLOperation ()
virtual int	call ()
virtual void	SetConnection (MySQLConnection *con)

Protected Member Functions
bool	Execute () override

Protected Attributes
SQLTransaction	m_trans

Static Protected Attributes
static std::mutex	_deadlockLock

Friends
template<class T >
class	DatabaseWorkerPool
class	DatabaseWorker

Additional Inherited Members
Public Attributes inherited from SQLOperation
MySQLConnection *	m_conn

Detailed Description

Low level class

Constructor & Destructor Documentation

TransactionTask::TransactionTask ( SQLTransaction  trans )

inline

: m_trans(trans) { }

TransactionTask::~TransactionTask ( )

inline

{ }

Member Function Documentation

bool TransactionTask::Execute ( )

overrideprotectedvirtual

Implements SQLOperation.

{
 int errorCode = m_conn->ExecuteTransaction(m_trans);
 if (!errorCode)
 return true;

 if (errorCode == ER_LOCK_DEADLOCK)
 {
 // Make sure only 1 async thread retries a transaction so they don't keep dead-locking each other
 std::lock_guard<std::mutex> lock(_deadlockLock);
 uint8 loopBreaker = 5; // Handle MySQL Errno 1213 without extending deadlock to the core itself
 for (uint8 i = 0; i < loopBreaker; ++i)
 if (!m_conn->ExecuteTransaction(m_trans))
 return true;
 }

 // Clean up now.
 m_trans->Cleanup();

 return false;
}

Friends And Related Function Documentation

friend class DatabaseWorker

friend

template<class T >

friend class DatabaseWorkerPool

friend

Member Data Documentation

std::mutex TransactionTask::_deadlockLock

staticprotected

SQLTransaction TransactionTask::m_trans

protected

---

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

• src/server/database/Database/Transaction.h
• src/server/database/Database/Transaction.cpp