#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	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

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
std::size_t	readFromPeer ()
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;
    }

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

SNode.C

Public Member Functions

Private Member Functions

Static Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ SocketContext()

Member Function Documentation

◆ getPacketIdentifier()

◆ onConnack()

◆ onConnect()

◆ onDisconnect()

◆ onPingreq()

◆ onPingresp()

◆ onPuback()

◆ onPubcomp()

◆ onPublish()

◆ onPubrec()

◆ onPubrel()

◆ onReceivedFromPeer()

◆ onSuback()

◆ onSubscribe()

◆ onUnsuback()

◆ onUnsubscribe()

◆ printData()

◆ send() [1/3]

◆ send() [2/3]

◆ send() [3/3]

◆ sendConnack()

◆ sendConnect()

◆ sendDisconnect()

◆ sendPingreq()

◆ sendPingresp()

◆ sendPuback()

◆ sendPubcomp()

◆ sendPublish()

◆ sendPubrec()

◆ sendPubrel()

◆ sendSuback()

◆ sendSubscribe()

◆ sendUnsuback()

◆ sendUnsubscribe()

Member Data Documentation

◆ _packetIdentifier

◆ controlPacketFactory