#include <TLSHandshake.h>

Inheritance diagram for core::socket::stream::tls::TLSHandshake:

Collaboration diagram for core::socket::stream::tls::TLSHandshake:

Static Public Member Functions
static void	doHandshake (const std::string &instanceName, SSL *ssl, const std::function< void(void)> &onSuccess, const std::function< void(void)> &onTimeout, const std::function< void(int)> &onStatus, const utils::Timeval &timeout)

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

Private Member Functions
	TLSHandshake (const std::string &instanceName, SSL *ssl, const std::function< void(void)> &onSuccess, const std::function< void(void)> &onTimeout, const std::function< void(int)> &onStatus, const utils::Timeval &timeout)

void	readEvent () final

void	writeEvent () final

void	signalEvent (int signum) final

void	readTimeout () final

void	writeTimeout () final

void	unobservedEvent () final

Private Attributes
SSL *	ssl = nullptr

std::function< void(void)>	onSuccess

std::function< void(void)>	onTimeout

std::function< void(int)>	onStatus

bool	timeoutTriggered

int	fd = -1

Additional Inherited Members
Public 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)

Public 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

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

Protected Member Functions inherited from core::DescriptorEventReceiver
bool	enable (int fd)

void	disable ()

void	suspend ()

void	resume ()

Protected Member Functions inherited from core::Observer
void	observed ()

void	unObserved ()

	Observer ()=default

	Observer (Observer &)=delete

	Observer (Observer &&)=delete

virtual	~Observer ()

Protected Member Functions inherited from core::EventReceiver
virtual	~EventReceiver ()=default

	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

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

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

Detailed Description

Definition at line 68 of file TLSHandshake.h.

Constructor & Destructor Documentation

◆ TLSHandshake()

core::socket::stream::tls::TLSHandshake::TLSHandshake	(	const std::string &	instanceName,
		SSL *	ssl,
		const std::function< void(void)> &	onSuccess,
		const std::function< void(void)> &	onTimeout,
		const std::function< void(int)> &	onStatus,
		const utils::Timeval &	timeout
	)

private

Definition at line 61 of file TLSHandshake.cpp.

        : ReadEventReceiver(instanceName + " SSL/TLS: Handshake", timeout)
        , WriteEventReceiver(instanceName + " SSL/TLS: Handshake", timeout)
        , ssl(ssl)
        , onSuccess(onSuccess)
        , onTimeout(onTimeout)
        , onStatus(onStatus)
        , timeoutTriggered(false)
        , fd(SSL_get_fd(ssl)) {
        const int ret = SSL_do_handshake(ssl);
 
        int sslErr = SSL_ERROR_NONE;
        if (ret < 1) {
            sslErr = SSL_get_error(ssl, ret);
        }
 
        if (!ReadEventReceiver::enable(fd)) {
            delete this;
        } else if (!WriteEventReceiver::enable(fd)) {
            ReadEventReceiver::disable();
        } else {
            ReadEventReceiver::suspend();
            WriteEventReceiver::suspend();
 
            switch (sslErr) {
                case SSL_ERROR_WANT_READ:
                    ReadEventReceiver::resume();
                    break;
                case SSL_ERROR_WANT_WRITE:
                    WriteEventReceiver::resume();
                    break;
                case SSL_ERROR_NONE:
                case SSL_ERROR_ZERO_RETURN:
                    ReadEventReceiver::disable();
                    WriteEventReceiver::disable();
                    onSuccess();
                    break;
                default:
                    ReadEventReceiver::disable();
                    WriteEventReceiver::disable();
                    onStatus(sslErr);
                    break;
            }
        }
    }

References core::DescriptorEventReceiver::disable(), core::DescriptorEventReceiver::enable(), fd, onStatus, onSuccess, onTimeout, core::eventreceiver::ReadEventReceiver::ReadEventReceiver(), core::DescriptorEventReceiver::resume(), ssl, core::DescriptorEventReceiver::suspend(), timeoutTriggered, and core::eventreceiver::WriteEventReceiver::WriteEventReceiver().

Referenced by doHandshake().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

◆ doHandshake()

void core::socket::stream::tls::TLSHandshake::doHandshake	(	const std::string &	instanceName,
		SSL *	ssl,
		const std::function< void(void)> &	onSuccess,
		const std::function< void(void)> &	onTimeout,
		const std::function< void(int)> &	onStatus,
		const utils::Timeval &	timeout
	)

static

Definition at line 52 of file TLSHandshake.cpp.

                                                                {
        new TLSHandshake(instanceName, ssl, onSuccess, onTimeout, onStatus, timeout);
    }

References TLSHandshake().

Referenced by core::socket::stream::tls::SocketConnection< PhysicalSocketT, ConfigT >::doSSLHandshake().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ readEvent()

void core::socket::stream::tls::TLSHandshake::readEvent ( )

finalprivatevirtual

Implements core::eventreceiver::ReadEventReceiver.

Definition at line 112 of file TLSHandshake.cpp.

                                 {
        const int ret = SSL_do_handshake(ssl);
 
        int sslErr = SSL_ERROR_NONE;
        if (ret < 1) {
            sslErr = SSL_get_error(ssl, ret);
        }
 
        switch (sslErr) {
            case SSL_ERROR_WANT_READ:
                break;
            case SSL_ERROR_WANT_WRITE:
                ReadEventReceiver::suspend();
                WriteEventReceiver::resume();
                break;
            case SSL_ERROR_NONE:
            case SSL_ERROR_ZERO_RETURN:
                ReadEventReceiver::disable();
                WriteEventReceiver::disable();
                onSuccess();
                break;
            default:
                ReadEventReceiver::disable();
                WriteEventReceiver::disable();
                onStatus(sslErr);
                break;
        }
    }

References core::DescriptorEventReceiver::disable(), onStatus, onSuccess, core::DescriptorEventReceiver::resume(), ssl, and core::DescriptorEventReceiver::suspend().

Here is the call graph for this function:

◆ readTimeout()

void core::socket::stream::tls::TLSHandshake::readTimeout ( )

finalprivatevirtual

Reimplemented from core::eventreceiver::ReadEventReceiver.

Definition at line 170 of file TLSHandshake.cpp.

                                   {
        if (!timeoutTriggered) {
            timeoutTriggered = true;
            ReadEventReceiver::disable();
            WriteEventReceiver::disable();
            onTimeout();
        }
    }

References core::DescriptorEventReceiver::disable(), onTimeout, and timeoutTriggered.

Here is the call graph for this function:

◆ signalEvent()

void core::socket::stream::tls::TLSHandshake::signalEvent ( int signum )

finalprivatevirtual

Reimplemented from core::eventreceiver::ReadEventReceiver.

Definition at line 188 of file TLSHandshake.cpp.

188 { // Do nothing on signal event

189 }

◆ unobservedEvent()

void core::socket::stream::tls::TLSHandshake::unobservedEvent ( )

finalprivatevirtual

Implements core::Observer.

Definition at line 191 of file TLSHandshake.cpp.

                                       {
        delete this;
    }

◆ writeEvent()

void core::socket::stream::tls::TLSHandshake::writeEvent ( )

finalprivatevirtual

Implements core::eventreceiver::WriteEventReceiver.

Definition at line 141 of file TLSHandshake.cpp.

                                  {
        const int ret = SSL_do_handshake(ssl);
 
        int sslErr = SSL_ERROR_NONE;
        if (ret < 1) {
            sslErr = SSL_get_error(ssl, ret);
        }
 
        switch (sslErr) {
            case SSL_ERROR_WANT_READ:
                WriteEventReceiver::suspend();
                ReadEventReceiver::resume();
                break;
            case SSL_ERROR_WANT_WRITE:
                break;
            case SSL_ERROR_NONE:
            case SSL_ERROR_ZERO_RETURN:
                ReadEventReceiver::disable();
                WriteEventReceiver::disable();
                onSuccess();
                break;
            default:
                ReadEventReceiver::disable();
                WriteEventReceiver::disable();
                onStatus(sslErr);
                break;
        }
    }

References core::DescriptorEventReceiver::disable(), onStatus, onSuccess, core::DescriptorEventReceiver::resume(), ssl, and core::DescriptorEventReceiver::suspend().

Here is the call graph for this function:

◆ writeTimeout()

void core::socket::stream::tls::TLSHandshake::writeTimeout ( )

finalprivatevirtual

Reimplemented from core::eventreceiver::WriteEventReceiver.

Definition at line 179 of file TLSHandshake.cpp.

                                    {
        if (!timeoutTriggered) {
            timeoutTriggered = true;
            ReadEventReceiver::disable();
            WriteEventReceiver::disable();
            onTimeout();
        }
    }

References core::DescriptorEventReceiver::disable(), onTimeout, and timeoutTriggered.

Here is the call graph for this function:

Member Data Documentation

◆ fd

int core::socket::stream::tls::TLSHandshake::fd = -1

private

Definition at line 103 of file TLSHandshake.h.

Referenced by TLSHandshake().

◆ onStatus

std::function<void(int)> core::socket::stream::tls::TLSHandshake::onStatus

private

Definition at line 99 of file TLSHandshake.h.

Referenced by readEvent(), TLSHandshake(), and writeEvent().

◆ onSuccess

std::function<void(void)> core::socket::stream::tls::TLSHandshake::onSuccess

private

Definition at line 97 of file TLSHandshake.h.

Referenced by readEvent(), TLSHandshake(), and writeEvent().

◆ onTimeout

std::function<void(void)> core::socket::stream::tls::TLSHandshake::onTimeout

private

Definition at line 98 of file TLSHandshake.h.

Referenced by readTimeout(), TLSHandshake(), and writeTimeout().

◆ ssl

SSL* core::socket::stream::tls::TLSHandshake::ssl = nullptr

private

Definition at line 96 of file TLSHandshake.h.

Referenced by readEvent(), TLSHandshake(), and writeEvent().

◆ timeoutTriggered

bool core::socket::stream::tls::TLSHandshake::timeoutTriggered

private

Definition at line 101 of file TLSHandshake.h.

Referenced by readTimeout(), TLSHandshake(), and writeTimeout().

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

core/socket/stream/tls/TLSHandshake.h
core/socket/stream/tls/TLSHandshake.cpp

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ TLSHandshake()

Member Function Documentation

◆ doHandshake()

◆ readEvent()

◆ readTimeout()

◆ signalEvent()

◆ unobservedEvent()

◆ writeEvent()

◆ writeTimeout()

Member Data Documentation

◆ fd

◆ onStatus

◆ onSuccess

◆ onTimeout

◆ ssl

◆ timeoutTriggered