iot::mqtt::ControlPacketDeserializer Class Reference

#include <ControlPacketDeserializer.h>

Inheritance diagram for iot::mqtt::ControlPacketDeserializer:

Collaboration diagram for iot::mqtt::ControlPacketDeserializer:

Public Member Functions
	ControlPacketDeserializer ()=default
	ControlPacketDeserializer (uint32_t remainingLength, uint8_t flags, uint8_t mustFlags)
ControlPacketDeserializer &	operator= (const ControlPacketDeserializer &)=default
virtual	~ControlPacketDeserializer ()
std::size_t	deserialize (iot::mqtt::MqttContext *mqttContext)
uint32_t	getRemainingLength () const
bool	isComplete () const
bool	isError () const
std::size_t	getConsumed () const

Protected Attributes
bool	complete = false
bool	error = false
uint32_t	remainingLength = 0
std::size_t	consumed = 0

Private Member Functions
virtual std::size_t	deserializeVP (iot::mqtt::MqttContext *mqttContext)=0

Detailed Description

Definition at line 58 of file ControlPacketDeserializer.h.

Constructor & Destructor Documentation

ControlPacketDeserializer() [1/2]

iot::mqtt::ControlPacketDeserializer::ControlPacketDeserializer ( )

default

ControlPacketDeserializer() [2/2]

iot::mqtt::ControlPacketDeserializer::ControlPacketDeserializer	(	uint32_t	remainingLength,
		uint8_t	flags,
		uint8_t	mustFlags )

Definition at line 50 of file ControlPacketDeserializer.cpp.

        : error(flags != mustFlags)
        , remainingLength(remainingLength) {
    }

References error, and remainingLength.

~ControlPacketDeserializer()

iot::mqtt::ControlPacketDeserializer::~ControlPacketDeserializer ( )

virtual

Reimplemented in iot::mqtt::client::ControlPacketDeserializer, and iot::mqtt::server::ControlPacketDeserializer.

Definition at line 55 of file ControlPacketDeserializer.cpp.

                                                          {
    }

Member Function Documentation

deserialize()

std::size_t iot::mqtt::ControlPacketDeserializer::deserialize

(

iot::mqtt::MqttContext *

mqttContext

)

Definition at line 58 of file ControlPacketDeserializer.cpp.

                                                                                    {
        const std::size_t currentConsumed = deserializeVP(mqttContext);
        consumed += currentConsumed;
 
        error = (complete && consumed != this->getRemainingLength()) || (!complete && consumed >= this->getRemainingLength());
 
        return currentConsumed;
    }

References consumed, and deserializeVP().

Here is the call graph for this function:

deserializeVP()

virtual std::size_t iot::mqtt::ControlPacketDeserializer::deserializeVP ( iot::mqtt::MqttContext * mqttContext )

privatepure virtual

Implemented in iot::mqtt::client::packets::Connack, iot::mqtt::client::packets::Pingresp, iot::mqtt::client::packets::Puback, iot::mqtt::client::packets::Pubcomp, iot::mqtt::client::packets::Publish, iot::mqtt::client::packets::Pubrec, iot::mqtt::client::packets::Pubrel, iot::mqtt::client::packets::Suback, iot::mqtt::client::packets::Unsuback, iot::mqtt::server::packets::Connect, iot::mqtt::server::packets::Disconnect, iot::mqtt::server::packets::Pingreq, iot::mqtt::server::packets::Puback, iot::mqtt::server::packets::Pubcomp, iot::mqtt::server::packets::Publish, iot::mqtt::server::packets::Pubrec, iot::mqtt::server::packets::Pubrel, iot::mqtt::server::packets::Subscribe, and iot::mqtt::server::packets::Unsubscribe.

Referenced by deserialize().

Here is the caller graph for this function:

getConsumed()

std::size_t iot::mqtt::ControlPacketDeserializer::getConsumed

(

)

const

Definition at line 79 of file ControlPacketDeserializer.cpp.

                                                           {
        return consumed;
    }

References consumed.

Referenced by iot::mqtt::client::packets::Publish::deserializeVP(), iot::mqtt::client::packets::Suback::deserializeVP(), iot::mqtt::server::packets::Publish::deserializeVP(), iot::mqtt::server::packets::Subscribe::deserializeVP(), and iot::mqtt::server::packets::Unsubscribe::deserializeVP().

Here is the caller graph for this function:

getRemainingLength()

uint32_t iot::mqtt::ControlPacketDeserializer::getRemainingLength

(

)

const

Definition at line 67 of file ControlPacketDeserializer.cpp.

                                                                 {
        return remainingLength;
    }

References remainingLength.

Referenced by iot::mqtt::client::packets::Publish::deserializeVP(), iot::mqtt::client::packets::Suback::deserializeVP(), iot::mqtt::server::packets::Publish::deserializeVP(), iot::mqtt::server::packets::Subscribe::deserializeVP(), and iot::mqtt::server::packets::Unsubscribe::deserializeVP().

Here is the caller graph for this function:

isComplete()

bool iot::mqtt::ControlPacketDeserializer::isComplete

(

)

const

Definition at line 71 of file ControlPacketDeserializer.cpp.

                                                     {
        return complete;
    }

References complete.

isError()

bool iot::mqtt::ControlPacketDeserializer::isError

(

)

const

Definition at line 75 of file ControlPacketDeserializer.cpp.

                                                  {
        return error;
    }

References error.

operator=()

ControlPacketDeserializer & iot::mqtt::ControlPacketDeserializer::operator= ( const ControlPacketDeserializer & )

default

Member Data Documentation

complete

bool iot::mqtt::ControlPacketDeserializer::complete = false

protected

Definition at line 82 of file ControlPacketDeserializer.h.

Referenced by iot::mqtt::client::packets::Connack::deserializeVP(), iot::mqtt::client::packets::Pingresp::deserializeVP(), iot::mqtt::client::packets::Puback::deserializeVP(), iot::mqtt::client::packets::Pubcomp::deserializeVP(), iot::mqtt::client::packets::Publish::deserializeVP(), iot::mqtt::client::packets::Pubrec::deserializeVP(), iot::mqtt::client::packets::Pubrel::deserializeVP(), iot::mqtt::client::packets::Suback::deserializeVP(), iot::mqtt::client::packets::Unsuback::deserializeVP(), iot::mqtt::server::packets::Connect::deserializeVP(), iot::mqtt::server::packets::Disconnect::deserializeVP(), iot::mqtt::server::packets::Pingreq::deserializeVP(), iot::mqtt::server::packets::Puback::deserializeVP(), iot::mqtt::server::packets::Pubcomp::deserializeVP(), iot::mqtt::server::packets::Publish::deserializeVP(), iot::mqtt::server::packets::Pubrec::deserializeVP(), iot::mqtt::server::packets::Pubrel::deserializeVP(), iot::mqtt::server::packets::Subscribe::deserializeVP(), iot::mqtt::server::packets::Unsubscribe::deserializeVP(), and isComplete().

consumed

std::size_t iot::mqtt::ControlPacketDeserializer::consumed = 0

protected

Definition at line 87 of file ControlPacketDeserializer.h.

Referenced by deserialize(), and getConsumed().

error

bool iot::mqtt::ControlPacketDeserializer::error = false

protected

Definition at line 83 of file ControlPacketDeserializer.h.

Referenced by ControlPacketDeserializer(), isError(), iot::mqtt::client::packets::Publish::Publish(), and iot::mqtt::server::packets::Publish::Publish().

remainingLength

uint32_t iot::mqtt::ControlPacketDeserializer::remainingLength = 0

protected

Definition at line 85 of file ControlPacketDeserializer.h.

Referenced by ControlPacketDeserializer(), and getRemainingLength().

---

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

• iot/mqtt/ControlPacketDeserializer.h
• iot/mqtt/ControlPacketDeserializer.cpp