apps::echo::model::EchoSocketContext Class Reference

#include <EchoSocketContext.h>

Inheritance diagram for apps::echo::model::EchoSocketContext:

Collaboration diagram for apps::echo::model::EchoSocketContext:

Public Types
enum class	Role { SERVER , CLIENT }

Public Member Functions
	EchoSocketContext (core::socket::stream::SocketConnection *socketConnection, Role role)
Public Member Functions inherited from core::socket::stream::SocketContext
	SocketContext (core::socket::stream::SocketConnection *socketConnection)
void	sendToPeer (const char *chunk, std::size_t chunkLen) const final
bool	streamToPeer (core::pipe::Source *source) const
void	streamEof ()
std::size_t	readFromPeer (char *chunk, std::size_t chunklen) const final
void	setTimeout (const utils::Timeval &timeout) final
void	shutdownRead ()
void	shutdownWrite (bool forceClose=false)
void	close () override
std::size_t	getTotalSent () const override
std::size_t	getTotalQueued () const override
std::size_t	getTotalRead () const override
std::size_t	getTotalProcessed () const override
std::string	getOnlineSince () const override
std::string	getOnlineDuration () const override
SocketConnection *	getSocketConnection () const
void	sendToPeer (const std::string &data) const
Public Member Functions inherited from core::socket::SocketContext
	SocketContext (const SocketContext &)=delete
	SocketContext (SocketContext &&)=delete
SocketContext &	operator= (const SocketContext &)=delete
SocketContext &	operator= (SocketContext &&)=delete
void	sendToPeer (const std::string &data) const

Private Member Functions
void	onConnected () override
void	onDisconnected () override
bool	onSignal (int signum) override
std::size_t	onReceivedFromPeer () override

Private Attributes
Role	role

Additional Inherited Members
Protected Member Functions inherited from core::socket::stream::SocketContext
void	onWriteError (int errnum) override
void	onReadError (int errnum) override
std::size_t	readFromPeer ()
Protected Member Functions inherited from core::socket::SocketContext
	SocketContext ()=default
virtual	~SocketContext ()

Detailed Description

Definition at line 60 of file EchoSocketContext.h.

Member Enumeration Documentation

Role

enum class apps::echo::model::EchoSocketContext::Role

strong

Enumerator
SERVER
CLIENT

Definition at line 62 of file EchoSocketContext.h.

{ SERVER, CLIENT };

Constructor & Destructor Documentation

EchoSocketContext()

apps::echo::model::EchoSocketContext::EchoSocketContext ( core::socket::stream::SocketConnection * socketConnection, Role role )

explicit

Definition at line 54 of file EchoSocketContext.cpp.

        : core::socket::stream::SocketContext(socketConnection)
        , role(role) {
    }

References role, and core::socket::stream::SocketContext::SocketContext().

Referenced by apps::echo::model::EchoClientSocketContextFactory::create(), and apps::echo::model::EchoServerSocketContextFactory::create().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

onConnected()

void apps::echo::model::EchoSocketContext::onConnected ( )

overrideprivatevirtual

Implements core::socket::stream::SocketContext.

Definition at line 59 of file EchoSocketContext.cpp.

                                        {
        VLOG(1) << "Echo connected";
 
        if (role == Role::CLIENT) {
            sendToPeer("Hello peer! Nice to see you!!!");
        }
    }

References CLIENT, role, and core::socket::SocketContext::sendToPeer().

Here is the call graph for this function:

onDisconnected()

void apps::echo::model::EchoSocketContext::onDisconnected ( )

overrideprivatevirtual

Implements core::socket::stream::SocketContext.

Definition at line 67 of file EchoSocketContext.cpp.

                                           {
        VLOG(1) << "Echo disconnected";
    }

onReceivedFromPeer()

std::size_t apps::echo::model::EchoSocketContext::onReceivedFromPeer ( )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 75 of file EchoSocketContext.cpp.

                                                    {
        char chunk[4096];
 
        const std::size_t chunklen = readFromPeer(chunk, 4096);
 
        if (chunklen > 0) {
            VLOG(1) << "Data to reflect: " << std::string(chunk, chunklen);
            sendToPeer(chunk, chunklen);
        }
 
        return chunklen;
    }

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

Here is the call graph for this function:

onSignal()

bool apps::echo::model::EchoSocketContext::onSignal ( int signum )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 71 of file EchoSocketContext.cpp.

                                                                {
        return true;
    }

Member Data Documentation

role

Role apps::echo::model::EchoSocketContext::role

private

Definition at line 74 of file EchoSocketContext.h.

Referenced by EchoSocketContext(), and onConnected().

---

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

• apps/echo/model/EchoSocketContext.h
• apps/echo/model/EchoSocketContext.cpp