#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

SocketConnection *	getSocketConnection () const

virtual void	switchSocketContext (SocketContext *newSocketContext)

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

Protected Member Functions inherited from core::socket::SocketContext
	SocketContext ()=default

virtual	~SocketContext ()

virtual bool	onSignal (int sig)=0

Detailed Description

Definition at line 83 of file SocketContext.h.

Constructor & Destructor Documentation

◆ SocketContext()

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

explicit

Definition at line 59 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 125 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 162 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 243 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 230 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 234 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 238 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 71 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 64 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 155 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 141 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 148 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 85 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 106 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 78 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 92 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 99 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 120 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 113 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 134 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 127 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 137 of file SocketContext.h.

Referenced by getPacketIdentifier().

◆ controlPacketFactory

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

private

Definition at line 135 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

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