#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 (bool forceClose) 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

virtual void	sendToPeer (const char *chunk, std::size_t chunkLen)=0

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	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 *	getConfig () 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()> &onDisconnectm, 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

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()> &	onDisconnectm,
		const std::shared_ptr< Config > &	config
	)

protected

Definition at line 107 of file SocketConnection.hpp.

        : SocketConnection(physicalSocket.getFd(), config.get())
        , SocketReader(
              instanceName + " [" + std::to_string(physicalSocket.getFd()) + "]",
              [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(
              instanceName + " [" + std::to_string(physicalSocket.getFd()) + "]",
              [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(onDisconnectm)
        , 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::instanceName, core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::onReadError(), and utils::PreserveErrno::PreserveErrno().

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 158 of file SocketConnection.hpp.

158 {

159 }

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 249 of file SocketConnection.hpp.

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

Referenced by core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::readTimeout(), core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::shutdownWrite(), and core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 284 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, core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::physicalSocket, and core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::setTimeout().

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 183 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 259 of file SocketConnection.hpp.

                                                                                                   {
        return *config;
    }

References core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 177 of file SocketConnection.hpp.

                                                                                           {
        return physicalSocket.getFd();
    }

References core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 189 of file SocketConnection.hpp.

                                                                                                 {
        return localAddress;
    }

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

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 195 of file SocketConnection.hpp.

                                                                                                  {
        return remoteAddress;
    }

References core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::remoteAddress.

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

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 279 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 269 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 274 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 264 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 311 of file SocketConnection.hpp.

                                                                                                      {
        socketContext->onReadError(errnum);
    }

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

Referenced by core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 301 of file SocketConnection.hpp.

                                                                                                                      {
        socketContext->readFromPeer(available);
    }

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

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 316 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 '" << 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, core::socket::SocketContext::onSignal(), utils::system::sigabbrev_np(), and core::socket::stream::SocketConnection::socketContext.

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 306 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 200 of file SocketConnection.hpp.

                                                                                                                                 {
        return SocketReader::readFromPeer(chunk, chunkLen);
    }

◆ readTimeout()

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

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

finalprivate

Definition at line 336 of file SocketConnection.hpp.

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

References core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::close(), and core::socket::stream::SocketConnection::connectionName.

Here is the call graph for this function:

◆ sendToPeer() [1/3]

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 205 of file SocketConnection.hpp.

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

◆ sendToPeer() [2/3]

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

virtual void core::socket::stream::SocketConnection::sendToPeer	(	const char *	chunk,
		std::size_t	chunkLen
	)

virtual

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

◆ sendToPeer() [3/3]

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

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

Definition at line 99 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 168 of file SocketConnection.hpp.

                                                                                                                              {
        SocketReader::setTimeout(timeout);
    }

Referenced by core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 162 of file SocketConnection.hpp.

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

References core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::setReadTimeout(), and core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::setWriteTimeout().

Referenced by core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 172 of file SocketConnection.hpp.

                                                                                                                               {
        SocketWriter::setTimeout(timeout);
    }

Referenced by core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 220 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)";
        }
    }

◆ shutdownWrite()

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

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

finalvirtual

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

Definition at line 233 of file SocketConnection.hpp.

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

References core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::close(), and core::socket::stream::SocketConnection::connectionName.

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 215 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 210 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 348 of file SocketConnection.hpp.

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

References core::socket::stream::SocketConnection::connectionName, core::socket::stream::SocketContext::detach(), core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 342 of file SocketConnection.hpp.

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

References core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::close(), and core::socket::stream::SocketConnection::connectionName.

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 core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::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 core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::doWriteShutdown(), and core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::getFd().

◆ 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 core::socket::stream::SocketConnectionT< PhysicalSocketT, SocketReaderT, SocketWriterT, ConfigT >::getRemoteAddress().

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

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

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/3]

◆ sendToPeer() [2/3]

◆ sendToPeer() [3/3]

◆ setReadTimeout()

◆ setTimeout()

◆ setWriteTimeout()

◆ shutdownRead()

◆ shutdownWrite()

◆ streamEof()

◆ streamToPeer()

◆ unobservedEvent()

◆ writeTimeout()

Member Data Documentation

◆ config

◆ localAddress

◆ onDisconnect

◆ physicalSocket

◆ remoteAddress