#include <SocketConnection.h>

Inheritance diagram for core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >:

Collaboration diagram for core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >:

Public Member Functions
	SocketConnectionT ()=delete
int	getFd () const final
void	setTimeout (const utils::Timeval &timeout) final
void	setReadTimeout (const utils::Timeval &timeout) final
void	setWriteTimeout (const utils::Timeval &timeout) final
const SocketAddress &	getBindAddress () const final
const SocketAddress &	getLocalAddress () const final
const SocketAddress &	getRemoteAddress () const final
std::size_t	readFromPeer (char *chunk, std::size_t chunkLen) final
void	sendToPeer (const char *chunk, std::size_t chunkLen) final
bool	streamToPeer (core::pipe::Source *source) final
void	streamEof () final
void	shutdownRead () final
void	shutdownWrite () final
void	close () final
Config *	getConfig () const
std::size_t	getTotalSent () const override
std::size_t	getTotalQueued () const override
std::size_t	getTotalRead () const override
std::size_t	getTotalProcessed () const override
void	sendToPeer (const std::string &data)
Public Member Functions inherited from core::socket::stream::SocketConnection
	SocketConnection (int fd, const net::config::ConfigInstance *config)
	SocketConnection (const SocketConnection &)=delete
void	setSocketContext (SocketContext *socketContext)
void	sendToPeer (const std::string &data)
void	sentToPeer (const std::vector< uint8_t > &data)
void	sentToPeer (const std::vector< char > &data)
const std::string &	getInstanceName () const
const std::string &	getConnectionName () const
SocketContext *	getSocketContext () const
std::string	getOnlineSince () const
std::string	getOnlineDuration () const
const net::config::ConfigInstance *	getConfigInstance () const

Protected Types
using	Super = core::socket::stream::SocketConnection
using	Config = ConfigT
using	PhysicalSocket = PhysicalSocketT
using	SocketReader = SocketReaderT
using	SocketWriter = SocketWriterT
using	SocketAddress = typename PhysicalSocket::SocketAddress

Protected Member Functions
	SocketConnectionT (PhysicalSocket &&physicalSocket, const std::function< void()> &onDisconnect, const std::shared_ptr< Config > &config)
	~SocketConnectionT () override
void	doWriteShutdown (const std::function< void()> &onShutdown) override
void	onWriteError (int errnum)
void	onReadError (int errnum)
Protected Member Functions inherited from core::socket::stream::SocketConnection
virtual	~SocketConnection ()
void	setSocketContext (const std::shared_ptr< SocketContextFactory > &socketContextFactory)

Private Member Functions
void	onReceivedFromPeer (std::size_t available) final
bool	onSignal (int signum) final
void	readTimeout () final
void	writeTimeout () final
void	unobservedEvent () final

Private Attributes
PhysicalSocket	physicalSocket
std::function< void()>	onDisconnect
SocketAddress	localAddress {}
SocketAddress	remoteAddress {}
std::shared_ptr< Config >	config

Additional Inherited Members
Protected Attributes inherited from core::socket::stream::SocketConnection
core::socket::stream::SocketContext *	socketContext = nullptr
core::socket::stream::SocketContext *	newSocketContext = nullptr
std::string	instanceName
std::string	connectionName
std::chrono::time_point< std::chrono::system_clock >	onlineSinceTimePoint

Detailed Description

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>
class core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >

Definition at line 158 of file SocketConnection.h.

Member Typedef Documentation

◆ Config

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

using core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::Config = ConfigT

protected

Definition at line 165 of file SocketConnection.h.

◆ PhysicalSocket

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

using core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::PhysicalSocket = PhysicalSocketT

protected

Definition at line 166 of file SocketConnection.h.

◆ SocketAddress

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

using core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::SocketAddress = typename PhysicalSocket::SocketAddress

protected

Definition at line 169 of file SocketConnection.h.

◆ SocketReader

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

using core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::SocketReader = SocketReaderT

protected

Definition at line 167 of file SocketConnection.h.

◆ SocketWriter

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

using core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::SocketWriter = SocketWriterT

protected

Definition at line 168 of file SocketConnection.h.

◆ Super

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

using core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::Super = core::socket::stream::SocketConnection

protected

Definition at line 163 of file SocketConnection.h.

Constructor & Destructor Documentation

◆ SocketConnectionT() [1/2]

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::SocketConnectionT ( )

delete

◆ SocketConnectionT() [2/2]

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::SocketConnectionT	(	PhysicalSocket &&	physicalSocket,
		const std::function< void()> &	onDisconnect,
		const std::shared_ptr< Config > &	config )

protected

Definition at line 105 of file SocketConnection.hpp.

        : SocketConnection(physicalSocket.getFd(), config.get())
        , SocketReader(
              Super::getConnectionName(),
              [this](int errnum) {
                  {
                      const utils::PreserveErrno pe(errnum);
                      if (errno == 0) {
                          LOG(TRACE) << connectionName << " OnReadError: EOF received";
                      } else {
                          PLOG(TRACE) << connectionName << " OnReadError";
                      }
                  }
                  SocketReader::disable();
 
                  onReadError(errnum);
              },
              config->getReadTimeout(),
              config->getReadBlockSize(),
              config->getTerminateTimeout())
        , SocketWriter(
              Super::getConnectionName(),
              [this](int errnum) {
                  {
                      const utils::PreserveErrno pe(errnum);
                      PLOG(TRACE) << connectionName << " OnWriteError";
                  }
                  SocketWriter::disable();
 
                  onWriteError(errnum);
              },
              config->getWriteTimeout(),
              config->getWriteBlockSize(),
              config->getTerminateTimeout())
        , physicalSocket(std::move(physicalSocket))
        , onDisconnect(onDisconnect)
        , localAddress(getLocalSocketAddress<SocketAddress>(this->physicalSocket, config))
        , remoteAddress(getRemoteSocketAddress<SocketAddress>(this->physicalSocket, config))
        , config(config) {
        if (!SocketReader::enable(this->physicalSocket.getFd())) {
            delete this;
        } else if (!SocketWriter::enable(this->physicalSocket.getFd())) {
            delete this;
        } else {
            SocketWriter::suspend();
        }
    }

References core::socket::stream::SocketConnection::connectionName, core::socket::stream::SocketConnection::getConnectionName(), logger::LogMessage::LogMessage(), onReadError(), utils::PreserveErrno::PreserveErrno(), and logger::TRACE.

Here is the call graph for this function:

◆ ~SocketConnectionT()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::~SocketConnectionT ( )

overrideprotected

Definition at line 156 of file SocketConnection.hpp.

156 {

157 }

Member Function Documentation

◆ close()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::close ( )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 252 of file SocketConnection.hpp.

                                                                                      {
        if (SocketWriter::isEnabled()) {
            SocketWriter::disable();
        }
        if (SocketReader::isEnabled()) {
            SocketReader::disable();
        }
    }

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

Here is the caller graph for this function:

◆ doWriteShutdown()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::doWriteShutdown ( const std::function< void()> & onShutdown )

overrideprotected

Definition at line 287 of file SocketConnection.hpp.

                                                                                                                                     {
        errno = 0;
 
        setTimeout(SocketWriter::terminateTimeout);
 
        LOG(TRACE) << connectionName << ": Shutdown (WR)";
 
        if (physicalSocket.shutdown(PhysicalSocket::SHUT::WR) == 0) {
            LOG(DEBUG) << connectionName << " Shutdown (WR): success";
        } else {
            PLOG(ERROR) << connectionName << " Shutdown (WR)";
        }
 
        onShutdown();
    }

References core::socket::stream::SocketConnection::connectionName, logger::DEBUG, logger::ERROR, logger::LogMessage::LogMessage(), physicalSocket, setTimeout(), and logger::TRACE.

Here is the call graph for this function:

◆ getBindAddress()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

const SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::SocketAddress & core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getBindAddress ( ) const

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 181 of file SocketConnection.hpp.

                                                                                                {
        return physicalSocket.getBindAddress();
    }

◆ getConfig()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

Config * core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getConfig ( ) const

Definition at line 262 of file SocketConnection.hpp.

                                                                                                   {
        return config.get();
    }

References config.

◆ getFd()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

int core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getFd ( ) const

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 175 of file SocketConnection.hpp.

                                                                                           {
        return physicalSocket.getFd();
    }

References physicalSocket.

◆ getLocalAddress()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

const SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::SocketAddress & core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getLocalAddress ( ) const

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 187 of file SocketConnection.hpp.

                                                                                                 {
        return localAddress;
    }

Referenced by tls::getClient(), and legacy::getLegacyClient().

Here is the caller graph for this function:

◆ getRemoteAddress()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

const SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::SocketAddress & core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getRemoteAddress ( ) const

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 193 of file SocketConnection.hpp.

                                                                                                  {
        return remoteAddress;
    }

References remoteAddress.

Referenced by tls::getClient(), and legacy::getLegacyClient().

Here is the caller graph for this function:

◆ getTotalProcessed()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

std::size_t core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getTotalProcessed ( ) const

overridevirtual

Implements core::socket::stream::SocketConnection.

Definition at line 282 of file SocketConnection.hpp.

                                                                                                             {
        return SocketReader::getTotalProcessed();
    }

◆ getTotalQueued()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

std::size_t core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getTotalQueued ( ) const

overridevirtual

Implements core::socket::stream::SocketConnection.

Definition at line 272 of file SocketConnection.hpp.

                                                                                                          {
        return SocketWriter::getTotalQueued();
    }

◆ getTotalRead()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

std::size_t core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getTotalRead ( ) const

overridevirtual

Implements core::socket::stream::SocketConnection.

Definition at line 277 of file SocketConnection.hpp.

                                                                                                        {
        return SocketReader::getTotalRead();
    }

◆ getTotalSent()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

std::size_t core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::getTotalSent ( ) const

overridevirtual

Implements core::socket::stream::SocketConnection.

Definition at line 267 of file SocketConnection.hpp.

                                                                                                        {
        return SocketWriter::getTotalSent();
    }

◆ onReadError()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::onReadError ( int errnum )

protected

Definition at line 332 of file SocketConnection.hpp.

                                                                                                      {
        socketContext->onReadError(errnum);
    }

References core::socket::stream::SocketContext::onReadError(), and core::socket::stream::SocketConnection::socketContext.

Referenced by SocketConnectionT().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ onReceivedFromPeer()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::onReceivedFromPeer ( std::size_t available )

finalprivate

Definition at line 304 of file SocketConnection.hpp.

                                                                                                                      {
        std::size_t consumed = socketContext->readFromPeer();
 
        if (available != 0 && consumed == 0) {
            LOG(TRACE) << connectionName << ": Data available: " << available << " but nothing read";
 
            close();
 
            delete newSocketContext;
            newSocketContext = nullptr;
        } else if (newSocketContext != nullptr) { // Perform a pending SocketContextSwitch
            socketContext->detach();
 
            socketContext = newSocketContext;
            newSocketContext = nullptr;
 
            socketContext->attach();
 
            LOG(DEBUG) << connectionName << " SocketConnection: switch completed";
        }
    }

References core::socket::stream::SocketContext::attach(), close(), core::socket::stream::SocketConnection::connectionName, logger::DEBUG, core::socket::stream::SocketContext::detach(), logger::LogMessage::LogMessage(), core::socket::stream::SocketConnection::newSocketContext, core::socket::stream::SocketContext::readFromPeer(), core::socket::stream::SocketConnection::socketContext, and logger::TRACE.

Here is the call graph for this function:

◆ onSignal()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

bool core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::onSignal ( int signum )

finalprivate

Definition at line 337 of file SocketConnection.hpp.

                                                                                                   {
        switch (signum) {
            case SIGINT:
                [[fallthrough]];
            case SIGTERM:
                [[fallthrough]];
            case SIGABRT:
                [[fallthrough]];
            case SIGHUP:
                LOG(DEBUG) << connectionName << ": Shutting down due to signal '" << utils::system::strsignal(signum) << "' (SIG"
                           << utils::system::sigabbrev_np(signum) << " [" << signum << "])";
                break;
            case SIGALRM:
                break;
        }
 
        return socketContext != nullptr ? socketContext->onSignal(signum) : true;
    }

References core::socket::stream::SocketConnection::connectionName, logger::DEBUG, logger::LogMessage::LogMessage(), core::socket::SocketContext::onSignal(), utils::system::sigabbrev_np(), core::socket::stream::SocketConnection::socketContext, and utils::system::strsignal().

Here is the call graph for this function:

◆ onWriteError()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::onWriteError ( int errnum )

protected

Definition at line 327 of file SocketConnection.hpp.

                                                                                                       {
        socketContext->onWriteError(errnum);
    }

References core::socket::stream::SocketContext::onWriteError(), and core::socket::stream::SocketConnection::socketContext.

Here is the call graph for this function:

◆ readFromPeer()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

std::size_t core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::readFromPeer	(	char *	chunk,
		std::size_t	chunkLen )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 198 of file SocketConnection.hpp.

                                                                                                                                 {
        std::size_t ret = 0;
 
        if (newSocketContext == nullptr) {
            ret = SocketReader::readFromPeer(chunk, chunkLen);
        } else {
            LOG(TRACE) << connectionName << " ReadFromPeer: New SocketContext != nullptr: SocketContextSwitch still in progress";
        }
 
        return ret;
    }

◆ readTimeout()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::readTimeout ( )

finalprivate

Definition at line 357 of file SocketConnection.hpp.

                                                                                            {
        LOG(WARNING) << connectionName << ": Read timeout";
        close();
    }

References close(), core::socket::stream::SocketConnection::connectionName, logger::LogMessage::LogMessage(), and logger::WARNING.

Here is the call graph for this function:

◆ sendToPeer() [1/2]

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::sendToPeer	(	const char *	chunk,
		std::size_t	chunkLen )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 211 of file SocketConnection.hpp.

                                                                                                                                {
        SocketWriter::sendToPeer(chunk, chunkLen);
    }

◆ sendToPeer() [2/2]

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

void core::socket::stream::SocketConnection::sendToPeer ( const std::string & data )

Definition at line 98 of file SocketConnection.cpp.

                                                           {
        sendToPeer(data.data(), data.size());
    }

◆ setReadTimeout()

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

void core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::setReadTimeout ( const utils::Timeval & timeout )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 166 of file SocketConnection.hpp.

                                                                                                                              {
        SocketReader::setTimeout(timeout);
    }

Referenced by setTimeout().

Here is the caller graph for this function:

◆ setTimeout()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::setTimeout ( const utils::Timeval & timeout )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 160 of file SocketConnection.hpp.

                                                                                                                      {
        setReadTimeout(timeout);
        setWriteTimeout(timeout);
    }

References setReadTimeout(), and setWriteTimeout().

Referenced by doWriteShutdown().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ setWriteTimeout()

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

void core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::setWriteTimeout ( const utils::Timeval & timeout )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 170 of file SocketConnection.hpp.

                                                                                                                               {
        SocketWriter::setTimeout(timeout);
    }

Referenced by setTimeout().

Here is the caller graph for this function:

◆ shutdownRead()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::shutdownRead ( )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 226 of file SocketConnection.hpp.

                                                                                             {
        LOG(TRACE) << connectionName << ": Shutdown (RD)";
 
        SocketReader::shutdownRead();
 
        if (physicalSocket.shutdown(PhysicalSocket::SHUT::RD) == 0) {
            LOG(DEBUG) << connectionName << " Shutdown (RD): success";
        } else {
            PLOG(ERROR) << connectionName << " Shutdown (RD)";
        }
    }

References core::socket::stream::SocketConnection::connectionName, logger::DEBUG, logger::ERROR, logger::LogMessage::LogMessage(), physicalSocket, and logger::TRACE.

Here is the call graph for this function:

◆ shutdownWrite()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::shutdownWrite ( )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 239 of file SocketConnection.hpp.

                                                                                              {
        if (!SocketWriter::shutdownInProgress) {
            LOG(TRACE) << connectionName << ": Stop writing";
 
            SocketWriter::shutdownWrite([this]() {
                if (SocketWriter::isEnabled()) {
                    SocketWriter::disable();
                }
            });
        }
    }

References core::socket::stream::SocketConnection::connectionName, logger::LogMessage::LogMessage(), and logger::TRACE.

Here is the call graph for this function:

◆ streamEof()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::streamEof ( )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 221 of file SocketConnection.hpp.

                                                                                          {
        SocketWriter::streamEof();
    }

◆ streamToPeer()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

bool core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::streamToPeer ( core::pipe::Source * source )

finalvirtual

Implements core::socket::stream::SocketConnection.

Definition at line 216 of file SocketConnection.hpp.

                                                                                                                   {
        return SocketWriter::streamToPeer(source);
    }

◆ unobservedEvent()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::unobservedEvent ( )

finalprivate

Definition at line 369 of file SocketConnection.hpp.

                                                                                                {
        if (socketContext != nullptr) {
            socketContext->detach();
        }
 
        onDisconnect();
 
        LOG(DEBUG) << connectionName << ": disconnected";
 
        delete this;
    }

References core::socket::stream::SocketConnection::connectionName, logger::DEBUG, core::socket::stream::SocketContext::detach(), logger::LogMessage::LogMessage(), onDisconnect, and core::socket::stream::SocketConnection::socketContext.

Here is the call graph for this function:

◆ writeTimeout()

template<typename PhysicalSocket, typename SocketReader, typename SocketWriter, typename Config>

void core::socket::stream::SocketConnectionT< PhysicalSocket, SocketReader, SocketWriter, Config >::writeTimeout ( )

finalprivate

Definition at line 363 of file SocketConnection.hpp.

                                                                                             {
        LOG(WARNING) << connectionName << ": Write timeout";
        close();
    }

References close(), core::socket::stream::SocketConnection::connectionName, logger::LogMessage::LogMessage(), and logger::WARNING.

Here is the call graph for this function:

Member Data Documentation

◆ config

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

std::shared_ptr<Config> core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::config

private

Definition at line 235 of file SocketConnection.h.

Referenced by getConfig().

◆ localAddress

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

SocketAddress core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::localAddress {}

private

Definition at line 232 of file SocketConnection.h.

232{};

◆ onDisconnect

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

std::function<void()> core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::onDisconnect

private

Definition at line 230 of file SocketConnection.h.

Referenced by unobservedEvent().

◆ physicalSocket

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

PhysicalSocket core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::physicalSocket

private

Definition at line 228 of file SocketConnection.h.

Referenced by doWriteShutdown(), getFd(), and shutdownRead().

◆ remoteAddress

template<typename PhysicalSocketT, typename SocketReaderT, typename SocketWriterT, typename ConfigT>

SocketAddress core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::remoteAddress {}

private

Definition at line 233 of file SocketConnection.h.

233{};

Referenced by getRemoteAddress().

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

core/socket/stream/SocketConnection.h
core/socket/stream/SocketConnection.hpp

SNode.C

Public Member Functions

Protected Types

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ Config

◆ PhysicalSocket

◆ SocketAddress

◆ SocketReader

◆ SocketWriter

◆ Super

Constructor & Destructor Documentation

◆ SocketConnectionT() [1/2]

◆ SocketConnectionT() [2/2]

◆ ~SocketConnectionT()

Member Function Documentation

◆ close()

◆ doWriteShutdown()

◆ getBindAddress()

◆ getConfig()

◆ getFd()

◆ getLocalAddress()

◆ getRemoteAddress()

◆ getTotalProcessed()

◆ getTotalQueued()

◆ getTotalRead()

◆ getTotalSent()

◆ onReadError()

◆ onReceivedFromPeer()

◆ onSignal()

◆ onWriteError()

◆ readFromPeer()

◆ readTimeout()

◆ sendToPeer() [1/2]

◆ sendToPeer() [2/2]

◆ setReadTimeout()

◆ setTimeout()

◆ setWriteTimeout()

◆ shutdownRead()

◆ shutdownWrite()

◆ streamEof()

◆ streamToPeer()

◆ unobservedEvent()

◆ writeTimeout()

Member Data Documentation

◆ config

◆ localAddress

◆ onDisconnect

◆ physicalSocket

◆ remoteAddress