31 lines
826 B
C++
31 lines
826 B
C++
#include "PubAckPacket.hpp"
|
|
|
|
using AsyncMqttClientInternals::PubAckPacket;
|
|
|
|
PubAckPacket::PubAckPacket(ParsingInformation* parsingInformation, OnPubAckInternalCallback callback)
|
|
: _parsingInformation(parsingInformation)
|
|
, _callback(callback)
|
|
, _bytePosition(0)
|
|
, _packetIdMsb(0)
|
|
, _packetId(0) {
|
|
}
|
|
|
|
PubAckPacket::~PubAckPacket() {
|
|
}
|
|
|
|
void PubAckPacket::parseVariableHeader(char* data, size_t len, size_t* currentBytePosition) {
|
|
char currentByte = data[(*currentBytePosition)++];
|
|
if (_bytePosition++ == 0) {
|
|
_packetIdMsb = currentByte;
|
|
} else {
|
|
_packetId = currentByte | _packetIdMsb << 8;
|
|
_parsingInformation->bufferState = BufferState::NONE;
|
|
_callback(_packetId);
|
|
}
|
|
}
|
|
|
|
void PubAckPacket::parsePayload(char* data, size_t len, size_t* currentBytePosition) {
|
|
(void)data;
|
|
(void)currentBytePosition;
|
|
}
|