core::socket::stream Namespace Reference

Namespaces
namespace	legacy
namespace	tls
namespace	stream

Classes
class	SocketContext
class	SocketConnection
class	SocketConnectionT
class	ClientFlowController
class	ServerFlowController
class	SocketContextFactory
class	SocketReader
class	SocketWriter
class	SocketConnector
class	SocketAcceptor
class	FlowController
class	SocketClient
class	SocketServer

Functions
template<typename SocketAddress, typename PhysicalSocket, typename Config>
SocketAddress	getLocalSocketAddress (PhysicalSocket &physicalSocket, Config &config)
template<typename SocketAddress, typename PhysicalSocket, typename Config>
SocketAddress	getRemoteSocketAddress (PhysicalSocket &physicalSocket, Config &config)
template<typename SocketClient, typename... Args>
SocketClient	Client (const std::string &instanceName, const std::function< void(typename SocketClient::Config *)> &configurator, Args &&... socketContextFactoryArgs)
template<typename SocketClient, typename... Args>
SocketClient	Client (const std::string &instanceName, Args &&... socketContextFactoryArgs)
template<typename SocketServer, typename... Args>
SocketServer	Server (const std::string &instanceName, const std::function< void(typename SocketServer::Config *)> &configurator, Args &&... socketContextFactoryArgs)
template<typename SocketServer, typename... Args>
SocketServer	Server (const std::string &instanceName, Args &&... socketContextFactoryArgs)

Variables
template<typename ConcreteFlowController>
uint64_t	FlowController< ConcreteFlowController >::idCounter = 0

Function Documentation

Client() [1/2]

template<typename SocketClient, typename... Args>

SocketClient core::socket::stream::Client	(	const std::string &	instanceName,
		Args &&...	socketContextFactoryArgs )

Definition at line 361 of file SocketClient.h.

                                                                                           {
        return SocketClient(instanceName, std::forward<Args>(socketContextFactoryArgs)...);
    }

Client() [2/2]

template<typename SocketClient, typename... Args>

SocketClient core::socket::stream::Client	(	const std::string &	instanceName,
		const std::function< void(typename SocketClient::Config *)> &	configurator,
		Args &&...	socketContextFactoryArgs )

Definition at line 350 of file SocketClient.h.

                                                            {
        const SocketClient socketClient(instanceName, std::forward<Args>(socketContextFactoryArgs)...);
 
        configurator(socketClient.getConfig());
 
        return socketClient;
    }

getLocalSocketAddress()

template<typename SocketAddress, typename PhysicalSocket, typename Config>

SocketAddress core::socket::stream::getLocalSocketAddress	(	PhysicalSocket &	physicalSocket,
		Config &	config )

Definition at line 59 of file SocketConnection.hpp.

                                                                                        {
        typename SocketAddress::SockAddr localSockAddr;
        typename SocketAddress::SockLen localSockAddrLen = sizeof(typename SocketAddress::SockAddr);
 
        SocketAddress localPeerAddress;
        if (physicalSocket.getSockName(localSockAddr, localSockAddrLen) == 0) {
            try {
                localPeerAddress = config->Local::getSocketAddress(localSockAddr, localSockAddrLen);
                LOG(TRACE) << config->getInstanceName() << " [" << physicalSocket.getFd() << "]" << std::setw(25)
                           << "  PeerAddress (local): " << localPeerAddress.toString();
            } catch (const typename SocketAddress::BadSocketAddress& badSocketAddress) {
                LOG(WARNING) << config->getInstanceName() << " [" << physicalSocket.getFd() << "]" << std::setw(25)
                             << "  PeerAddress (local): " << badSocketAddress.what();
            }
        } else {
            PLOG(WARNING) << config->getInstanceName() << " [" << physicalSocket.getFd() << "]" << std::setw(25)
                          << " PeerAddress (local) not retrievable";
        }
 
        return localPeerAddress;
    }

References logger::LogMessage::LogMessage(), logger::TRACE, and logger::WARNING.

Here is the call graph for this function:

getRemoteSocketAddress()

template<typename SocketAddress, typename PhysicalSocket, typename Config>

SocketAddress core::socket::stream::getRemoteSocketAddress	(	PhysicalSocket &	physicalSocket,
		Config &	config )

Definition at line 82 of file SocketConnection.hpp.

                                                                                         {
        typename SocketAddress::SockAddr remoteSockAddr;
        typename SocketAddress::SockLen remoteSockAddrLen = sizeof(typename SocketAddress::SockAddr);
 
        SocketAddress remotePeerAddress;
        if (physicalSocket.getPeerName(remoteSockAddr, remoteSockAddrLen) == 0) {
            try {
                remotePeerAddress = config->Remote::getSocketAddress(remoteSockAddr, remoteSockAddrLen);
                LOG(TRACE) << config->getInstanceName() << " [" << physicalSocket.getFd() << "]" << std::setw(25)
                           << "  PeerAddress (remote): " << remotePeerAddress.toString();
            } catch (const typename SocketAddress::BadSocketAddress& badSocketAddress) {
                LOG(WARNING) << config->getInstanceName() << " [" << physicalSocket.getFd() << "]" << std::setw(25)
                             << "  PeerAddress (remote): " << badSocketAddress.what();
            }
        } else {
            PLOG(WARNING) << config->getInstanceName() << " [" << physicalSocket.getFd() << "]" << std::setw(25)
                          << " PeerAddress (remote) not retrievble";
        }
 
        return remotePeerAddress;
    }

References logger::LogMessage::LogMessage(), logger::TRACE, and logger::WARNING.

Here is the call graph for this function:

Server() [1/2]

template<typename SocketServer, typename... Args>

SocketServer core::socket::stream::Server	(	const std::string &	instanceName,
		Args &&...	socketContextFactoryArgs )

Definition at line 328 of file SocketServer.h.

                                                                                           {
        return SocketServer(instanceName, std::forward<Args>(socketContextFactoryArgs)...);
    }

Server() [2/2]

template<typename SocketServer, typename... Args>

SocketServer core::socket::stream::Server	(	const std::string &	instanceName,
		const std::function< void(typename SocketServer::Config *)> &	configurator,
		Args &&...	socketContextFactoryArgs )

Definition at line 317 of file SocketServer.h.

                                                            {
        const SocketServer socketServer(instanceName, std::forward<Args>(socketContextFactoryArgs)...);
 
        configurator(socketServer.getConfig());
 
        return socketServer;
    }

Variable Documentation

FlowController< ConcreteFlowController >::idCounter

template<typename ConcreteFlowController>

uint64_t core::socket::stream::FlowController< ConcreteFlowController >::idCounter = 0

Definition at line 54 of file FlowController.hpp.