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
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) const
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 () const
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
ControlPacketDeserializer *	createControlPacketDeserializer (iot::mqtt::FixedHeader &fixedHeader) const 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	distributePublish (const iot::mqtt::packets::Publish &publish) final
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::list< std::string >	getSubscriptions () const
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 87 of file Mqtt.h.

Member Typedef Documentation

Super

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

private

Definition at line 89 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 72 of file Mqtt.cpp.

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

References iot::mqtt::Mqtt::Mqtt().

Here is the call graph for this function:

~Mqtt()

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

overridevirtual

Reimplemented from iot::mqtt::Mqtt.

Definition at line 77 of file Mqtt.cpp.

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

References iot::mqtt::Mqtt::clientId, iot::mqtt::server::broker::Broker::publish(), releaseSession(), willFlag, willMessage, willQoS, willRetain, and willTopic.

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 218 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->close();
        } 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->close();
        } 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->close();
        } else if (!connect.getWillFlag() && (connect.getWillQoS() != 0 || connect.getWillRetain())) {
            LOG(ERROR) << connectionName << " MQTT Broker:   WillFlag not set but WillQoS or WillRetain set";
 
            mqttContext->close();
        } else if (connect.getWillQoS() > 2) {
            LOG(ERROR) << connectionName << " MQTT Broker:   WillQoS larger than 2";
 
            mqttContext->close();
        } else if (connect.getPasswordFlag() && !connect.getUsernameFlag()) {
            LOG(ERROR) << connectionName << " MQTT Broker:   Password flag set but username flag not";
 
            mqttContext->close();
        } 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(keepAlive)) {
                onConnect(connect);
            } else {
                mqttContext->close();
            }
        }
    }

References cleanSession, iot::mqtt::Mqtt::clientId, iot::mqtt::MqttContext::close(), connectFlags, iot::mqtt::Mqtt::connectionName, logger::ERROR, iot::mqtt::packets::Connect::getCleanSession(), iot::mqtt::packets::Connect::getClientId(), iot::mqtt::packets::Connect::getConnectFlags(), iot::mqtt::packets::Connect::getKeepAlive(), iot::mqtt::packets::Connect::getLevel(), iot::mqtt::packets::Connect::getPassword(), iot::mqtt::packets::Connect::getPasswordFlag(), iot::mqtt::packets::Connect::getProtocol(), iot::mqtt::packets::Connect::getReflect(), iot::mqtt::packets::Connect::getUsername(), iot::mqtt::packets::Connect::getUsernameFlag(), iot::mqtt::packets::Connect::getWillFlag(), iot::mqtt::packets::Connect::getWillMessage(), iot::mqtt::packets::Connect::getWillQoS(), iot::mqtt::packets::Connect::getWillRetain(), iot::mqtt::packets::Connect::getWillTopic(), logger::INFO, initSession(), iot::mqtt::server::packets::Connect::isFakedClientId(), keepAlive, level, logger::LogMessage::LogMessage(), iot::mqtt::Mqtt::mqttContext, onConnect(), password, passwordFlag, protocol, reflect, sendConnack(), username, usernameFlag, willFlag, willMessage, willQoS, willRetain, and willTopic.

Referenced by iot::mqtt::server::packets::Connect::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

_onDisconnect()

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

private

Definition at line 355 of file Mqtt.cpp.

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

References onDisconnect(), releaseSession(), and willFlag.

Referenced by iot::mqtt::server::packets::Disconnect::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

_onPingreq()

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

private

Definition at line 349 of file Mqtt.cpp.

                                                                    {
        sendPingresp();
 
        onPingreq(pingreq);
    }

References onPingreq(), and sendPingresp().

Referenced by iot::mqtt::server::packets::Pingreq::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

_onPublish()

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

private

Definition at line 296 of file Mqtt.cpp.

                                                                    {
        if (Super::_onPublish(publish)) {
            distributePublish(publish);
        }
    }

References iot::mqtt::Mqtt::_onPublish(), and distributePublish().

Referenced by iot::mqtt::server::packets::Publish::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

_onSubscribe()

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

private

Definition at line 302 of file Mqtt.cpp.

                                                                          {
        if (subscribe.getPacketIdentifier() == 0) {
            LOG(ERROR) << connectionName << " MQTT Broker:   PackageIdentifier missing";
            mqttContext->close();
        } else {
            LOG(DEBUG) << connectionName << " MQTT Broker:   PacketIdentifier: 0x" << std::hex << std::setfill('0') << std::setw(4)
                       << subscribe.getPacketIdentifier() << std::dec;
 
            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);
        }
    }

References iot::mqtt::Mqtt::clientId, iot::mqtt::MqttContext::close(), iot::mqtt::Mqtt::connectionName, logger::DEBUG, logger::ERROR, iot::mqtt::Topic::getName(), iot::mqtt::packets::Subscribe::getPacketIdentifier(), iot::mqtt::Topic::getQoS(), iot::mqtt::packets::Subscribe::getTopics(), logger::INFO, logger::LogMessage::LogMessage(), iot::mqtt::Mqtt::mqttContext, onSubscribe(), sendSuback(), and iot::mqtt::server::broker::Broker::subscribe().

Referenced by iot::mqtt::server::packets::Subscribe::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

_onUnsubscribe()

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

private

Definition at line 327 of file Mqtt.cpp.

                                                                                {
        if (unsubscribe.getPacketIdentifier() == 0) {
            LOG(ERROR) << connectionName << " MQTT Broker:   PackageIdentifier missing";
            mqttContext->close();
        } else {
            LOG(DEBUG) << connectionName << " MQTT Broker:   PacketIdentifier: 0x" << std::hex << std::setfill('0') << std::setw(4)
                       << unsubscribe.getPacketIdentifier() << std::dec;
 
            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 iot::mqtt::Mqtt::clientId, iot::mqtt::MqttContext::close(), iot::mqtt::Mqtt::connectionName, logger::DEBUG, logger::ERROR, iot::mqtt::packets::Unsubscribe::getPacketIdentifier(), iot::mqtt::packets::Unsubscribe::getTopics(), logger::INFO, logger::LogMessage::LogMessage(), iot::mqtt::Mqtt::mqttContext, onUnsubscribe(), sendUnsuback(), and iot::mqtt::server::broker::Broker::unsubscribe().

Referenced by iot::mqtt::server::packets::Unsubscribe::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

createControlPacketDeserializer()

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

finalprivatevirtual

Implements iot::mqtt::Mqtt.

Definition at line 90 of file Mqtt.cpp.

                                                                                                                 {
        iot::mqtt::ControlPacketDeserializer* controlPacketDeserializer = nullptr; // NOLINT
 
        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;
    }

References iot::mqtt::server::packets::Connect::Connect(), iot::mqtt::server::packets::Disconnect::Disconnect(), iot::mqtt::FixedHeader::getFlags(), iot::mqtt::FixedHeader::getRemainingLength(), iot::mqtt::FixedHeader::getType(), iot::mqtt::server::packets::Pingreq::Pingreq(), iot::mqtt::server::packets::Puback::Puback(), iot::mqtt::server::packets::Pubcomp::Pubcomp(), iot::mqtt::server::packets::Publish::Publish(), iot::mqtt::server::packets::Pubrec::Pubrec(), iot::mqtt::server::packets::Pubrel::Pubrel(), iot::mqtt::server::packets::Subscribe::Subscribe(), and iot::mqtt::server::packets::Unsubscribe::Unsubscribe().

Here is the call graph for this function:

deliverPacket()

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

overrideprivatevirtual

Implements iot::mqtt::Mqtt.

Definition at line 142 of file Mqtt.cpp.

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

References iot::mqtt::server::ControlPacketDeserializer::deliverPacket().

Here is the call graph for this function:

distributePublish()

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

finalprivatevirtual

Implements iot::mqtt::Mqtt.

Definition at line 197 of file Mqtt.cpp.

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

References iot::mqtt::Mqtt::clientId, iot::mqtt::packets::Publish::getMessage(), iot::mqtt::packets::Publish::getQoS(), iot::mqtt::packets::Publish::getRetain(), iot::mqtt::packets::Publish::getTopic(), iot::mqtt::Mqtt::onPublish(), and iot::mqtt::server::broker::Broker::publish().

Referenced by _onPublish().

Here is the call graph for this function:

Here is the caller graph for this function:

getCleanSession()

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

(

)

const

Definition at line 439 of file Mqtt.cpp.

                                     {
        return cleanSession;
    }

References cleanSession.

getClientId()

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

(

)

const

Definition at line 399 of file Mqtt.cpp.

                                      {
        return clientId;
    }

References iot::mqtt::Mqtt::clientId.

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

Here is the caller graph for this function:

getConnectFlags()

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

(

)

const

Definition at line 391 of file Mqtt.cpp.

                                        {
        return connectFlags;
    }

References connectFlags.

getKeepAlive()

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

(

)

const

Definition at line 395 of file Mqtt.cpp.

                                      {
        return keepAlive;
    }

References keepAlive.

getLevel()

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

(

)

const

Definition at line 387 of file Mqtt.cpp.

                                 {
        return level;
    }

References level.

getPassword()

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

(

)

const

Definition at line 415 of file Mqtt.cpp.

                                      {
        return password;
    }

References password.

getPasswordFlag()

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

(

)

const

Definition at line 423 of file Mqtt.cpp.

                                     {
        return passwordFlag;
    }

References passwordFlag.

getProtocol()

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

(

)

const

Definition at line 383 of file Mqtt.cpp.

                                      {
        return protocol;
    }

References protocol.

getReflect()

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

(

)

const

Definition at line 443 of file Mqtt.cpp.

                                {
        return reflect;
    }

References reflect.

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

Here is the caller graph for this function:

getSubscriptions()

std::list< std::string > iot::mqtt::server::Mqtt::getSubscriptions ( ) const

private

Definition at line 379 of file Mqtt.cpp.

                                                    {
        return broker->getSubscriptions(clientId);
    }

References iot::mqtt::Mqtt::clientId, and iot::mqtt::server::broker::Broker::getSubscriptions().

Here is the call graph for this function:

getUsername()

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

(

)

const

Definition at line 411 of file Mqtt.cpp.

                                      {
        return username;
    }

References username.

getUsernameFlag()

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

(

)

const

Definition at line 419 of file Mqtt.cpp.

                                     {
        return usernameFlag;
    }

References usernameFlag.

getWillFlag()

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

(

)

const

Definition at line 435 of file Mqtt.cpp.

                                 {
        return willFlag;
    }

References willFlag.

getWillMessage()

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

(

)

const

Definition at line 407 of file Mqtt.cpp.

                                         {
        return willMessage;
    }

References willMessage.

getWillQoS()

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

(

)

const

Definition at line 431 of file Mqtt.cpp.

                                   {
        return willQoS;
    }

References willQoS.

getWillRetain()

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

(

)

const

Definition at line 427 of file Mqtt.cpp.

                                   {
        return willRetain;
    }

References willRetain.

getWillTopic()

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

(

)

const

Definition at line 403 of file Mqtt.cpp.

                                       {
        return willTopic;
    }

References willTopic.

initSession() [1/2]

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

private

Definition at line 146 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, iot::mqtt::Mqtt::clientId, iot::mqtt::Mqtt::connectionName, logger::DEBUG, logger::ERROR, iot::mqtt::server::broker::Broker::hasActiveSession(), iot::mqtt::server::broker::Broker::hasRetainedSession(), logger::INFO, iot::mqtt::Mqtt::initSession(), logger::LogMessage::LogMessage(), iot::mqtt::server::broker::Broker::newSession(), iot::mqtt::server::broker::Broker::renewSession(), iot::mqtt::server::broker::Broker::restartSession(), sendConnack(), iot::mqtt::server::broker::Broker::unsubscribe(), 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 105 of file Mqtt.cpp.

                                                                   {
        this->session = session;
 
        for (const auto& [packetIdentifier, publish] : session->outgoingPublishMap) {
            LOG(INFO) << connectionName << " MQTT: PUBLISH Resend";
 
            send(publish);
        }
 
        for (const uint16_t packetIdentifier : session->pubrelPacketIdentifierSet) {
            LOG(INFO) << connectionName << " MQTT: PUBREL Resend";
 
            sendPubrel(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 203 of file Mqtt.cpp.

                                                                              {
    }

Referenced by _onConnect().

Here is the caller graph for this function:

onDisconnect()

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

privatevirtual

Definition at line 215 of file Mqtt.cpp.

                                                                                       {
    }

Referenced by _onDisconnect().

Here is the caller graph for this function:

onPingreq()

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

privatevirtual

Definition at line 212 of file Mqtt.cpp.

                                                                              {
    }

Referenced by _onPingreq().

Here is the caller graph for this function:

onSignal()

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

overrideprotectedvirtual

Implements iot::mqtt::Mqtt.

Definition at line 85 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 206 of file Mqtt.cpp.

                                                                                    {
    }

Referenced by _onSubscribe().

Here is the caller graph for this function:

onUnsubscribe()

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

privatevirtual

Definition at line 209 of file Mqtt.cpp.

                                                                                          {
    }

Referenced by _onUnsubscribe().

Here is the caller graph for this function:

releaseSession()

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

private

Definition at line 183 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, iot::mqtt::Mqtt::clientId, iot::mqtt::Mqtt::connectionName, logger::DEBUG, iot::mqtt::server::broker::Broker::deleteSession(), iot::mqtt::server::broker::Broker::isActiveSession(), logger::LogMessage::LogMessage(), and iot::mqtt::server::broker::Broker::retainSession().

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

Here is the call graph for this function:

Here is the caller graph for this function:

sendConnack()

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

private

Definition at line 363 of file Mqtt.cpp.

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

References iot::mqtt::packets::Connack::Connack(), and iot::mqtt::Mqtt::send().

Referenced by _onConnect(), and initSession().

Here is the call graph for this function:

Here is the caller graph for this function:

sendPingresp()

void iot::mqtt::server::Mqtt::sendPingresp ( ) const

private

Definition at line 375 of file Mqtt.cpp.

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

References iot::mqtt::packets::Pingresp::Pingresp(), and iot::mqtt::Mqtt::send().

Referenced by _onPingreq().

Here is the call graph for this function:

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

private

Definition at line 367 of file Mqtt.cpp.

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

References iot::mqtt::Mqtt::send(), and iot::mqtt::packets::Suback::Suback().

Referenced by _onSubscribe().

Here is the call graph for this function:

Here is the caller graph for this function:

sendUnsuback()

void iot::mqtt::server::Mqtt::sendUnsuback ( uint16_t packetIdentifier ) const

private

Definition at line 371 of file Mqtt.cpp.

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

References iot::mqtt::Mqtt::send(), and iot::mqtt::packets::Unsuback::Unsuback().

Referenced by _onUnsubscribe().

Here is the call graph for this function:

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 168 of file Mqtt.h.

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

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

friend

Definition at line 172 of file Mqtt.h.

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

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

friend

Definition at line 171 of file Mqtt.h.

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

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

friend

Definition at line 176 of file Mqtt.h.

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

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

friend

Definition at line 174 of file Mqtt.h.

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

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

friend

Definition at line 173 of file Mqtt.h.

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

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

friend

Definition at line 175 of file Mqtt.h.

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

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

friend

Definition at line 177 of file Mqtt.h.

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

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

friend

Definition at line 169 of file Mqtt.h.

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

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

friend

Definition at line 170 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 166 of file Mqtt.h.

cleanSession

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

protected

Definition at line 163 of file Mqtt.h.

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

connectFlags

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

protected

Definition at line 150 of file Mqtt.h.

Referenced by _onConnect(), and getConnectFlags().

keepAlive

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

protected

Definition at line 151 of file Mqtt.h.

Referenced by _onConnect(), and getKeepAlive().

level

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

protected

Definition at line 149 of file Mqtt.h.

Referenced by _onConnect(), and getLevel().

password

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

protected

Definition at line 156 of file Mqtt.h.

Referenced by _onConnect(), and getPassword().

passwordFlag

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

protected

Definition at line 159 of file Mqtt.h.

Referenced by _onConnect(), and getPasswordFlag().

protocol

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

protected

Definition at line 148 of file Mqtt.h.

Referenced by _onConnect(), and getProtocol().

reflect

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

protected

Definition at line 164 of file Mqtt.h.

Referenced by _onConnect(), and getReflect().

username

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

protected

Definition at line 155 of file Mqtt.h.

Referenced by _onConnect(), and getUsername().

usernameFlag

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

protected

Definition at line 158 of file Mqtt.h.

Referenced by _onConnect(), and getUsernameFlag().

willFlag

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

protected

Definition at line 162 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 154 of file Mqtt.h.

Referenced by _onConnect(), getWillMessage(), and ~Mqtt().

willQoS

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

protected

Definition at line 161 of file Mqtt.h.

Referenced by _onConnect(), getWillQoS(), and ~Mqtt().

willRetain

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

protected

Definition at line 160 of file Mqtt.h.

Referenced by _onConnect(), getWillRetain(), and ~Mqtt().

willTopic

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

protected

Definition at line 153 of file Mqtt.h.

Referenced by _onConnect(), getWillTopic(), and ~Mqtt().

---

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

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