iot::mqtt::server::Mqtt Class Reference

#include <Mqtt.h>

Inheritance diagram for iot::mqtt::server::Mqtt:

Collaboration diagram for iot::mqtt::server::Mqtt:

Public Member Functions
	Mqtt (const std::string &connectionName, const std::shared_ptr< broker::Broker > &broker)
	~Mqtt () override
void	sendConnack (uint8_t returnCode, uint8_t flags) const
void	sendSuback (uint16_t packetIdentifier, const std::list< uint8_t > &returnCodes) const
void	sendUnsuback (uint16_t packetIdentifier) const
void	sendPingresp () const
std::string	getProtocol () const
uint8_t	getLevel () const
uint8_t	getConnectFlags () const
uint16_t	getKeepAlive () const
std::string	getClientId () const
std::string	getWillTopic () const
std::string	getWillMessage () const
std::string	getUsername () const
std::string	getPassword () const
bool	getUsernameFlag () const
bool	getPasswordFlag () const
bool	getWillRetain () const
uint8_t	getWillQoS () const
bool	getWillFlag () const
bool	getCleanSession () const
bool	getReflect () const
Public Member Functions inherited from iot::mqtt::Mqtt
	Mqtt (const std::string &connectionName)
	Mqtt (const std::string &connectionName, const std::string &clientId)
	Mqtt (Mqtt &&)=delete
	Mqtt (const Mqtt &)=delete
Mqtt &	operator= (Mqtt &&)=delete
Mqtt &	operator= (const Mqtt &)=delete
virtual void	onConnected ()
virtual void	onDisconnected ()
const std::string &	getConnectionName () const
const MqttContext *	getMqttContext () const
void	sendPublish (const std::string &topic, const std::string &message, uint8_t qoS, bool retain)
void	sendPuback (uint16_t packetIdentifier) const
void	sendPubrec (uint16_t packetIdentifier) const
void	sendPubrel (uint16_t packetIdentifier) const
void	sendPubcomp (uint16_t packetIdentifier) const

Protected Member Functions
bool	onSignal (int sig) override
Protected Member Functions inherited from iot::mqtt::Mqtt
void	initSession (Session *session, utils::Timeval keepAlive)
virtual void	onPublish (const iot::mqtt::packets::Publish &publish)
virtual void	onPuback (const iot::mqtt::packets::Puback &puback)
virtual void	onPubrec (const iot::mqtt::packets::Pubrec &pubrec)
virtual void	onPubrel (const iot::mqtt::packets::Pubrel &pubrel)
virtual void	onPubcomp (const iot::mqtt::packets::Pubcomp &pubcomp)
bool	_onPublish (const iot::mqtt::packets::Publish &publish)
void	_onPuback (const iot::mqtt::packets::Puback &puback)
void	_onPubrec (const iot::mqtt::packets::Pubrec &pubrec)
void	_onPubrel (const iot::mqtt::packets::Pubrel &pubrel)
void	_onPubcomp (const iot::mqtt::packets::Pubcomp &pubcomp)
uint16_t	getPacketIdentifier ()
void	send (const iot::mqtt::ControlPacket &controlPacket) const
void	printVP (const iot::mqtt::ControlPacket &packet) const
void	printFixedHeader (const iot::mqtt::FixedHeader &fixedHeader) const

Protected Attributes
std::string	protocol
uint8_t	level = 0
uint8_t	connectFlags = 0
uint16_t	keepAlive = 0
std::string	willTopic
std::string	willMessage
std::string	username
std::string	password
bool	usernameFlag = false
bool	passwordFlag = false
bool	willRetain = false
uint8_t	willQoS = 0
bool	willFlag = false
bool	cleanSession = false
bool	reflect = true
std::shared_ptr< iot::mqtt::server::broker::Broker >	broker
Protected Attributes inherited from iot::mqtt::Mqtt
std::string	connectionName
std::string	clientId
MqttContext *	mqttContext = nullptr

Private Types
using	Super = iot::mqtt::Mqtt

Private Member Functions
iot::mqtt::ControlPacketDeserializer *	createControlPacketDeserializer (iot::mqtt::FixedHeader &fixedHeader) final
void	deliverPacket (iot::mqtt::ControlPacketDeserializer *controlPacketDeserializer) override
bool	initSession (const utils::Timeval &keepAlive)
void	releaseSession ()
virtual void	onConnect (const iot::mqtt::packets::Connect &connect)
virtual void	onSubscribe (const iot::mqtt::packets::Subscribe &subscribe)
virtual void	onUnsubscribe (const iot::mqtt::packets::Unsubscribe &unsubscribe)
virtual void	onPingreq (const iot::mqtt::packets::Pingreq &pingreq)
virtual void	onDisconnect (const iot::mqtt::packets::Disconnect &disconnect)
void	_onConnect (const iot::mqtt::server::packets::Connect &connect)
void	_onPublish (const iot::mqtt::server::packets::Publish &publish)
void	_onSubscribe (const iot::mqtt::server::packets::Subscribe &subscribe)
void	_onUnsubscribe (const iot::mqtt::server::packets::Unsubscribe &unsubscribe)
void	_onPingreq (const iot::mqtt::server::packets::Pingreq &pingreq)
void	_onDisconnect (const iot::mqtt::server::packets::Disconnect &disconnect)
void	initSession (Session *session, utils::Timeval keepAlive)

Friends
class	iot::mqtt::server::packets::Connect
class	iot::mqtt::server::packets::Subscribe
class	iot::mqtt::server::packets::Unsubscribe
class	iot::mqtt::server::packets::Pingreq
class	iot::mqtt::server::packets::Disconnect
class	iot::mqtt::server::packets::Publish
class	iot::mqtt::server::packets::Pubcomp
class	iot::mqtt::server::packets::Pubrec
class	iot::mqtt::server::packets::Puback
class	iot::mqtt::server::packets::Pubrel

Additional Inherited Members
Static Public Member Functions inherited from iot::mqtt::Mqtt
static std::string	toHexString (const std::vector< char > &data)
static std::string	toHexString (const std::string &data)

Detailed Description

Definition at line 65 of file Mqtt.h.

Member Typedef Documentation

Super

using iot::mqtt::server::Mqtt::Super = iot::mqtt::Mqtt

private

Definition at line 67 of file Mqtt.h.

Constructor & Destructor Documentation

Mqtt()

iot::mqtt::server::Mqtt::Mqtt ( const std::string & connectionName, const std::shared_ptr< broker::Broker > & broker )

explicit

Definition at line 51 of file Mqtt.cpp.

        : Super(connectionName)
        , broker(broker) {
    }

~Mqtt()

iot::mqtt::server::Mqtt::~Mqtt ( )

overridevirtual

Reimplemented from iot::mqtt::Mqtt.

Definition at line 56 of file Mqtt.cpp.

                {
        releaseSession();
 
        if (willFlag) {
            broker->publish(clientId, willTopic, willMessage, willQoS, willRetain);
        }
    }

References releaseSession(), and willFlag.

Here is the call graph for this function:

Member Function Documentation

_onConnect()

void iot::mqtt::server::Mqtt::_onConnect ( const iot::mqtt::server::packets::Connect & connect )

private

Definition at line 191 of file Mqtt.cpp.

                                                                    {
        LOG(INFO) << connectionName << " MQTT Broker:   Protocol: " << connect.getProtocol();
        LOG(INFO) << connectionName << " MQTT Broker:   Version: " << static_cast<uint16_t>(connect.getLevel());
        LOG(INFO) << connectionName << " MQTT Broker:   ConnectFlags: 0x" << std::hex << std::setfill('0') << std::setw(2)
                  << static_cast<uint16_t>(connect.getConnectFlags()) << std::dec << std::setw(0);
        LOG(INFO) << connectionName << " MQTT Broker:   KeepAlive: " << connect.getKeepAlive();
        LOG(INFO) << connectionName << " MQTT Broker:   ClientID: " << connect.getClientId();
        LOG(INFO) << connectionName << " MQTT Broker:   CleanSession: " << connect.getCleanSession();
 
        if (connect.getWillFlag()) {
            LOG(INFO) << connectionName << " MQTT Broker:   WillTopic: " << connect.getWillTopic();
            LOG(INFO) << connectionName << " MQTT Broker:   WillMessage: " << connect.getWillMessage();
            LOG(INFO) << connectionName << " MQTT Broker:   WillQoS: " << static_cast<uint16_t>(connect.getWillQoS());
            LOG(INFO) << connectionName << " MQTT Broker:   WillRetain: " << connect.getWillRetain();
        }
        if (connect.getUsernameFlag()) {
            LOG(INFO) << connectionName << " MQTT Broker:   Username: " << connect.getUsername();
        }
        if (connect.getPasswordFlag()) {
            LOG(INFO) << connectionName << " MQTT Broker:   Password: " << connect.getPassword();
        }
 
        if (connect.getProtocol() != "MQTT") {
            LOG(ERROR) << connectionName << " MQTT Broker:   Wrong Protocol: " << connect.getProtocol();
            mqttContext->end(true);
        } else if ((connect.getLevel()) != MQTT_VERSION_3_1_1) {
            LOG(ERROR) << connectionName << " MQTT Broker:   Wrong Protocol Level: " << MQTT_VERSION_3_1_1 << " != " << connect.getLevel();
            sendConnack(MQTT_CONNACK_UNACEPTABLEVERSION, MQTT_SESSION_NEW);
 
            mqttContext->end(true);
        } else if (connect.isFakedClientId() && !connect.getCleanSession()) {
            LOG(ERROR) << connectionName << " MQTT Broker:   Resume session but no ClientId present";
            sendConnack(MQTT_CONNACK_IDENTIFIERREJECTED, MQTT_SESSION_NEW);
 
            mqttContext->end(true);
        } else {
            // V-Header
            protocol = connect.getProtocol();
            level = connect.getLevel();
            reflect = connect.getReflect();
            connectFlags = connect.getConnectFlags();
            keepAlive = connect.getKeepAlive();
 
            // Payload
            clientId = connect.getClientId();
            willTopic = connect.getWillTopic();
            willMessage = connect.getWillMessage();
            username = connect.getUsername();
            password = connect.getPassword();
 
            // Derived from flags
            usernameFlag = connect.getUsernameFlag();
            passwordFlag = connect.getPasswordFlag();
            willRetain = connect.getWillRetain();
            willQoS = connect.getWillQoS();
            willFlag = connect.getWillFlag();
            cleanSession = connect.getCleanSession();
 
            if (initSession(1.5 * keepAlive)) {
                onConnect(connect);
            } else {
                mqttContext->end(true);
            }
        }
    }

References cleanSession, connectFlags, initSession(), keepAlive, level, passwordFlag, reflect, sendConnack(), usernameFlag, willFlag, willQoS, and willRetain.

Here is the call graph for this function:

_onDisconnect()

void iot::mqtt::server::Mqtt::_onDisconnect ( const iot::mqtt::server::packets::Disconnect & disconnect )

private

Definition at line 318 of file Mqtt.cpp.

                                                                             {
        willFlag = false;
 
        onDisconnect(disconnect);
 
        releaseSession();
    }

References releaseSession(), and willFlag.

Here is the call graph for this function:

_onPingreq()

void iot::mqtt::server::Mqtt::_onPingreq ( const iot::mqtt::server::packets::Pingreq & pingreq )

private

Definition at line 312 of file Mqtt.cpp.

                                                                    {
        sendPingresp();
 
        onPingreq(pingreq);
    }

References sendPingresp().

Here is the call graph for this function:

_onPublish()

void iot::mqtt::server::Mqtt::_onPublish ( const iot::mqtt::server::packets::Publish & publish )

private

Definition at line 257 of file Mqtt.cpp.

                                                                    {
        if (Super::_onPublish(publish)) {
            broker->publish(clientId, publish.getTopic(), publish.getMessage(), publish.getQoS(), publish.getRetain());
 
            onPublish(publish);
        }
    }

_onSubscribe()

void iot::mqtt::server::Mqtt::_onSubscribe ( const iot::mqtt::server::packets::Subscribe & subscribe )

private

Definition at line 265 of file Mqtt.cpp.

                                                                          {
        if (subscribe.getPacketIdentifier() == 0) {
            LOG(ERROR) << connectionName << " MQTT Broker:   PackageIdentifier missing";
            mqttContext->end(true);
        } else {
            LOG(DEBUG) << connectionName << " MQTT Broker:   PacketIdentifier: 0x" << std::hex << std::setfill('0') << std::setw(4)
                       << subscribe.getPacketIdentifier();
 
            for (const iot::mqtt::Topic& topic : subscribe.getTopics()) {
                LOG(INFO) << connectionName << " MQTT Broker:   Topic filter: '" << topic.getName()
                          << "', QoS: " << static_cast<uint16_t>(topic.getQoS());
            }
 
            std::list<uint8_t> returnCodes;
            for (const iot::mqtt::Topic& topic : subscribe.getTopics()) {
                const uint8_t returnCode = broker->subscribe(clientId, topic.getName(), topic.getQoS());
                returnCodes.push_back(returnCode);
            }
 
            sendSuback(subscribe.getPacketIdentifier(), returnCodes);
 
            onSubscribe(subscribe);
        }
    }

_onUnsubscribe()

void iot::mqtt::server::Mqtt::_onUnsubscribe ( const iot::mqtt::server::packets::Unsubscribe & unsubscribe )

private

Definition at line 290 of file Mqtt.cpp.

                                                                                {
        if (unsubscribe.getPacketIdentifier() == 0) {
            LOG(ERROR) << connectionName << " MQTT Broker:   PackageIdentifier missing";
            mqttContext->end(true);
        } else {
            LOG(DEBUG) << connectionName << " MQTT Broker:   PacketIdentifier: 0x" << std::hex << std::setfill('0') << std::setw(4)
                       << unsubscribe.getPacketIdentifier();
 
            for (const std::string& topic : unsubscribe.getTopics()) {
                LOG(INFO) << connectionName << " MQTT Broker:   Topic: " << topic;
            }
 
            for (const std::string& topic : unsubscribe.getTopics()) {
                broker->unsubscribe(clientId, topic);
            }
 
            sendUnsuback(unsubscribe.getPacketIdentifier());
 
            onUnsubscribe(unsubscribe);
        }
    }

References sendUnsuback().

Here is the call graph for this function:

createControlPacketDeserializer()

iot::mqtt::ControlPacketDeserializer * iot::mqtt::server::Mqtt::createControlPacketDeserializer ( iot::mqtt::FixedHeader & fixedHeader )

finalprivatevirtual

Implements iot::mqtt::Mqtt.

Definition at line 69 of file Mqtt.cpp.

                                                                                                           {
        iot::mqtt::ControlPacketDeserializer* controlPacketDeserializer = nullptr;
 
        switch (fixedHeader.getType()) {
            case MQTT_CONNECT:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Connect(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBLISH:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Publish(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBACK:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Puback(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBREC:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Pubrec(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBREL:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Pubrel(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBCOMP:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Pubcomp(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_SUBSCRIBE:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Subscribe(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_UNSUBSCRIBE:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Unsubscribe(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PINGREQ:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Pingreq(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_DISCONNECT:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Disconnect(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            default:
                controlPacketDeserializer = nullptr;
                break;
        }
 
        return controlPacketDeserializer;
    }

deliverPacket()

void iot::mqtt::server::Mqtt::deliverPacket ( iot::mqtt::ControlPacketDeserializer * controlPacketDeserializer )

overrideprivatevirtual

Implements iot::mqtt::Mqtt.

Definition at line 121 of file Mqtt.cpp.

                                                                                        {
        static_cast<iot::mqtt::server::ControlPacketDeserializer*>(controlPacketDeserializer)->deliverPacket(this); // NOLINT
    }

getCleanSession()

bool iot::mqtt::server::Mqtt::getCleanSession

(

)

const

Definition at line 398 of file Mqtt.cpp.

                                     {
        return cleanSession;
    }

References cleanSession.

getClientId()

std::string iot::mqtt::server::Mqtt::getClientId

(

)

const

Definition at line 358 of file Mqtt.cpp.

                                      {
        return clientId;
    }

getConnectFlags()

uint8_t iot::mqtt::server::Mqtt::getConnectFlags

(

)

const

Definition at line 350 of file Mqtt.cpp.

                                        {
        return connectFlags;
    }

References connectFlags.

getKeepAlive()

uint16_t iot::mqtt::server::Mqtt::getKeepAlive

(

)

const

Definition at line 354 of file Mqtt.cpp.

                                      {
        return keepAlive;
    }

References keepAlive.

getLevel()

uint8_t iot::mqtt::server::Mqtt::getLevel

(

)

const

Definition at line 346 of file Mqtt.cpp.

                                 {
        return level;
    }

References level.

getPassword()

std::string iot::mqtt::server::Mqtt::getPassword

(

)

const

Definition at line 374 of file Mqtt.cpp.

                                      {
        return password;
    }

getPasswordFlag()

bool iot::mqtt::server::Mqtt::getPasswordFlag

(

)

const

Definition at line 382 of file Mqtt.cpp.

                                     {
        return passwordFlag;
    }

References passwordFlag.

getProtocol()

std::string iot::mqtt::server::Mqtt::getProtocol

(

)

const

Definition at line 342 of file Mqtt.cpp.

                                      {
        return protocol;
    }

getReflect()

bool iot::mqtt::server::Mqtt::getReflect

(

)

const

Definition at line 402 of file Mqtt.cpp.

                                {
        return reflect;
    }

References reflect.

Referenced by iot::mqtt::server::broker::Session::sendPublish().

Here is the caller graph for this function:

getUsername()

std::string iot::mqtt::server::Mqtt::getUsername

(

)

const

Definition at line 370 of file Mqtt.cpp.

                                      {
        return username;
    }

getUsernameFlag()

bool iot::mqtt::server::Mqtt::getUsernameFlag

(

)

const

Definition at line 378 of file Mqtt.cpp.

                                     {
        return usernameFlag;
    }

References usernameFlag.

getWillFlag()

bool iot::mqtt::server::Mqtt::getWillFlag

(

)

const

Definition at line 394 of file Mqtt.cpp.

                                 {
        return willFlag;
    }

References willFlag.

getWillMessage()

std::string iot::mqtt::server::Mqtt::getWillMessage

(

)

const

Definition at line 366 of file Mqtt.cpp.

                                         {
        return willMessage;
    }

getWillQoS()

uint8_t iot::mqtt::server::Mqtt::getWillQoS

(

)

const

Definition at line 390 of file Mqtt.cpp.

                                   {
        return willQoS;
    }

References willQoS.

getWillRetain()

bool iot::mqtt::server::Mqtt::getWillRetain

(

)

const

Definition at line 386 of file Mqtt.cpp.

                                   {
        return willRetain;
    }

References willRetain.

getWillTopic()

std::string iot::mqtt::server::Mqtt::getWillTopic

(

)

const

Definition at line 362 of file Mqtt.cpp.

                                       {
        return willTopic;
    }

initSession() [1/2]

bool iot::mqtt::server::Mqtt::initSession ( const utils::Timeval & keepAlive )

private

Definition at line 125 of file Mqtt.cpp.

                                                        {
        bool success = true;
 
        if (broker->hasActiveSession(clientId)) {
            LOG(ERROR) << connectionName << " MQTT Broker: Existing session found for ClientId = " << clientId;
            LOG(ERROR) << connectionName << " MQTT Broker:   closing";
            sendConnack(MQTT_CONNACK_IDENTIFIERREJECTED, 0);
 
            willFlag = false;
            success = false;
        } else if (broker->hasRetainedSession(clientId)) {
            LOG(INFO) << connectionName << " MQTT Broker: Retained session found for ClientId = " << clientId;
            if (cleanSession) {
                LOG(DEBUG) << connectionName << "   New SessionId = " << this;
                sendConnack(MQTT_CONNACK_ACCEPT, MQTT_SESSION_NEW);
 
                broker->unsubscribe(clientId);
                initSession(broker->newSession(clientId, this), keepAlive);
            } else {
                LOG(DEBUG) << connectionName << "   Renew SessionId = " << this;
                sendConnack(MQTT_CONNACK_ACCEPT, MQTT_SESSION_PRESENT);
 
                initSession(broker->renewSession(clientId, this), keepAlive);
                broker->restartSession(clientId);
            }
        } else {
            LOG(INFO) << connectionName << " MQTT Broker: No session found for ClientId = " << clientId;
            LOG(INFO) << connectionName << " MQTT Broker:   new SessionId = " << this;
 
            sendConnack(MQTT_CONNACK_ACCEPT, MQTT_SESSION_NEW);
 
            initSession(broker->newSession(clientId, this), keepAlive);
        }
 
        return success;
    }

References cleanSession, sendConnack(), and willFlag.

Referenced by _onConnect().

Here is the call graph for this function:

Here is the caller graph for this function:

initSession() [2/2]

void iot::mqtt::Mqtt::initSession ( Session * session, utils::Timeval keepAlive )

private

Definition at line 83 of file Mqtt.cpp.

                                                                   {
        this->session = session;
 
        for (const auto& [packetIdentifier, publish] : session->publishMap) {
            LOG(INFO) << connectionName << " MQTT: PUBLISH Resend";
 
            send(publish);
        }
 
        for (const uint16_t packetIdentifier : session->pubrelPacketIdentifierSet) {
            LOG(INFO) << connectionName << " MQTT: PUBREL Resend";
 
            send(iot::mqtt::packets::Pubrel(packetIdentifier));
        }
 
        if (keepAlive > 0) {
            keepAlive *= 1.5;
 
            LOG(INFO) << connectionName << " MQTT: Keep alive initialized with: " << keepAlive;
 
            keepAliveTimer = core::timer::Timer::singleshotTimer(
                [this, keepAlive]() {
                    LOG(ERROR) << connectionName << " MQTT: Keep-alive timer expired. Interval was: " << keepAlive;
                    mqttContext->close();
                },
                keepAlive);
        }
 
        mqttContext->getSocketConnection()->setTimeout(0);
    }

onConnect()

void iot::mqtt::server::Mqtt::onConnect ( const iot::mqtt::packets::Connect & connect )

privatevirtual

Definition at line 176 of file Mqtt.cpp.

                                                                              {
    }

onDisconnect()

void iot::mqtt::server::Mqtt::onDisconnect ( const iot::mqtt::packets::Disconnect & disconnect )

privatevirtual

Definition at line 188 of file Mqtt.cpp.

                                                                                       {
    }

onPingreq()

void iot::mqtt::server::Mqtt::onPingreq ( const iot::mqtt::packets::Pingreq & pingreq )

privatevirtual

Definition at line 185 of file Mqtt.cpp.

                                                                              {
    }

onSignal()

bool iot::mqtt::server::Mqtt::onSignal ( int sig )

overrideprotectedvirtual

Implements iot::mqtt::Mqtt.

Definition at line 64 of file Mqtt.cpp.

                                                {
        willFlag = false;
        return true;
    }

References willFlag.

onSubscribe()

void iot::mqtt::server::Mqtt::onSubscribe ( const iot::mqtt::packets::Subscribe & subscribe )

privatevirtual

Definition at line 179 of file Mqtt.cpp.

                                                                                    {
    }

onUnsubscribe()

void iot::mqtt::server::Mqtt::onUnsubscribe ( const iot::mqtt::packets::Unsubscribe & unsubscribe )

privatevirtual

Definition at line 182 of file Mqtt.cpp.

                                                                                          {
    }

releaseSession()

void iot::mqtt::server::Mqtt::releaseSession ( )

private

Definition at line 162 of file Mqtt.cpp.

                              {
        if (broker->isActiveSession(clientId, this)) {
            if (cleanSession) {
                LOG(DEBUG) << connectionName << " MQTT Broker: Delete session for ClientId = " << clientId;
                LOG(DEBUG) << connectionName << " MQTT Broker:   SessionId = " << this;
                broker->deleteSession(clientId);
            } else {
                LOG(DEBUG) << connectionName << " MQTT Broker: Retain session for ClientId = " << clientId;
                LOG(DEBUG) << connectionName << " MQTT Broker:   SessionId = " << this;
                broker->retainSession(clientId);
            }
        }
    }

References cleanSession.

Referenced by _onDisconnect(), and ~Mqtt().

Here is the caller graph for this function:

sendConnack()

void iot::mqtt::server::Mqtt::sendConnack	(	uint8_t	returnCode,
		uint8_t	flags ) const

Definition at line 326 of file Mqtt.cpp.

                                                                  { // Server
        send(iot::mqtt::packets::Connack(returnCode, flags));
    }

Referenced by _onConnect(), and initSession().

Here is the caller graph for this function:

sendPingresp()

void iot::mqtt::server::Mqtt::sendPingresp

(

)

const

Definition at line 338 of file Mqtt.cpp.

                                  { // Server
        send(iot::mqtt::packets::Pingresp());
    }

Referenced by _onPingreq().

Here is the caller graph for this function:

sendSuback()

void iot::mqtt::server::Mqtt::sendSuback	(	uint16_t	packetIdentifier,
		const std::list< uint8_t > &	returnCodes ) const

Definition at line 330 of file Mqtt.cpp.

                                                                                              { // Server
        send(iot::mqtt::packets::Suback(packetIdentifier, returnCodes));
    }

sendUnsuback()

void iot::mqtt::server::Mqtt::sendUnsuback

(

uint16_t

packetIdentifier

)

const

Definition at line 334 of file Mqtt.cpp.

                                                           { // Server
        send(iot::mqtt::packets::Unsuback(packetIdentifier));
    }

Referenced by _onUnsubscribe().

Here is the caller graph for this function:

Friends And Related Symbol Documentation

iot::mqtt::server::packets::Connect

friend class iot::mqtt::server::packets::Connect

friend

Definition at line 143 of file Mqtt.h.

iot::mqtt::server::packets::Disconnect

friend class iot::mqtt::server::packets::Disconnect

friend

Definition at line 147 of file Mqtt.h.

iot::mqtt::server::packets::Pingreq

friend class iot::mqtt::server::packets::Pingreq

friend

Definition at line 146 of file Mqtt.h.

iot::mqtt::server::packets::Puback

friend class iot::mqtt::server::packets::Puback

friend

Definition at line 151 of file Mqtt.h.

iot::mqtt::server::packets::Pubcomp

friend class iot::mqtt::server::packets::Pubcomp

friend

Definition at line 149 of file Mqtt.h.

iot::mqtt::server::packets::Publish

friend class iot::mqtt::server::packets::Publish

friend

Definition at line 148 of file Mqtt.h.

iot::mqtt::server::packets::Pubrec

friend class iot::mqtt::server::packets::Pubrec

friend

Definition at line 150 of file Mqtt.h.

iot::mqtt::server::packets::Pubrel

friend class iot::mqtt::server::packets::Pubrel

friend

Definition at line 152 of file Mqtt.h.

iot::mqtt::server::packets::Subscribe

friend class iot::mqtt::server::packets::Subscribe

friend

Definition at line 144 of file Mqtt.h.

iot::mqtt::server::packets::Unsubscribe

friend class iot::mqtt::server::packets::Unsubscribe

friend

Definition at line 145 of file Mqtt.h.

Member Data Documentation

broker

std::shared_ptr<iot::mqtt::server::broker::Broker> iot::mqtt::server::Mqtt::broker

protected

Definition at line 141 of file Mqtt.h.

cleanSession

bool iot::mqtt::server::Mqtt::cleanSession = false

protected

Definition at line 138 of file Mqtt.h.

Referenced by _onConnect(), getCleanSession(), initSession(), and releaseSession().

connectFlags

uint8_t iot::mqtt::server::Mqtt::connectFlags = 0

protected

Definition at line 125 of file Mqtt.h.

Referenced by _onConnect(), and getConnectFlags().

keepAlive

uint16_t iot::mqtt::server::Mqtt::keepAlive = 0

protected

Definition at line 126 of file Mqtt.h.

Referenced by _onConnect(), and getKeepAlive().

level

uint8_t iot::mqtt::server::Mqtt::level = 0

protected

Definition at line 124 of file Mqtt.h.

Referenced by _onConnect(), and getLevel().

password

std::string iot::mqtt::server::Mqtt::password

protected

Definition at line 131 of file Mqtt.h.

passwordFlag

bool iot::mqtt::server::Mqtt::passwordFlag = false

protected

Definition at line 134 of file Mqtt.h.

Referenced by _onConnect(), and getPasswordFlag().

protocol

std::string iot::mqtt::server::Mqtt::protocol

protected

Definition at line 123 of file Mqtt.h.

reflect

bool iot::mqtt::server::Mqtt::reflect = true

protected

Definition at line 139 of file Mqtt.h.

Referenced by _onConnect(), and getReflect().

username

std::string iot::mqtt::server::Mqtt::username

protected

Definition at line 130 of file Mqtt.h.

usernameFlag

bool iot::mqtt::server::Mqtt::usernameFlag = false

protected

Definition at line 133 of file Mqtt.h.

Referenced by _onConnect(), and getUsernameFlag().

willFlag

bool iot::mqtt::server::Mqtt::willFlag = false

protected

Definition at line 137 of file Mqtt.h.

Referenced by _onConnect(), _onDisconnect(), getWillFlag(), initSession(), onSignal(), and ~Mqtt().

willMessage

std::string iot::mqtt::server::Mqtt::willMessage

protected

Definition at line 129 of file Mqtt.h.

willQoS

uint8_t iot::mqtt::server::Mqtt::willQoS = 0

protected

Definition at line 136 of file Mqtt.h.

Referenced by _onConnect(), and getWillQoS().

willRetain

bool iot::mqtt::server::Mqtt::willRetain = false

protected

Definition at line 135 of file Mqtt.h.

Referenced by _onConnect(), and getWillRetain().

willTopic

std::string iot::mqtt::server::Mqtt::willTopic

protected

Definition at line 128 of file Mqtt.h.

---

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

• iot/mqtt/server/Mqtt.h
• iot/mqtt/server/Mqtt.cpp