#include <TlsLegacySocketContext.h>

Inheritance diagram for apps::tlslegacy::TlsLegacySocketContext:

Collaboration diagram for apps::tlslegacy::TlsLegacySocketContext:

Public Types
enum class	Role { SERVER , CLIENT }

Public Member Functions
	TlsLegacySocketContext (core::socket::stream::SocketConnection *socketConnection, Role role)
Public Member Functions inherited from core::socket::stream::SocketContext
	SocketContext (core::socket::stream::SocketConnection *socketConnection)
void	sendToPeer (const char *chunk, std::size_t chunkLen) const final
bool	streamToPeer (core::pipe::Source *source) const
void	streamEof ()
std::size_t	readFromPeer (char *chunk, std::size_t chunklen) const final
void	setTimeout (const utils::Timeval &timeout) final
void	shutdownRead ()
void	shutdownWrite ()
void	close () override
std::size_t	getTotalSent () const override
std::size_t	getTotalQueued () const override
std::size_t	getTotalRead () const override
std::size_t	getTotalProcessed () const override
std::string	getOnlineSince () const override
std::string	getOnlineDuration () const override
SocketConnection *	getSocketConnection () const
void	sendToPeer (const std::string &data) const
Public Member Functions inherited from core::socket::SocketContext
	SocketContext (const SocketContext &)=delete
	SocketContext (SocketContext &&)=delete
SocketContext &	operator= (const SocketContext &)=delete
SocketContext &	operator= (SocketContext &&)=delete
void	sendToPeer (const std::string &data) const

Private Member Functions
void	onConnected () override
void	onDisconnected () override
bool	onSignal (int signum) override
std::size_t	onReceivedFromPeer () override
void	onClientLine (const std::string &line)
void	onServerLine (const std::string &line)
void	startLegacyRetryTimer (const std::string &payload)

Private Attributes
Role	role
std::string	inboundBuffer
bool	tlsReplySeen = false
bool	legacyReplySeen = false
bool	legacyPayloadSeen = false
core::timer::Timer	legacyRetryTimer

Additional Inherited Members
Protected Member Functions inherited from core::socket::stream::SocketContext
void	onWriteError (int errnum) override
void	onReadError (int errnum) override
std::size_t	readFromPeer ()
Protected Member Functions inherited from core::socket::SocketContext
	SocketContext ()=default
virtual	~SocketContext ()

Detailed Description

Definition at line 23 of file TlsLegacySocketContext.h.

Member Enumeration Documentation

◆ Role

enum class apps::tlslegacy::TlsLegacySocketContext::Role

strong

Enumerator
SERVER
CLIENT

Definition at line 25 of file TlsLegacySocketContext.h.

25{ SERVER, CLIENT };

Constructor & Destructor Documentation

◆ TlsLegacySocketContext()

apps::tlslegacy::TlsLegacySocketContext::TlsLegacySocketContext	(	core::socket::stream::SocketConnection *	socketConnection,
		Role	role )

explicit

Definition at line 23 of file TlsLegacySocketContext.cpp.

        : core::socket::stream::SocketContext(socketConnection)
        , role(role) {
    }

References role, and core::socket::stream::SocketContext::SocketContext().

Referenced by apps::tlslegacy::TlsLegacyClientSocketContextFactory::create(), and apps::tlslegacy::TlsLegacyServerSocketContextFactory::create().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

◆ onClientLine()

void apps::tlslegacy::TlsLegacySocketContext::onClientLine ( const std::string & line )

private

Definition at line 62 of file TlsLegacySocketContext.cpp.

                                                                   {
        if (line == TLS_ACK && !tlsReplySeen) {
            tlsReplySeen = true;
            VLOG(1) << getSocketConnection()->getConnectionName() << ": got TLS ack, initiating TLS shutdown handshake (close_notify) "
                    << line;
            shutdownWrite();
            startLegacyRetryTimer(LEGACY_HELLO);
        } else if (line == LEGACY_ACK && !legacyReplySeen) {
            legacyReplySeen = true;
            legacyRetryTimer.cancel();
            VLOG(1) << getSocketConnection()->getConnectionName() << ": got LEGACY ack -> post-TLS plaintext path works " << line;
            shutdownWrite();
        }
    }

References core::Timer::cancel(), core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), anonymous_namespace{TlsLegacySocketContext.cpp}::LEGACY_ACK, anonymous_namespace{TlsLegacySocketContext.cpp}::LEGACY_HELLO, legacyReplySeen, legacyRetryTimer, logger::LogMessage::LogMessage(), core::socket::stream::SocketContext::shutdownWrite(), startLegacyRetryTimer(), anonymous_namespace{TlsLegacySocketContext.cpp}::TLS_ACK, and tlsReplySeen.

Referenced by onReceivedFromPeer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ onConnected()

void apps::tlslegacy::TlsLegacySocketContext::onConnected ( )

overrideprivatevirtual

Implements core::socket::stream::SocketContext.

Definition at line 28 of file TlsLegacySocketContext.cpp.

                                             {
        VLOG(1) << getSocketConnection()->getConnectionName() << ": connected";
 
        if (role == Role::CLIENT) {
            sendToPeer(TLS_HELLO);
            VLOG(1) << getSocketConnection()->getConnectionName() << ": sent TLS greeting";
        }
    }

References CLIENT, core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), logger::LogMessage::LogMessage(), role, core::socket::SocketContext::sendToPeer(), and anonymous_namespace{TlsLegacySocketContext.cpp}::TLS_HELLO.

Here is the call graph for this function:

◆ onDisconnected()

void apps::tlslegacy::TlsLegacySocketContext::onDisconnected ( )

overrideprivatevirtual

Implements core::socket::stream::SocketContext.

Definition at line 37 of file TlsLegacySocketContext.cpp.

                                                {
        legacyRetryTimer.cancel();
        VLOG(1) << getSocketConnection()->getConnectionName() << ": disconnected";
    }

References core::Timer::cancel(), core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), legacyRetryTimer, and logger::LogMessage::LogMessage().

Here is the call graph for this function:

◆ onReceivedFromPeer()

std::size_t apps::tlslegacy::TlsLegacySocketContext::onReceivedFromPeer ( )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 91 of file TlsLegacySocketContext.cpp.

                                                         {
        char chunk[4096];
        const std::size_t chunkLen = readFromPeer(chunk, sizeof(chunk));
 
        if (chunkLen == 0) {
            return 0;
        }
 
        inboundBuffer.append(chunk, chunkLen);
 
        std::size_t pos = std::string::npos;
        while ((pos = inboundBuffer.find('\n')) != std::string::npos) {
            const std::string line = inboundBuffer.substr(0, pos + 1);
            inboundBuffer.erase(0, pos + 1);
 
            if (role == Role::CLIENT) {
                onClientLine(line);
            } else {
                onServerLine(line);
            }
        }
 
        return chunkLen;
    }

References CLIENT, inboundBuffer, onClientLine(), onServerLine(), core::socket::stream::SocketContext::readFromPeer(), and role.

Here is the call graph for this function:

◆ onServerLine()

void apps::tlslegacy::TlsLegacySocketContext::onServerLine ( const std::string & line )

private

Definition at line 77 of file TlsLegacySocketContext.cpp.

                                                                   {
        if (line == TLS_HELLO && !tlsReplySeen) {
            tlsReplySeen = true;
            sendToPeer(TLS_ACK);
            VLOG(1) << getSocketConnection()->getConnectionName() << ": TLS phase complete, waiting for peer close_notify " << line;
        } else if (line == LEGACY_HELLO && !legacyPayloadSeen) {
            legacyPayloadSeen = true;
            legacyRetryTimer.cancel();
            sendToPeer(LEGACY_ACK);
            VLOG(1) << getSocketConnection()->getConnectionName() << ": received LEGACY payload after TLS shutdown " << line;
            shutdownWrite();
        }
    }

References core::Timer::cancel(), core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), anonymous_namespace{TlsLegacySocketContext.cpp}::LEGACY_ACK, anonymous_namespace{TlsLegacySocketContext.cpp}::LEGACY_HELLO, legacyPayloadSeen, legacyRetryTimer, logger::LogMessage::LogMessage(), core::socket::SocketContext::sendToPeer(), core::socket::stream::SocketContext::shutdownWrite(), anonymous_namespace{TlsLegacySocketContext.cpp}::TLS_ACK, anonymous_namespace{TlsLegacySocketContext.cpp}::TLS_HELLO, and tlsReplySeen.

Referenced by onReceivedFromPeer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ onSignal()

bool apps::tlslegacy::TlsLegacySocketContext::onSignal ( int signum )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 42 of file TlsLegacySocketContext.cpp.

                                                                     {
        return true;
    }

◆ startLegacyRetryTimer()

void apps::tlslegacy::TlsLegacySocketContext::startLegacyRetryTimer ( const std::string & payload )

private

Definition at line 46 of file TlsLegacySocketContext.cpp.

                                                                               {
        legacyRetryTimer.cancel();
 
        legacyRetryTimer = core::timer::Timer::intervalTimer(
            [this, payload](const std::function<void()>& stop) {
                if (role == Role::CLIENT && legacyReplySeen) {
                    stop();
                    return;
                }
 
                sendToPeer(payload);
                VLOG(1) << getSocketConnection()->getConnectionName() << ": trying post-TLS legacy payload: " << payload;
            },
            utils::Timeval(0.5));
    }

References core::Timer::cancel(), CLIENT, core::socket::stream::SocketConnection::getConnectionName(), core::socket::stream::SocketContext::getSocketConnection(), core::timer::Timer::intervalTimer(), legacyReplySeen, legacyRetryTimer, logger::LogMessage::LogMessage(), core::timer::Timer::operator=(), role, core::socket::SocketContext::sendToPeer(), and utils::Timeval::Timeval().

Referenced by onClientLine().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ inboundBuffer

std::string apps::tlslegacy::TlsLegacySocketContext::inboundBuffer

private

Definition at line 40 of file TlsLegacySocketContext.h.

Referenced by onReceivedFromPeer().

◆ legacyPayloadSeen

bool apps::tlslegacy::TlsLegacySocketContext::legacyPayloadSeen = false

private

Definition at line 44 of file TlsLegacySocketContext.h.

Referenced by onServerLine().

◆ legacyReplySeen

bool apps::tlslegacy::TlsLegacySocketContext::legacyReplySeen = false

private

Definition at line 43 of file TlsLegacySocketContext.h.

Referenced by onClientLine(), and startLegacyRetryTimer().

◆ legacyRetryTimer

core::timer::Timer apps::tlslegacy::TlsLegacySocketContext::legacyRetryTimer

private

Definition at line 46 of file TlsLegacySocketContext.h.

Referenced by onClientLine(), onDisconnected(), onServerLine(), and startLegacyRetryTimer().

◆ role

Role apps::tlslegacy::TlsLegacySocketContext::role

private

Definition at line 39 of file TlsLegacySocketContext.h.

Referenced by onConnected(), onReceivedFromPeer(), startLegacyRetryTimer(), and TlsLegacySocketContext().

◆ tlsReplySeen

bool apps::tlslegacy::TlsLegacySocketContext::tlsReplySeen = false

private

Definition at line 42 of file TlsLegacySocketContext.h.

Referenced by onClientLine(), and onServerLine().

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

apps/tlslegacy/TlsLegacySocketContext.h
apps/tlslegacy/TlsLegacySocketContext.cpp

SNode.C

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

◆ Role

Constructor & Destructor Documentation

◆ TlsLegacySocketContext()

Member Function Documentation

◆ onClientLine()

◆ onConnected()

◆ onDisconnected()

◆ onReceivedFromPeer()

◆ onServerLine()

◆ onSignal()

◆ startLegacyRetryTimer()

Member Data Documentation

◆ inboundBuffer

◆ legacyPayloadSeen

◆ legacyReplySeen

◆ legacyRetryTimer

◆ role

◆ tlsReplySeen