iot::mqtt_fast::SocketContext Class Reference

#include <SocketContext.h>

Inheritance diagram for iot::mqtt_fast::SocketContext:

Collaboration diagram for iot::mqtt_fast::SocketContext:

Public Member Functions
	SocketContext (core::socket::stream::SocketConnection *socketConnection)
void	sendConnect (const std::string &clientId)
void	sendConnack (uint8_t returnCode, uint8_t flags)
void	sendPublish (const std::string &topic, const std::string &message, bool dup=false, uint8_t qoS=0, bool retain=false)
void	sendPuback (uint16_t packetIdentifier)
void	sendPubrec (uint16_t packetIdentifier)
void	sendPubrel (uint16_t packetIdentifier)
void	sendPubcomp (uint16_t packetIdentifier)
void	sendSubscribe (std::list< Topic > &topics)
void	sendSuback (uint16_t packetIdentifier, const std::list< uint8_t > &returnCodes)
void	sendUnsubscribe (const std::list< std::string > &topics)
void	sendUnsuback (uint16_t packetIdentifier)
void	sendPingreq ()
void	sendPingresp ()
void	sendDisconnect ()
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 Member Functions
virtual void	onConnect (const iot::mqtt_fast::packets::Connect &connect)=0
virtual void	onConnack (const iot::mqtt_fast::packets::Connack &connack)=0
virtual void	onPublish (const iot::mqtt_fast::packets::Publish &publish)=0
virtual void	onPuback (const iot::mqtt_fast::packets::Puback &puback)=0
virtual void	onPubrec (const iot::mqtt_fast::packets::Pubrec &pubrec)=0
virtual void	onPubrel (const iot::mqtt_fast::packets::Pubrel &pubrel)=0
virtual void	onPubcomp (const iot::mqtt_fast::packets::Pubcomp &pubcomp)=0
virtual void	onSubscribe (const iot::mqtt_fast::packets::Subscribe &subscribe)=0
virtual void	onSuback (const iot::mqtt_fast::packets::Suback &suback)=0
virtual void	onUnsubscribe (const iot::mqtt_fast::packets::Unsubscribe &unsubscribe)=0
virtual void	onUnsuback (const iot::mqtt_fast::packets::Unsuback &unsuback)=0
virtual void	onPingreq (const iot::mqtt_fast::packets::Pingreq &pingreq)=0
virtual void	onPingresp (const iot::mqtt_fast::packets::Pingresp &pingresp)=0
virtual void	onDisconnect (const iot::mqtt_fast::packets::Disconnect &disconnect)=0
std::size_t	onReceivedFromPeer () final
void	send (iot::mqtt_fast::ControlPacket &&controlPacket) const
void	send (iot::mqtt_fast::ControlPacket &controlPacket) const
void	send (std::vector< char > &&data) const
uint16_t	getPacketIdentifier ()

Static Private Member Functions
static void	printData (const std::vector< char > &data)

Private Attributes
iot::mqtt_fast::ControlPacketFactory	controlPacketFactory
uint16_t	_packetIdentifier = 0

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 ()
virtual bool	onSignal (int sig)=0

Detailed Description

Definition at line 85 of file SocketContext.h.

Constructor & Destructor Documentation

SocketContext()

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

explicit

Definition at line 60 of file SocketContext.cpp.

        : core::socket::stream::SocketContext(socketConnection)
        , controlPacketFactory(this) {
    }

References iot::mqtt_fast::ControlPacketFactory::ControlPacketFactory(), controlPacketFactory, and core::socket::stream::SocketContext::SocketContext().

Here is the call graph for this function:

Member Function Documentation

getPacketIdentifier()

uint16_t iot::mqtt_fast::SocketContext::getPacketIdentifier ( )

inlineprivate

Definition at line 127 of file SocketContext.h.

                                       {
            ++_packetIdentifier;
 
            if (_packetIdentifier == 0) {
                ++_packetIdentifier;
            }
 
            return _packetIdentifier;
        }

References _packetIdentifier.

Referenced by sendPublish(), sendSubscribe(), and sendUnsubscribe().

Here is the caller graph for this function:

onConnack()

virtual void iot::mqtt_fast::SocketContext::onConnack ( const iot::mqtt_fast::packets::Connack &  connack )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onConnect()

virtual void iot::mqtt_fast::SocketContext::onConnect ( const iot::mqtt_fast::packets::Connect &  connect )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onDisconnect()

virtual void iot::mqtt_fast::SocketContext::onDisconnect ( const iot::mqtt_fast::packets::Disconnect &  disconnect )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onPingreq()

virtual void iot::mqtt_fast::SocketContext::onPingreq ( const iot::mqtt_fast::packets::Pingreq &  pingreq )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onPingresp()

virtual void iot::mqtt_fast::SocketContext::onPingresp ( const iot::mqtt_fast::packets::Pingresp &  pingresp )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onPuback()

virtual void iot::mqtt_fast::SocketContext::onPuback ( const iot::mqtt_fast::packets::Puback &  puback )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onPubcomp()

virtual void iot::mqtt_fast::SocketContext::onPubcomp ( const iot::mqtt_fast::packets::Pubcomp &  pubcomp )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onPublish()

virtual void iot::mqtt_fast::SocketContext::onPublish ( const iot::mqtt_fast::packets::Publish &  publish )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onPubrec()

virtual void iot::mqtt_fast::SocketContext::onPubrec ( const iot::mqtt_fast::packets::Pubrec &  pubrec )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onPubrel()

virtual void iot::mqtt_fast::SocketContext::onPubrel ( const iot::mqtt_fast::packets::Pubrel &  pubrel )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onReceivedFromPeer()

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

finalprivatevirtual

Implements core::socket::SocketContext.

Definition at line 163 of file SocketContext.cpp.

                                                {
        const std::size_t consumed = controlPacketFactory.construct();
 
        if (controlPacketFactory.isError()) {
            LOG(ERROR) << "MQTT (fast): SocketContext: Error during ControlPacket construction";
            close();
        } else if (controlPacketFactory.isComplete()) {
            LOG(DEBUG) << "MQTT (fast): ======================================================";
            LOG(DEBUG) << "MQTT (fast): PacketType: " << static_cast<uint16_t>(controlPacketFactory.getPacketType());
            LOG(DEBUG) << "MQTT (fast): PacketFlags: " << static_cast<uint16_t>(controlPacketFactory.getPacketFlags());
            LOG(DEBUG) << "MQTT (fast): RemainingLength: " << static_cast<uint16_t>(controlPacketFactory.getRemainingLength());
 
            printData(controlPacketFactory.getPacket().getValue());
 
            switch (controlPacketFactory.getPacketType()) {
                case MQTT_CONNECT:
                    onConnect(iot::mqtt_fast::packets::Connect(controlPacketFactory));
                    break;
                case MQTT_CONNACK:
                    onConnack(iot::mqtt_fast::packets::Connack(controlPacketFactory));
                    break;
                case MQTT_PUBLISH:
                    onPublish(iot::mqtt_fast::packets::Publish(controlPacketFactory));
                    break;
                case MQTT_PUBACK:
                    onPuback(iot::mqtt_fast::packets::Puback(controlPacketFactory));
                    break;
                case MQTT_PUBREC:
                    onPubrec(iot::mqtt_fast::packets::Pubrec(controlPacketFactory));
                    break;
                case MQTT_PUBREL:
                    onPubrel(iot::mqtt_fast::packets::Pubrel(controlPacketFactory));
                    break;
                case MQTT_PUBCOMP:
                    onPubcomp(iot::mqtt_fast::packets::Pubcomp(controlPacketFactory));
                    break;
                case MQTT_SUBSCRIBE:
                    onSubscribe(iot::mqtt_fast::packets::Subscribe(controlPacketFactory));
                    break;
                case MQTT_SUBACK:
                    onSuback(iot::mqtt_fast::packets::Suback(controlPacketFactory));
                    break;
                case MQTT_UNSUBSCRIBE:
                    onUnsubscribe(iot::mqtt_fast::packets::Unsubscribe(controlPacketFactory));
                    break;
                case MQTT_UNSUBACK:
                    onUnsuback(iot::mqtt_fast::packets::Unsuback(controlPacketFactory));
                    break;
                case MQTT_PINGREQ:
                    onPingreq(iot::mqtt_fast::packets::Pingreq(controlPacketFactory));
                    break;
                case MQTT_PINGRESP:
                    onPingresp(iot::mqtt_fast::packets::Pingresp(controlPacketFactory));
                    break;
                case MQTT_DISCONNECT:
                    onDisconnect(iot::mqtt_fast::packets::Disconnect(controlPacketFactory));
                    break;
                default:
                    close();
                    break;
            }
 
            controlPacketFactory.reset();
        }
 
        return consumed;
    }

References core::socket::stream::SocketContext::close(), iot::mqtt_fast::packets::Connack::Connack(), iot::mqtt_fast::packets::Connect::Connect(), iot::mqtt_fast::ControlPacketFactory::construct(), controlPacketFactory, iot::mqtt_fast::packets::Disconnect::Disconnect(), iot::mqtt_fast::ControlPacketFactory::getPacket(), iot::mqtt_fast::ControlPacketFactory::getPacketFlags(), iot::mqtt_fast::ControlPacketFactory::getPacketType(), iot::mqtt_fast::ControlPacketFactory::getRemainingLength(), iot::mqtt_fast::types::Binary::getValue(), iot::mqtt_fast::ControlPacketFactory::isComplete(), iot::mqtt_fast::ControlPacketFactory::isError(), onConnack(), onConnect(), onDisconnect(), onPingreq(), onPingresp(), onPuback(), onPubcomp(), onPublish(), onPubrec(), onPubrel(), onSuback(), onSubscribe(), onUnsuback(), onUnsubscribe(), iot::mqtt_fast::packets::Pingreq::Pingreq(), iot::mqtt_fast::packets::Pingresp::Pingresp(), printData(), iot::mqtt_fast::packets::Puback::Puback(), iot::mqtt_fast::packets::Pubcomp::Pubcomp(), iot::mqtt_fast::packets::Publish::Publish(), iot::mqtt_fast::packets::Pubrec::Pubrec(), iot::mqtt_fast::packets::Pubrel::Pubrel(), iot::mqtt_fast::ControlPacketFactory::reset(), iot::mqtt_fast::packets::Suback::Suback(), iot::mqtt_fast::packets::Subscribe::Subscribe(), iot::mqtt_fast::packets::Unsuback::Unsuback(), and iot::mqtt_fast::packets::Unsubscribe::Unsubscribe().

Here is the call graph for this function:

onSuback()

virtual void iot::mqtt_fast::SocketContext::onSuback ( const iot::mqtt_fast::packets::Suback &  suback )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onSubscribe()

virtual void iot::mqtt_fast::SocketContext::onSubscribe ( const iot::mqtt_fast::packets::Subscribe &  subscribe )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onUnsuback()

virtual void iot::mqtt_fast::SocketContext::onUnsuback ( const iot::mqtt_fast::packets::Unsuback &  unsuback )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

onUnsubscribe()

virtual void iot::mqtt_fast::SocketContext::onUnsubscribe ( const iot::mqtt_fast::packets::Unsubscribe &  unsubscribe )

privatepure virtual

Referenced by onReceivedFromPeer().

Here is the caller graph for this function:

printData()

void iot::mqtt_fast::SocketContext::printData ( const std::vector< char > &  data )

staticprivate

Definition at line 244 of file SocketContext.cpp.

                                                             {
        std::stringstream ss;
 
        ss << "Data: ";
        unsigned long i = 0;
        for (char const ch : data) {
            if (i != 0 && i % 8 == 0 && i + 1 != data.size()) {
                ss << std::endl;
                ss << "                                            ";
            }
            ++i;
            ss << "0x" << std::hex << std::setfill('0') << std::setw(2) << static_cast<uint16_t>(static_cast<uint8_t>(ch))
               << " "; // << " | ";
        }
 
        LOG(DEBUG) << ss.str();
    }

Referenced by onReceivedFromPeer(), and send().

Here is the caller graph for this function:

send() [1/3]

void iot::mqtt_fast::SocketContext::send ( iot::mqtt_fast::ControlPacket &&  controlPacket ) const

private

Definition at line 231 of file SocketContext.cpp.

                                                                {
        send(controlPacket.getPacket());
    }

References iot::mqtt_fast::ControlPacket::getPacket(), and send().

Referenced by sendConnack(), sendConnect(), sendDisconnect(), sendPingreq(), sendPingresp(), sendPuback(), sendPubcomp(), sendPublish(), sendPubrec(), sendPubrel(), sendSuback(), sendSubscribe(), sendUnsuback(), and sendUnsubscribe().

Here is the call graph for this function:

Here is the caller graph for this function:

send() [2/3]

void iot::mqtt_fast::SocketContext::send ( iot::mqtt_fast::ControlPacket &  controlPacket ) const

private

Definition at line 235 of file SocketContext.cpp.

                                                               {
        send(controlPacket.getPacket());
    }

References iot::mqtt_fast::ControlPacket::getPacket(), and send().

Here is the call graph for this function:

send() [3/3]

void iot::mqtt_fast::SocketContext::send ( std::vector< char > &&  data ) const

private

Definition at line 239 of file SocketContext.cpp.

                                                         {
        printData(data);
        sendToPeer(data.data(), data.size());
    }

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

Referenced by send(), and send().

Here is the call graph for this function:

Here is the caller graph for this function:

sendConnack()

void iot::mqtt_fast::SocketContext::sendConnack	(	uint8_t	returnCode,
		uint8_t	flags
	)

Definition at line 72 of file SocketContext.cpp.

                                                                     {
        LOG(DEBUG) << "MQTT (fast): Send CONNACK";
        LOG(DEBUG) << "MQTT (fast): ============";
 
        send(iot::mqtt_fast::packets::Connack(returnCode, flags));
    }

References iot::mqtt_fast::packets::Connack::Connack(), and send().

Here is the call graph for this function:

sendConnect()

void iot::mqtt_fast::SocketContext::sendConnect

(

const std::string &

clientId

)

Definition at line 65 of file SocketContext.cpp.

                                                             {
        LOG(DEBUG) << "MQTT (fast): Send CONNECT";
        LOG(DEBUG) << "MQTT (fast): ============";
 
        send(iot::mqtt_fast::packets::Connect(clientId));
    }

References iot::mqtt_fast::packets::Connect::Connect(), and send().

Here is the call graph for this function:

sendDisconnect()

void iot::mqtt_fast::SocketContext::sendDisconnect

(

)

Definition at line 156 of file SocketContext.cpp.

                                       {
        LOG(DEBUG) << "MQTT (fast): Send Disconnect";
        LOG(DEBUG) << "MQTT (fast): ===============";
 
        send(iot::mqtt_fast::packets::Disconnect());
    }

References iot::mqtt_fast::packets::Disconnect::Disconnect(), and send().

Here is the call graph for this function:

sendPingreq()

void iot::mqtt_fast::SocketContext::sendPingreq

(

)

Definition at line 142 of file SocketContext.cpp.

                                    {
        LOG(DEBUG) << "MQTT (fast): Send Pingreq";
        LOG(DEBUG) << "MQTT (fast): ============";
 
        send(iot::mqtt_fast::packets::Pingreq());
    }

References iot::mqtt_fast::packets::Pingreq::Pingreq(), and send().

Here is the call graph for this function:

sendPingresp()

void iot::mqtt_fast::SocketContext::sendPingresp

(

)

Definition at line 149 of file SocketContext.cpp.

                                     {
        LOG(DEBUG) << "MQTT (fast): Send Pingresp";
        LOG(DEBUG) << "MQTT (fast): =============";
 
        send(iot::mqtt_fast::packets::Pingresp());
    }

References iot::mqtt_fast::packets::Pingresp::Pingresp(), and send().

Here is the call graph for this function:

sendPuback()

void iot::mqtt_fast::SocketContext::sendPuback

(

uint16_t

packetIdentifier

)

Definition at line 86 of file SocketContext.cpp.

                                                            {
        LOG(DEBUG) << "MQTT (fast): Send PUBACK";
        LOG(DEBUG) << "MQTT (fast): ===========";
 
        send(iot::mqtt_fast::packets::Puback(packetIdentifier));
    }

References iot::mqtt_fast::packets::Puback::Puback(), and send().

Here is the call graph for this function:

sendPubcomp()

void iot::mqtt_fast::SocketContext::sendPubcomp

(

uint16_t

packetIdentifier

)

Definition at line 107 of file SocketContext.cpp.

                                                             {
        LOG(DEBUG) << "MQTT (fast): Send PUBCOMP";
        LOG(DEBUG) << "MQTT (fast): ============";
 
        send(iot::mqtt_fast::packets::Pubcomp(packetIdentifier));
    }

References iot::mqtt_fast::packets::Pubcomp::Pubcomp(), and send().

Here is the call graph for this function:

sendPublish()

void iot::mqtt_fast::SocketContext::sendPublish	(	const std::string &	topic,
		const std::string &	message,
		bool	dup = false,
		uint8_t	qoS = 0,
		bool	retain = false
	)

Definition at line 79 of file SocketContext.cpp.

                                                                                                                        {
        LOG(DEBUG) << "MQTT (fast): Send PUBLISH";
        LOG(DEBUG) << "MQTT (fast): ============";
 
        send(iot::mqtt_fast::packets::Publish(qoS == 0 ? 0 : getPacketIdentifier(), topic, message, dup, qoS, retain));
    }

References getPacketIdentifier(), iot::mqtt_fast::packets::Publish::Publish(), and send().

Here is the call graph for this function:

sendPubrec()

void iot::mqtt_fast::SocketContext::sendPubrec

(

uint16_t

packetIdentifier

)

Definition at line 93 of file SocketContext.cpp.

                                                            {
        LOG(DEBUG) << "MQTT (fast): Send PUBREC";
        LOG(DEBUG) << "MQTT (fast): ===========";
 
        send(iot::mqtt_fast::packets::Pubrec(packetIdentifier));
    }

References iot::mqtt_fast::packets::Pubrec::Pubrec(), and send().

Here is the call graph for this function:

sendPubrel()

void iot::mqtt_fast::SocketContext::sendPubrel

(

uint16_t

packetIdentifier

)

Definition at line 100 of file SocketContext.cpp.

                                                            {
        LOG(DEBUG) << "MQTT (fast): Send PUBREL";
        LOG(DEBUG) << "MQTT (fast): ===========";
 
        send(iot::mqtt_fast::packets::Pubrel(packetIdentifier));
    }

References iot::mqtt_fast::packets::Pubrel::Pubrel(), and send().

Here is the call graph for this function:

sendSuback()

void iot::mqtt_fast::SocketContext::sendSuback	(	uint16_t	packetIdentifier,
		const std::list< uint8_t > &	returnCodes
	)

Definition at line 121 of file SocketContext.cpp.

                                                                                                 {
        LOG(DEBUG) << "MQTT (fast): Send SUBACK";
        LOG(DEBUG) << "MQTT (fast): ===========";
 
        send(iot::mqtt_fast::packets::Suback(packetIdentifier, returnCodes));
    }

References send(), and iot::mqtt_fast::packets::Suback::Suback().

Here is the call graph for this function:

sendSubscribe()

void iot::mqtt_fast::SocketContext::sendSubscribe

(

std::list< Topic > &

topics

)

Definition at line 114 of file SocketContext.cpp.

                                                                        {
        LOG(DEBUG) << "MQTT (fast): Send SUBSCRIBE";
        LOG(DEBUG) << "MQTT (fast): ==============";
 
        send(iot::mqtt_fast::packets::Subscribe(getPacketIdentifier(), topics));
    }

References getPacketIdentifier(), send(), and iot::mqtt_fast::packets::Subscribe::Subscribe().

Here is the call graph for this function:

sendUnsuback()

void iot::mqtt_fast::SocketContext::sendUnsuback

(

uint16_t

packetIdentifier

)

Definition at line 135 of file SocketContext.cpp.

                                                              {
        LOG(DEBUG) << "MQTT (fast): Send UNSUBACK";
        LOG(DEBUG) << "MQTT (fast): =============";
 
        send(iot::mqtt_fast::packets::Unsuback(packetIdentifier));
    }

References send(), and iot::mqtt_fast::packets::Unsuback::Unsuback().

Here is the call graph for this function:

sendUnsubscribe()

void iot::mqtt_fast::SocketContext::sendUnsubscribe

(

const std::list< std::string > &

topics

)

Definition at line 128 of file SocketContext.cpp.

                                                                        {
        LOG(DEBUG) << "MQTT (fast): Send UNSUBSCRIBE";
        LOG(DEBUG) << "MQTT (fast): ================";
 
        send(iot::mqtt_fast::packets::Unsubscribe(getPacketIdentifier(), topics));
    }

References getPacketIdentifier(), send(), and iot::mqtt_fast::packets::Unsubscribe::Unsubscribe().

Here is the call graph for this function:

Member Data Documentation

_packetIdentifier

uint16_t iot::mqtt_fast::SocketContext::_packetIdentifier = 0

private

Definition at line 139 of file SocketContext.h.

Referenced by getPacketIdentifier().

controlPacketFactory

iot::mqtt_fast::ControlPacketFactory iot::mqtt_fast::SocketContext::controlPacketFactory

private

Definition at line 137 of file SocketContext.h.

Referenced by onReceivedFromPeer(), and SocketContext().

---

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

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