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
SocketConnection *	getSocketConnection () const
virtual void	switchSocketContext (SocketContext *newSocketContext)
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
Protected Member Functions inherited from core::socket::SocketContext
	SocketContext ()=default
virtual	~SocketContext ()
virtual bool	onSignal (int sig)=0

Detailed Description

Definition at line 61 of file SocketContext.h.

Constructor & Destructor Documentation

SocketContext()

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

explicit

Definition at line 37 of file SocketContext.cpp.

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

Member Function Documentation

getPacketIdentifier()

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

inlineprivate

Definition at line 103 of file SocketContext.h.

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

References _packetIdentifier.

onConnack()

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

privatepure virtual

onConnect()

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

privatepure virtual

onDisconnect()

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

privatepure virtual

onPingreq()

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

privatepure virtual

onPingresp()

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

privatepure virtual

onPuback()

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

privatepure virtual

onPubcomp()

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

privatepure virtual

onPublish()

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

privatepure virtual

onPubrec()

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

privatepure virtual

onPubrel()

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

privatepure virtual

onReceivedFromPeer()

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

finalprivatevirtual

Implements core::socket::SocketContext.

Definition at line 140 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;
    }

onSuback()

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

privatepure virtual

onSubscribe()

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

privatepure virtual

onUnsuback()

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

privatepure virtual

onUnsubscribe()

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

privatepure virtual

printData()

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

staticprivate

Definition at line 221 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();
    }

send() [1/3]

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

private

Definition at line 208 of file SocketContext.cpp.

                                                                {
        send(controlPacket.getPacket());
    }

send() [2/3]

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

private

Definition at line 212 of file SocketContext.cpp.

                                                               {
        send(controlPacket.getPacket());
    }

send() [3/3]

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

private

Definition at line 216 of file SocketContext.cpp.

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

sendConnack()

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

Definition at line 49 of file SocketContext.cpp.

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

sendConnect()

void iot::mqtt_fast::SocketContext::sendConnect

(

const std::string &

clientId

)

Definition at line 42 of file SocketContext.cpp.

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

sendDisconnect()

void iot::mqtt_fast::SocketContext::sendDisconnect

(

)

Definition at line 133 of file SocketContext.cpp.

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

sendPingreq()

void iot::mqtt_fast::SocketContext::sendPingreq

(

)

Definition at line 119 of file SocketContext.cpp.

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

sendPingresp()

void iot::mqtt_fast::SocketContext::sendPingresp

(

)

Definition at line 126 of file SocketContext.cpp.

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

sendPuback()

void iot::mqtt_fast::SocketContext::sendPuback

(

uint16_t

packetIdentifier

)

Definition at line 63 of file SocketContext.cpp.

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

sendPubcomp()

void iot::mqtt_fast::SocketContext::sendPubcomp

(

uint16_t

packetIdentifier

)

Definition at line 84 of file SocketContext.cpp.

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

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 56 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));
    }

sendPubrec()

void iot::mqtt_fast::SocketContext::sendPubrec

(

uint16_t

packetIdentifier

)

Definition at line 70 of file SocketContext.cpp.

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

sendPubrel()

void iot::mqtt_fast::SocketContext::sendPubrel

(

uint16_t

packetIdentifier

)

Definition at line 77 of file SocketContext.cpp.

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

sendSuback()

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

Definition at line 98 of file SocketContext.cpp.

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

sendSubscribe()

void iot::mqtt_fast::SocketContext::sendSubscribe

(

std::list< Topic > &

topics

)

Definition at line 91 of file SocketContext.cpp.

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

sendUnsuback()

void iot::mqtt_fast::SocketContext::sendUnsuback

(

uint16_t

packetIdentifier

)

Definition at line 112 of file SocketContext.cpp.

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

sendUnsubscribe()

void iot::mqtt_fast::SocketContext::sendUnsubscribe

(

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

topics

)

Definition at line 105 of file SocketContext.cpp.

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

Member Data Documentation

_packetIdentifier

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

private

Definition at line 115 of file SocketContext.h.

Referenced by getPacketIdentifier().

controlPacketFactory

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

private

Definition at line 113 of file SocketContext.h.

---

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

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