Defines some functions and data types shared between ASql engines. More...
#include <asql.hpp>
Classes | |
class | Queries |
Thread safe queue of queries. More... | |
struct | QuerySet |
class | SetCanceler |
Locks the mutex on a statement and set's the canceller to the queries canceller. More... | |
Public Member Functions | |
void | start () |
Start all threads of the handler. | |
void | terminate () |
Terminate all thread of the handler. | |
void | queue (Transaction< T > &transaction) |
Queue up a transaction for completion. | |
void | queue (T *const &statement, Query &query) |
Static Public Attributes | |
static const bool | s_false = false |
Protected Member Functions | |
ConnectionPar (const int maxThreads_) | |
Private Member Functions | |
void | intHandler (const unsigned int id) |
Function that runs in threads. | |
Private Attributes | |
boost::scoped_array< Queries > | queries |
Defines some functions and data types shared between ASql engines.
Definition at line 1167 of file asql.hpp.
ASql::ConnectionPar< T >::ConnectionPar | ( | const int | maxThreads_ ) | [inline, protected] |
void ASql::ConnectionPar< T >::intHandler | ( | const unsigned int | id ) | [private] |
Function that runs in threads.
Definition at line 1264 of file asql.hpp.
References ASql::Query::callback(), ASql::Query::clearResults(), ASql::Query::getCallback(), ASql::Query::isCallback(), ASql::ConnectionPar< T >::QuerySet::m_commit, ASql::ConnectionPar< T >::QuerySet::m_query, ASql::Query::m_sharedData, ASql::ConnectionPar< T >::QuerySet::m_statement, ASql::Query::parameters(), ASql::Query::results(), and ASql::Query::setCallback().
void ASql::ConnectionPar< T >::queue | ( | T *const & | statement, |
Query & | query | ||
) | [inline] |
void ASql::ConnectionPar< T >::queue | ( | Transaction< T > & | transaction ) |
Queue up a transaction for completion.
Definition at line 1364 of file asql.hpp.
References ASql::Transaction< T >::begin(), and ASql::Transaction< T >::end().
Referenced by ASql::MySQL::Statement::queue().
void ASql::ConnectionPar< T >::start | ( | ) |
void ASql::ConnectionPar< T >::terminate | ( | ) |
boost::scoped_array<Queries> ASql::ConnectionPar< T >::queries [private] |
const bool ASql::ConnectionPar< T >::s_false = false [static] |
Definition at line 1217 of file asql.hpp.
Referenced by ASql::ConnectionPar< T >::SetCanceler::~SetCanceler().