#include <MariaDBConnection.h>

Inheritance diagram for database::mariadb::MariaDBConnection:

Collaboration diagram for database::mariadb::MariaDBConnection:

Public Member Functions
	MariaDBConnection (MariaDBClient *mariaDBClient, const MariaDBConnectionDetails &connectionDetails)

	MariaDBConnection (const MariaDBConnection &)=delete

	~MariaDBConnection () override

MariaDBConnection &	operator= (const MariaDBConnection &)=delete

MariaDBCommandSequence &	execute_async (MariaDBCommandSequence &&commandSequence)

void	execute_sync (MariaDBCommand *mariaDBCommand)

void	commandStart (const utils::Timeval &currentTime)

void	commandContinue (int status)

void	commandCompleted ()

void	unmanaged ()

Protected Member Functions
void	checkStatus (int status)

void	readEvent () override

void	writeEvent () override

void	outOfBandEvent () override

void	readTimeout () override

void	writeTimeout () override

void	outOfBandTimeout () override

void	unobservedEvent () override

Private Attributes
MariaDBClient *	mariaDBClient

MYSQL *	mysql

std::deque< MariaDBCommandSequence >	commandSequenceQueue

MariaDBCommand *	currentCommand = nullptr

bool	connected = false

MariaDBCommandStartEvent	commandStartEvent

Additional Inherited Members
Private Member Functions inherited from core::eventreceiver::ReadEventReceiver
	ReadEventReceiver (const std::string &name, const utils::Timeval &timeout)

Private Member Functions inherited from core::DescriptorEventReceiver
	DescriptorEventReceiver (const std::string &name, DescriptorEventPublisher &descriptorEventPublisher, const utils::Timeval &timeout=TIMEOUT::DISABLE)

int	getRegisteredFd () const

bool	isEnabled () const

bool	isSuspended () const

void	setTimeout (const utils::Timeval &timeout)

utils::Timeval	getTimeout (const utils::Timeval &currentTime) const

void	checkTimeout (const utils::Timeval &currentTime)

bool	enable (int fd)

void	disable ()

void	suspend ()

void	resume ()

Private Member Functions inherited from core::EventReceiver
	EventReceiver (const std::string &name)

	EventReceiver (EventReceiver &)=delete

	EventReceiver (EventReceiver &&)=delete

EventReceiver &	operator= (EventReceiver &)=delete

EventReceiver &	operator= (EventReceiver &&)=delete

virtual void	destruct ()

void	span ()

void	relax ()

const std::string &	getName () const

virtual	~EventReceiver ()=default

Private Member Functions inherited from core::eventreceiver::WriteEventReceiver
	WriteEventReceiver (const std::string &name, const utils::Timeval &timeout)

Private Member Functions inherited from core::eventreceiver::ExceptionalConditionEventReceiver
	ExceptionalConditionEventReceiver (const std::string &name, const utils::Timeval &timeout=60)

Static Private Member Functions inherited from core::EventReceiver
static void	atNextTick (const std::function< void(void)> &callBack)

Detailed Description

Definition at line 64 of file MariaDBConnection.h.

Constructor & Destructor Documentation

◆ MariaDBConnection() [1/2]

database::mariadb::MariaDBConnection::MariaDBConnection	(	MariaDBClient *	mariaDBClient,
		const MariaDBConnectionDetails &	connectionDetails )

explicit

Definition at line 40 of file MariaDBConnection.cpp.

        : ReadEventReceiver("MariaDBConnectionRead", core::DescriptorEventReceiver::TIMEOUT::DISABLE)
        , WriteEventReceiver("MariaDBConnectionWrite", core::DescriptorEventReceiver::TIMEOUT::DISABLE)
        , ExceptionalConditionEventReceiver("MariaDBConnectionExceptional", core::DescriptorEventReceiver::TIMEOUT::DISABLE)
        , mariaDBClient(mariaDBClient)
        , mysql(mysql_init(nullptr))
        , commandStartEvent("MariaDBCommandStartEvent", this) {
        mysql_options(mysql, MYSQL_OPT_NONBLOCK, nullptr);
 
        execute_async(std::move(MariaDBCommandSequence().execute_async(new database::mariadb::commands::async::MariaDBConnectCommand(
            connectionDetails,
            [this]() {
                if (mysql_errno(mysql) == 0) {
                    const int fd = mysql_get_socket(mysql);
 
                    LOG(DEBUG) << "MariaDB: Got valid descriptor: " << fd;
 
                    if (ReadEventReceiver::enable(fd) && WriteEventReceiver::enable(fd) && ExceptionalConditionEventReceiver::enable(fd)) {
                        ReadEventReceiver::suspend();
                        WriteEventReceiver::suspend();
                        ExceptionalConditionEventReceiver::suspend();
 
                        connected = true;
                    } else {
                        if (ReadEventReceiver::isEnabled()) {
                            ReadEventReceiver::disable();
                        }
                        if (WriteEventReceiver::isEnabled()) {
                            WriteEventReceiver::disable();
                        }
                        if (ExceptionalConditionEventReceiver::isEnabled()) {
                            ExceptionalConditionEventReceiver::disable();
                        }
                    }
                } else {
                    LOG(WARNING) << "MariaDB: Got no valid descriptor: " << mysql_error(mysql) << ", " << mysql_errno(mysql);
                }
            },
            []() {
                LOG(DEBUG) << "MariaDB: Connect success";
            },
            [](const std::string& errorString, unsigned int errorNumber) {
                LOG(WARNING) << "MariaDB: Connect error: " << errorString << " : " << errorNumber;
            }))));
    }

Referenced by database::mariadb::MariaDBClient::execute_async(), and database::mariadb::MariaDBClient::execute_sync().

Here is the caller graph for this function:

◆ MariaDBConnection() [2/2]

database::mariadb::MariaDBConnection::MariaDBConnection ( const MariaDBConnection & )

delete

◆ ~MariaDBConnection()

database::mariadb::MariaDBConnection::~MariaDBConnection ( )

override

Definition at line 86 of file MariaDBConnection.cpp.

                                          {
        for (MariaDBCommandSequence& mariaDBCommandSequence : commandSequenceQueue) {
            for (MariaDBCommand* mariaDBCommand : mariaDBCommandSequence.sequence()) {
                if (core::SNodeC::state() == core::State::RUNNING && connected) {
                    mariaDBCommand->commandError(mysql_error(mysql), mysql_errno(mysql));
                }
 
                delete mariaDBCommand;
            }
        }
 
        if (mariaDBClient != nullptr) {
            mariaDBClient->connectionVanished();
        }
 
        mysql_close(mysql);
        mysql_library_end();
    }

Member Function Documentation

◆ checkStatus()

void database::mariadb::MariaDBConnection::checkStatus ( int status )

protected

Definition at line 173 of file MariaDBConnection.cpp.

                                                  {
        if (connected) {
            if ((status & MYSQL_WAIT_READ) != 0) {
                if (ReadEventReceiver::isSuspended() && ReadEventReceiver::isEnabled()) {
                    ReadEventReceiver::resume();
                }
            } else if (!ReadEventReceiver::isSuspended()) {
                ReadEventReceiver::suspend();
            }
 
            if ((status & MYSQL_WAIT_WRITE) != 0) {
                if (WriteEventReceiver::isSuspended() && WriteEventReceiver::isEnabled()) {
                    WriteEventReceiver::resume();
                }
            } else if (!WriteEventReceiver::isSuspended()) {
                WriteEventReceiver::suspend();
            }
 
            if ((status & MYSQL_WAIT_EXCEPT) != 0) {
                if (ExceptionalConditionEventReceiver::isSuspended() && ExceptionalConditionEventReceiver::isEnabled()) {
                    ExceptionalConditionEventReceiver::resume();
                }
            } else if (!ExceptionalConditionEventReceiver::isSuspended()) {
                ExceptionalConditionEventReceiver::suspend();
            }
 
            if ((status & MYSQL_WAIT_TIMEOUT) != 0) {
                ReadEventReceiver::setTimeout(mysql_get_timeout_value(mysql));
                //                WriteEventReceiver::setTimeout(mysql_get_timeout_value(mysql));
                //                ExceptionalConditionEventReceiver::setTimeout(mysql_get_timeout_value(mysql));
            } else {
                ReadEventReceiver::setTimeout(core::DescriptorEventReceiver::TIMEOUT::DEFAULT);
                //                WriteEventReceiver::setTimeout(core::DescriptorEventReceiver::TIMEOUT::DEFAULT);
                //                ExceptionalConditionEventReceiver::setTimeout(core::DescriptorEventReceiver::TIMEOUT::DEFAULT);
            }
 
            if (status == 0) {
                if (mysql_errno(mysql) == 0) {
                    if (currentCommand->commandCompleted()) {
                        commandCompleted();
                    }
                } else {
                    currentCommand->commandError(mysql_error(mysql), mysql_errno(mysql));
                    commandCompleted();
                }
                commandStartEvent.span();
            }
        } else {
            currentCommand->commandError(mysql_error(mysql), mysql_errno(mysql));
            commandCompleted();
            delete this;
        }
    }

◆ commandCompleted()

void database::mariadb::MariaDBConnection::commandCompleted ( )

Definition at line 157 of file MariaDBConnection.cpp.

                                             {
        LOG(DEBUG) << "MariaDB: Completed: " << currentCommand->commandInfo();
        commandSequenceQueue.front().commandCompleted();
 
        if (commandSequenceQueue.front().empty()) {
            commandSequenceQueue.pop_front();
        }
 
        delete currentCommand;
        currentCommand = nullptr;
    }

◆ commandContinue()

void database::mariadb::MariaDBConnection::commandContinue ( int status )

Definition at line 147 of file MariaDBConnection.cpp.

                                                      {
        if (currentCommand != nullptr) {
            checkStatus(currentCommand->commandContinue(status));
        } else if ((status & MYSQL_WAIT_READ) != 0 && commandSequenceQueue.empty()) {
            ReadEventReceiver::disable();
            WriteEventReceiver::disable();
            ExceptionalConditionEventReceiver::disable();
        }
    }

◆ commandStart()

void database::mariadb::MariaDBConnection::commandStart ( const utils::Timeval & currentTime )

Definition at line 128 of file MariaDBConnection.cpp.

                                                                        {
        if (!commandSequenceQueue.empty()) {
            currentCommand = commandSequenceQueue.front().nextCommand();
 
            LOG(DEBUG) << "MariaDB: Start: " << currentCommand->commandInfo();
 
            currentCommand->setMariaDBConnection(this);
            checkStatus(currentCommand->commandStart(mysql, currentTime));
        } else if (mariaDBClient != nullptr) {
            if (ReadEventReceiver::isSuspended() && ReadEventReceiver::isEnabled()) {
                ReadEventReceiver::resume();
            }
        } else {
            ReadEventReceiver::disable();
            WriteEventReceiver::disable();
            ExceptionalConditionEventReceiver::disable();
        }
    }

◆ execute_async()

MariaDBCommandSequence & database::mariadb::MariaDBConnection::execute_async ( MariaDBCommandSequence && commandSequence )

Definition at line 105 of file MariaDBConnection.cpp.

                                                                                                     {
        if (currentCommand == nullptr && commandSequenceQueue.empty()) {
            commandStartEvent.span();
        }
 
        commandSequenceQueue.emplace_back(std::move(commandSequence));
 
        return commandSequenceQueue.back();
    }

Referenced by database::mariadb::MariaDBClient::execute_async().

Here is the caller graph for this function:

◆ execute_sync()

void database::mariadb::MariaDBConnection::execute_sync ( MariaDBCommand * mariaDBCommand )

Definition at line 115 of file MariaDBConnection.cpp.

                                                                       {
        mariaDBCommand->commandStart(mysql, utils::Timeval::currentTime());
 
        if (mysql_errno(mysql) == 0) {
            if (mariaDBCommand->commandCompleted()) {
            }
        } else {
            mariaDBCommand->commandError(mysql_error(mysql), mysql_errno(mysql));
        }
 
        delete mariaDBCommand;
    }

Referenced by database::mariadb::MariaDBClient::execute_sync().

Here is the caller graph for this function:

◆ operator=()

MariaDBConnection & database::mariadb::MariaDBConnection::operator= ( const MariaDBConnection & )

delete

◆ outOfBandEvent()

void database::mariadb::MariaDBConnection::outOfBandEvent ( )

overrideprotectedvirtual

Implements core::eventreceiver::ExceptionalConditionEventReceiver.

Definition at line 235 of file MariaDBConnection.cpp.

                                           {
        commandContinue(MYSQL_WAIT_EXCEPT);
    }

◆ outOfBandTimeout()

void database::mariadb::MariaDBConnection::outOfBandTimeout ( )

overrideprotectedvirtual

Reimplemented from core::eventreceiver::ExceptionalConditionEventReceiver.

Definition at line 247 of file MariaDBConnection.cpp.

                                             {
        commandContinue(MYSQL_WAIT_TIMEOUT);
    }

◆ readEvent()

void database::mariadb::MariaDBConnection::readEvent ( )

overrideprotectedvirtual

Implements core::eventreceiver::ReadEventReceiver.

Definition at line 227 of file MariaDBConnection.cpp.

                                      {
        commandContinue(MYSQL_WAIT_READ);
    }

◆ readTimeout()

void database::mariadb::MariaDBConnection::readTimeout ( )

overrideprotectedvirtual

Reimplemented from core::eventreceiver::ReadEventReceiver.

Definition at line 239 of file MariaDBConnection.cpp.

                                        {
        commandContinue(MYSQL_WAIT_TIMEOUT);
    }

◆ unmanaged()

void database::mariadb::MariaDBConnection::unmanaged ( )

Definition at line 169 of file MariaDBConnection.cpp.

                                      {
        mariaDBClient = nullptr;
    }

Referenced by database::mariadb::MariaDBClient::~MariaDBClient().

Here is the caller graph for this function:

◆ unobservedEvent()

void database::mariadb::MariaDBConnection::unobservedEvent ( )

overrideprotectedvirtual

Implements core::Observer.

Definition at line 251 of file MariaDBConnection.cpp.

                                            {
        delete this;
    }

◆ writeEvent()

void database::mariadb::MariaDBConnection::writeEvent ( )

overrideprotectedvirtual

Implements core::eventreceiver::WriteEventReceiver.

Definition at line 231 of file MariaDBConnection.cpp.

                                       {
        commandContinue(MYSQL_WAIT_WRITE);
    }

◆ writeTimeout()

void database::mariadb::MariaDBConnection::writeTimeout ( )

overrideprotectedvirtual

Reimplemented from core::eventreceiver::WriteEventReceiver.

Definition at line 243 of file MariaDBConnection.cpp.

                                         {
        commandContinue(MYSQL_WAIT_TIMEOUT);
    }

Member Data Documentation

◆ commandSequenceQueue

std::deque<MariaDBCommandSequence> database::mariadb::MariaDBConnection::commandSequenceQueue

private

Definition at line 102 of file MariaDBConnection.h.

◆ commandStartEvent

MariaDBCommandStartEvent database::mariadb::MariaDBConnection::commandStartEvent

private

Definition at line 107 of file MariaDBConnection.h.

◆ connected

bool database::mariadb::MariaDBConnection::connected = false

private

Definition at line 105 of file MariaDBConnection.h.

◆ currentCommand

MariaDBCommand* database::mariadb::MariaDBConnection::currentCommand = nullptr

private

Definition at line 104 of file MariaDBConnection.h.

◆ mariaDBClient

MariaDBClient* database::mariadb::MariaDBConnection::mariaDBClient

private

Definition at line 99 of file MariaDBConnection.h.

◆ mysql

MYSQL* database::mariadb::MariaDBConnection::mysql

private

Definition at line 100 of file MariaDBConnection.h.

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

database/mariadb/MariaDBConnection.h
database/mariadb/MariaDBConnection.cpp

Public Member Functions

Protected Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ MariaDBConnection() [1/2]

◆ MariaDBConnection() [2/2]

◆ ~MariaDBConnection()

Member Function Documentation

◆ checkStatus()

◆ commandCompleted()

◆ commandContinue()

◆ commandStart()

◆ execute_async()

◆ execute_sync()

◆ operator=()

◆ outOfBandEvent()

◆ outOfBandTimeout()

◆ readEvent()

◆ readTimeout()

◆ unmanaged()

◆ unobservedEvent()

◆ writeEvent()

◆ writeTimeout()

Member Data Documentation

◆ commandSequenceQueue

◆ commandStartEvent

◆ connected

◆ currentCommand

◆ mariaDBClient

◆ mysql