core::socket::stream::SocketContext Class Reference

#include <SocketContext.h>

Inheritance diagram for core::socket::stream::SocketContext:

Collaboration diagram for core::socket::stream::SocketContext:

Public Member Functions
	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
SocketConnection *	getSocketConnection () const
virtual void	switchSocketContext (SocketContext *newSocketContext)
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

Protected Member Functions
void	onWriteError (int errnum) override
void	onReadError (int errnum) override
Protected Member Functions inherited from core::socket::SocketContext
	SocketContext ()=default
virtual	~SocketContext ()
virtual std::size_t	onReceivedFromPeer ()=0
virtual bool	onSignal (int sig)=0

Private Types
using	Super = core::socket::SocketContext

Private Member Functions
virtual void	onConnected ()=0
virtual void	onDisconnected ()=0

Private Attributes
core::socket::stream::SocketConnection *	socketConnection

Friends
template<typename PhysicalSocketT , class SocketReaderT , class SocketWriterT >
class	SocketConnectionT
class	SocketConnection

Detailed Description

Definition at line 64 of file SocketContext.h.

Member Typedef Documentation

Super

using core::socket::stream::SocketContext::Super = core::socket::SocketContext

private

Definition at line 66 of file SocketContext.h.

Constructor & Destructor Documentation

SocketContext()

core::socket::stream::SocketContext::SocketContext ( core::socket::stream::SocketConnection * socketConnection )

explicit

Definition at line 56 of file SocketContext.cpp.

        : socketConnection(socketConnection) {
    }

Referenced by iot::mqtt::SocketContext::SocketContext().

Here is the caller graph for this function:

Member Function Documentation

close()

void core::socket::stream::SocketContext::close ( )

overridevirtual

Implements core::socket::SocketContext.

Reimplemented in iot::mqtt::SocketContext.

Definition at line 89 of file SocketContext.cpp.

                              {
        socketConnection->close();
    }

Referenced by iot::mqtt::SocketContext::close().

Here is the caller graph for this function:

getSocketConnection()

SocketConnection * core::socket::stream::SocketContext::getSocketConnection

(

)

const

Definition at line 65 of file SocketContext.cpp.

                                                               {
        return socketConnection;
    }

Referenced by iot::mqtt::SocketContext::getSocketConnection().

Here is the caller graph for this function:

onConnected()

virtual void core::socket::stream::SocketContext::onConnected ( )

privatepure virtual

Implemented in apps::echo::model::EchoSocketContext, apps::http::SimpleSocketProtocol, apps::http::SimpleSocketProtocol, iot::mqtt::SocketContext, web::http::client::SocketContext, web::http::server::SocketContext, web::websocket::SocketContextUpgrade< SubProtocolT, RequestT, ResponseT >, web::websocket::SocketContextUpgrade< SubProtocol, web::http::client::Request, web::http::client::Response >, and web::websocket::SocketContextUpgrade< SubProtocol, web::http::server::Request, web::http::server::Response >.

onDisconnected()

virtual void core::socket::stream::SocketContext::onDisconnected ( )

privatepure virtual

Implemented in apps::echo::model::EchoSocketContext, apps::http::SimpleSocketProtocol, apps::http::SimpleSocketProtocol, iot::mqtt::SocketContext, web::http::client::SocketContext, web::http::server::SocketContext, web::websocket::SocketContextUpgrade< SubProtocolT, RequestT, ResponseT >, web::websocket::SocketContextUpgrade< SubProtocol, web::http::client::Request, web::http::client::Response >, and web::websocket::SocketContextUpgrade< SubProtocol, web::http::server::Request, web::http::server::Response >.

onReadError()

void core::socket::stream::SocketContext::onReadError ( int errnum )

overrideprotectedvirtual

Implements core::socket::SocketContext.

Definition at line 108 of file SocketContext.cpp.

                                              {
        errno = errnum;
 
        if (errno == 0) {
            LOG(DEBUG) << socketConnection->getConnectionName() << " SocketContext: EOF received";
        } else {
            PLOG(DEBUG) << socketConnection->getConnectionName() << " SocketContext: onReadError";
        }
        shutdownWrite();
    }

onWriteError()

void core::socket::stream::SocketContext::onWriteError ( int errnum )

overrideprotectedvirtual

Implements core::socket::SocketContext.

Reimplemented in web::http::client::SocketContext, and web::http::server::SocketContext.

Definition at line 101 of file SocketContext.cpp.

                                               {
        errno = errnum;
 
        PLOG(DEBUG) << socketConnection->getConnectionName() << " SocketContext: onWriteError";
        shutdownRead();
    }

readFromPeer()

std::size_t core::socket::stream::SocketContext::readFromPeer ( char * chunk, std::size_t chunklen ) const

finalvirtual

Implements core::socket::SocketContext.

Definition at line 81 of file SocketContext.cpp.

                                                                               {
        return socketConnection->readFromPeer(chunk, chunklen);
    }

Referenced by web::http::decoder::Chunked::Chunk::read(), web::http::decoder::Fields::read(), web::http::decoder::HTTP10Response::read(), and iot::mqtt::SocketContext::recv().

Here is the caller graph for this function:

sendToPeer() [1/2]

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

finalvirtual

Implements core::socket::SocketContext.

Definition at line 69 of file SocketContext.cpp.

                                                                              {
        socketConnection->sendToPeer(chunk, chunkLen);
    }

Referenced by iot::mqtt::SocketContext::send().

Here is the caller graph for this function:

sendToPeer() [2/2]

void core::socket::SocketContext::sendToPeer

(

const std::string &

data

)

const

Definition at line 75 of file SocketContext.cpp.

                                                              {
        sendToPeer(data.data(), data.length());
    }

setTimeout()

void core::socket::stream::SocketContext::setTimeout ( const utils::Timeval & timeout )

finalvirtual

Implements core::socket::SocketContext.

Definition at line 85 of file SocketContext.cpp.

                                                              {
        socketConnection->setTimeout(timeout);
    }

shutdownRead()

void core::socket::stream::SocketContext::shutdownRead

(

)

Definition at line 93 of file SocketContext.cpp.

                                     {
        socketConnection->shutdownRead();
    }

shutdownWrite()

void core::socket::stream::SocketContext::shutdownWrite

(

bool

forceClose = false

)

Definition at line 97 of file SocketContext.cpp.

                                                     {
        socketConnection->shutdownWrite(forceClose);
    }

Referenced by iot::mqtt::SocketContext::end().

Here is the caller graph for this function:

streamEof()

void core::socket::stream::SocketContext::streamEof

(

)

Definition at line 77 of file SocketContext.cpp.

                                  {
        socketConnection->streamEof();
    }

streamToPeer()

bool core::socket::stream::SocketContext::streamToPeer

(

core::pipe::Source *

source

)

const

Definition at line 73 of file SocketContext.cpp.

                                                             {
        return socketConnection->streamToPeer(source);
    }

switchSocketContext()

void core::socket::stream::SocketContext::switchSocketContext ( SocketContext * newSocketContext )

virtual

Definition at line 60 of file SocketContext.cpp.

                                                                           {
        LOG(DEBUG) << socketConnection->getConnectionName() << ": Register new SocketContext";
        socketConnection->switchSocketContext(newSocketContext);
    }

Friends And Related Symbol Documentation

SocketConnection

friend class SocketConnection

friend

Definition at line 100 of file SocketContext.h.

SocketConnectionT

template<typename PhysicalSocketT , class SocketReaderT , class SocketWriterT >

friend class SocketConnectionT

friend

Definition at line 99 of file SocketContext.h.

Member Data Documentation

socketConnection

core::socket::stream::SocketConnection* core::socket::stream::SocketContext::socketConnection

private

Definition at line 96 of file SocketContext.h.

---

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

• core/socket/stream/SocketContext.h
• core/socket/stream/SocketContext.cpp