iot::mqtt::SocketContext Class Reference

#include <SocketContext.h>

Inheritance diagram for iot::mqtt::SocketContext:

Collaboration diagram for iot::mqtt::SocketContext:

Public Member Functions
	SocketContext (core::socket::stream::SocketConnection *socketConnection, Mqtt *mqtt)
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)
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 Member Functions
void	onConnected () override
std::size_t	onReceivedFromPeer () override
void	onDisconnected () override
bool	onSignal (int sig) override
core::socket::stream::SocketConnection *	getSocketConnection () const override
std::size_t	recv (char *chunk, std::size_t chunklen) override
void	send (const char *chunk, std::size_t chunklen) override
void	end (bool fatal) override
void	close () override
Private Member Functions inherited from iot::mqtt::MqttContext
	MqttContext (Mqtt *mqtt)
	MqttContext (const MqttContext &)=default
MqttContext &	operator= (const MqttContext &)=default
virtual	~MqttContext ()
void	onConnected ()
std::size_t	onReceivedFromPeer ()
void	onDisconnected ()
bool	onSignal (int sig)

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 ()
Private Attributes inherited from iot::mqtt::MqttContext
Mqtt *	mqtt

Detailed Description

Definition at line 64 of file SocketContext.h.

Constructor & Destructor Documentation

SocketContext()

iot::mqtt::SocketContext::SocketContext ( core::socket::stream::SocketConnection *  socketConnection, Mqtt *  mqtt  )

explicit

Definition at line 50 of file SocketContext.cpp.

        : core::socket::stream::SocketContext(socketConnection)
        , iot::mqtt::MqttContext(mqtt) {
    }

References iot::mqtt::MqttContext::MqttContext(), and core::socket::stream::SocketContext::SocketContext().

Here is the call graph for this function:

Member Function Documentation

close()

void iot::mqtt::SocketContext::close ( )

overrideprivatevirtual

Reimplemented from core::socket::stream::SocketContext.

Definition at line 87 of file SocketContext.cpp.

                              {
        core::socket::stream::SocketContext::close();
    }

References core::socket::stream::SocketContext::close().

Here is the call graph for this function:

end()

void iot::mqtt::SocketContext::end ( bool  fatal )

overrideprivatevirtual

Implements iot::mqtt::MqttContext.

Definition at line 83 of file SocketContext.cpp.

                                      {
        shutdownWrite(fatal);
    }

References core::socket::stream::SocketContext::shutdownWrite().

Here is the call graph for this function:

getSocketConnection()

core::socket::stream::SocketConnection * iot::mqtt::SocketContext::getSocketConnection ( ) const

overrideprivatevirtual

Implements iot::mqtt::MqttContext.

Definition at line 67 of file SocketContext.cpp.

                                                                               {
        return core::socket::stream::SocketContext::getSocketConnection();
    }

References core::socket::stream::SocketContext::getSocketConnection().

Here is the call graph for this function:

onConnected()

void iot::mqtt::SocketContext::onConnected ( )

overrideprivatevirtual

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

Definition at line 55 of file SocketContext.cpp.

                                    {
        iot::mqtt::MqttContext::onConnected();
    }

References iot::mqtt::MqttContext::onConnected().

Here is the call graph for this function:

onDisconnected()

void iot::mqtt::SocketContext::onDisconnected ( )

overrideprivatevirtual

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

Definition at line 59 of file SocketContext.cpp.

                                       {
        iot::mqtt::MqttContext::onDisconnected();
    }

References iot::mqtt::MqttContext::onDisconnected().

Here is the call graph for this function:

onReceivedFromPeer()

std::size_t iot::mqtt::SocketContext::onReceivedFromPeer ( )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 71 of file SocketContext.cpp.

                                                {
        return iot::mqtt::MqttContext::onReceivedFromPeer();
    }

References iot::mqtt::MqttContext::onReceivedFromPeer().

Here is the call graph for this function:

onSignal()

bool iot::mqtt::SocketContext::onSignal ( int  sig )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 63 of file SocketContext.cpp.

                                        {
        return iot::mqtt::MqttContext::onSignal(sig);
    }

References iot::mqtt::MqttContext::onSignal().

Here is the call graph for this function:

recv()

std::size_t iot::mqtt::SocketContext::recv ( char *  chunk, std::size_t  chunklen  )

overrideprivatevirtual

Implements iot::mqtt::MqttContext.

Definition at line 75 of file SocketContext.cpp.

                                                                 {
        return readFromPeer(chunk, chunklen);
    }

References core::socket::stream::SocketContext::readFromPeer().

Here is the call graph for this function:

send()

void iot::mqtt::SocketContext::send ( const char *  chunk, std::size_t  chunklen  )

overrideprivatevirtual

Implements iot::mqtt::MqttContext.

Definition at line 79 of file SocketContext.cpp.

                                                                  {
        sendToPeer(chunk, chunklen);
    }

References core::socket::stream::SocketContext::sendToPeer().

Here is the call graph for this function:

---

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

• iot/mqtt/SocketContext.h
• iot/mqtt/SocketContext.cpp