apps::http::SimpleSocketProtocol Class Reference

Inheritance diagram for apps::http::SimpleSocketProtocol:

Collaboration diagram for apps::http::SimpleSocketProtocol:

Public Member Functions
	SimpleSocketProtocol (core::socket::stream::SocketConnection *socketConnection)
	~SimpleSocketProtocol () override
void	onConnected () override
void	onDisconnected () override
bool	onSignal (int signum) override
std::size_t	onReceivedFromPeer () override
void	onWriteError (int errnum) override
void	onReadError (int errnum) override
	SimpleSocketProtocol (core::socket::stream::SocketConnection *socketConnection)
	~SimpleSocketProtocol () override
void	onConnected () override
void	onDisconnected () override
bool	onSignal (int signum) override
std::size_t	onReceivedFromPeer () override
void	onWriteError (int errnum) override
void	onReadError (int errnum) override
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	switchSocketContext (SocketContext *newSocketContext)
virtual std::size_t	readFromPeer (char *chunk, std::size_t chunklen) const=0
void	sendToPeer (const std::string &data) const
virtual void	sendToPeer (const char *chunk, std::size_t chunkLen) const=0
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 Attributes
web::http::client::ResponseParser *	responseParser

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

Detailed Description

Definition at line 85 of file httplowlevelclient.cpp.

Constructor & Destructor Documentation

SimpleSocketProtocol() [1/2]

apps::http::SimpleSocketProtocol::SimpleSocketProtocol ( core::socket::stream::SocketConnection *  socketConnection )

inlineexplicit

Definition at line 87 of file httplowlevelclient.cpp.

            : core::socket::stream::SocketContext(socketConnection) {
            responseParser = getResponseParser(this);
        }

References apps::http::getResponseParser(), responseParser, and core::socket::stream::SocketContext::SocketContext().

Referenced by apps::http::SimpleSocketProtocolFactory::create().

Here is the call graph for this function:

Here is the caller graph for this function:

~SimpleSocketProtocol() [1/2]

apps::http::SimpleSocketProtocol::~SimpleSocketProtocol ( )

override

Definition at line 123 of file httplowlevelclient.cpp.

                                                {
        delete responseParser;
    }

References responseParser.

SimpleSocketProtocol() [2/2]

apps::http::SimpleSocketProtocol::SimpleSocketProtocol ( core::socket::stream::SocketConnection *  socketConnection )

inlineexplicit

Definition at line 87 of file httplowlevelclient.cpp.

            : core::socket::stream::SocketContext(socketConnection) {
            responseParser = getResponseParser(this);
        }

~SimpleSocketProtocol() [2/2]

apps::http::SimpleSocketProtocol::~SimpleSocketProtocol ( )

override

Member Function Documentation

onConnected() [1/2]

void apps::http::SimpleSocketProtocol::onConnected ( )

inlineoverridevirtual

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

Definition at line 94 of file httplowlevelclient.cpp.

                                    {
            VLOG(1) << "SimpleSocketProtocol connected";
        }

onConnected() [2/2]

void apps::http::SimpleSocketProtocol::onConnected ( )

inlineoverridevirtual

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

Definition at line 94 of file httplowlevelclient.cpp.

                                    {
            VLOG(1) << "SimpleSocketProtocol connected";
        }

onDisconnected() [1/2]

void apps::http::SimpleSocketProtocol::onDisconnected ( )

inlineoverridevirtual

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

Definition at line 97 of file httplowlevelclient.cpp.

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

onDisconnected() [2/2]

void apps::http::SimpleSocketProtocol::onDisconnected ( )

inlineoverridevirtual

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

Definition at line 97 of file httplowlevelclient.cpp.

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

onReadError() [1/2]

void apps::http::SimpleSocketProtocol::onReadError ( int  errnum )

inlineoverridevirtual

Implements core::socket::SocketContext.

Definition at line 114 of file httplowlevelclient.cpp.

                                              {
            core::socket::stream::SocketContext::onReadError(errnum);
            shutdownWrite();
        }

References core::socket::stream::SocketContext::onReadError(), and core::socket::stream::SocketContext::shutdownWrite().

Here is the call graph for this function:

onReadError() [2/2]

void apps::http::SimpleSocketProtocol::onReadError ( int  errnum )

inlineoverridevirtual

Implements core::socket::SocketContext.

Definition at line 114 of file httplowlevelclient.cpp.

                                              {
            core::socket::stream::SocketContext::onReadError(errnum);
            shutdownWrite();
        }

onReceivedFromPeer() [1/2]

std::size_t apps::http::SimpleSocketProtocol::onReceivedFromPeer ( )

inlineoverridevirtual

Implements core::socket::SocketContext.

Definition at line 105 of file httplowlevelclient.cpp.

                                                {
            return responseParser->parse();
        }

References web::http::Parser::parse(), and responseParser.

Here is the call graph for this function:

onReceivedFromPeer() [2/2]

std::size_t apps::http::SimpleSocketProtocol::onReceivedFromPeer ( )

inlineoverridevirtual

Implements core::socket::SocketContext.

Definition at line 105 of file httplowlevelclient.cpp.

                                                {
            return responseParser->parse();
        }

onSignal() [1/2]

bool apps::http::SimpleSocketProtocol::onSignal ( int  signum )

inlineoverridevirtual

Implements core::socket::SocketContext.

Definition at line 101 of file httplowlevelclient.cpp.

                                                            {
            return true;
        }

onSignal() [2/2]

bool apps::http::SimpleSocketProtocol::onSignal ( int  signum )

inlineoverridevirtual

Implements core::socket::SocketContext.

Definition at line 101 of file httplowlevelclient.cpp.

                                                            {
            return true;
        }

onWriteError() [1/2]

void apps::http::SimpleSocketProtocol::onWriteError ( int  errnum )

inlineoverridevirtual

Implements core::socket::SocketContext.

Definition at line 109 of file httplowlevelclient.cpp.

                                               {
            core::socket::stream::SocketContext::onWriteError(errnum);
            shutdownRead();
        }

References core::socket::stream::SocketContext::onWriteError(), and core::socket::stream::SocketContext::shutdownRead().

Here is the call graph for this function:

onWriteError() [2/2]

void apps::http::SimpleSocketProtocol::onWriteError ( int  errnum )

inlineoverridevirtual

Implements core::socket::SocketContext.

Definition at line 109 of file httplowlevelclient.cpp.

                                               {
            core::socket::stream::SocketContext::onWriteError(errnum);
            shutdownRead();
        }

Member Data Documentation

responseParser

web::http::client::ResponseParser * apps::http::SimpleSocketProtocol::responseParser

private

Definition at line 120 of file httplowlevelclient.cpp.

Referenced by onReceivedFromPeer(), SimpleSocketProtocol(), and ~SimpleSocketProtocol().

---

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

• apps/http/httplowlevelclient.cpp