#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 86 of file MariaDBConnection.h.

Constructor & Destructor Documentation

◆ MariaDBConnection() [1/2]

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

explicit

Definition at line 62 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 108 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 195 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 179 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 169 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 150 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 127 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 137 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 257 of file MariaDBConnection.cpp.

                                           {
        commandContinue(MYSQL_WAIT_EXCEPT);
    }

◆ outOfBandTimeout()

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

overrideprotectedvirtual

Reimplemented from core::eventreceiver::ExceptionalConditionEventReceiver.

Definition at line 269 of file MariaDBConnection.cpp.

                                             {
        commandContinue(MYSQL_WAIT_TIMEOUT);
    }

◆ readEvent()

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

overrideprotectedvirtual

Implements core::eventreceiver::ReadEventReceiver.

Definition at line 249 of file MariaDBConnection.cpp.

                                      {
        commandContinue(MYSQL_WAIT_READ);
    }

◆ readTimeout()

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

overrideprotectedvirtual

Reimplemented from core::eventreceiver::ReadEventReceiver.

Definition at line 261 of file MariaDBConnection.cpp.

                                        {
        commandContinue(MYSQL_WAIT_TIMEOUT);
    }

◆ unmanaged()

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

Definition at line 191 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 273 of file MariaDBConnection.cpp.

                                            {
        delete this;
    }

◆ writeEvent()

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

overrideprotectedvirtual

Implements core::eventreceiver::WriteEventReceiver.

Definition at line 253 of file MariaDBConnection.cpp.

                                       {
        commandContinue(MYSQL_WAIT_WRITE);
    }

◆ writeTimeout()

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

overrideprotectedvirtual

Reimplemented from core::eventreceiver::WriteEventReceiver.

Definition at line 265 of file MariaDBConnection.cpp.

                                         {
        commandContinue(MYSQL_WAIT_TIMEOUT);
    }

Member Data Documentation

◆ commandSequenceQueue

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

private

Definition at line 124 of file MariaDBConnection.h.

◆ commandStartEvent

MariaDBCommandStartEvent database::mariadb::MariaDBConnection::commandStartEvent

private

Definition at line 129 of file MariaDBConnection.h.

◆ connected

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

private

Definition at line 127 of file MariaDBConnection.h.

◆ currentCommand

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

private

Definition at line 126 of file MariaDBConnection.h.

◆ mariaDBClient

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

private

Definition at line 121 of file MariaDBConnection.h.

◆ mysql

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

private

Definition at line 122 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