SNode.C
Loading...
Searching...
No Matches
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 ()
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
SocketConnectiongetSocketConnection () const
void sendToPeer (const std::string &data) const
Public Member Functions inherited from core::socket::SocketContext
 SocketContext (const SocketContext &)=delete
 SocketContext (SocketContext &&)=delete
SocketContextoperator= (const SocketContext &)=delete
SocketContextoperator= (SocketContext &&)=delete
void sendToPeer (const std::string &data) const

Private Attributes

web::http::client::ResponseParserresponseParser

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 84 of file httplowlevelclient.cpp.

Constructor & Destructor Documentation

◆ SimpleSocketProtocol() [1/2]

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

Definition at line 86 of file httplowlevelclient.cpp.

87 : core::socket::stream::SocketContext(socketConnection) {
89 }
web::http::client::ResponseParser * responseParser
core::socket::stream::SocketConnection * socketConnection
static web::http::client::ResponseParser * getResponseParser(core::socket::stream::SocketContext *socketContext)

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 122 of file httplowlevelclient.cpp.

122 {
123 delete responseParser;
124 }

References responseParser.

◆ SimpleSocketProtocol() [2/2]

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

Definition at line 86 of file httplowlevelclient.cpp.

87 : core::socket::stream::SocketContext(socketConnection) {
89 }

◆ ~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 93 of file httplowlevelclient.cpp.

93 {
94 VLOG(1) << "SimpleSocketProtocol connected";
95 }
#define VLOG(level)
Definition Logger.h:164

References logger::LogMessage::LogMessage().

Here is the call graph for this function:

◆ onConnected() [2/2]

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

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

Definition at line 93 of file httplowlevelclient.cpp.

93 {
94 VLOG(1) << "SimpleSocketProtocol connected";
95 }

◆ onDisconnected() [1/2]

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

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

Definition at line 96 of file httplowlevelclient.cpp.

96 {
97 VLOG(1) << "SimpleSocketProtocol disconnected";
98 }

References logger::LogMessage::LogMessage().

Here is the call graph for this function:

◆ onDisconnected() [2/2]

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

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

Definition at line 96 of file httplowlevelclient.cpp.

96 {
97 VLOG(1) << "SimpleSocketProtocol disconnected";
98 }

◆ onReadError() [1/2]

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

Implements core::socket::SocketContext.

Definition at line 113 of file httplowlevelclient.cpp.

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 113 of file httplowlevelclient.cpp.

◆ onReceivedFromPeer() [1/2]

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

Implements core::socket::SocketContext.

Definition at line 104 of file httplowlevelclient.cpp.

104 {
105 return responseParser->parse();
106 }

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 104 of file httplowlevelclient.cpp.

104 {
105 return responseParser->parse();
106 }

◆ onSignal() [1/2]

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

Implements core::socket::SocketContext.

Definition at line 100 of file httplowlevelclient.cpp.

100 {
101 return true;
102 }

◆ onSignal() [2/2]

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

Implements core::socket::SocketContext.

Definition at line 100 of file httplowlevelclient.cpp.

100 {
101 return true;
102 }

◆ onWriteError() [1/2]

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

Implements core::socket::SocketContext.

Definition at line 108 of file httplowlevelclient.cpp.

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 108 of file httplowlevelclient.cpp.

Member Data Documentation

◆ responseParser

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

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