core::socket::stream Namespace Reference

Namespaces
namespace	legacy
namespace	stream
namespace	tls

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

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)

Function Documentation

getLocalSocketAddress()

template<typename SocketAddress , typename PhysicalSocket , typename Config >

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

Definition at line 59 of file SocketConnector.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;
    }

getRemoteSocketAddress()

template<typename SocketAddress , typename PhysicalSocket , typename Config >

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

Definition at line 82 of file SocketConnector.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 retrievable";
        }
 
        return remotePeerAddress;
    }