core::socket::stream Namespace Reference

Namespaces
namespace	legacy
namespace	tls
namespace	stream

Classes
class	AutoConnectControl
class	SocketContext
class	SocketConnection
class	SocketConnectionT
class	SocketContextFactory
class	SocketReader
class	SocketWriter
class	SocketConnector
class	SocketAcceptor
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)

Function Documentation

Client() [1/2]

template<typename SocketClient, typename... Args>

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

Definition at line 417 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 406 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 61 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 84 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 383 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 372 of file SocketServer.h.

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