31 lines
881 B
C++
31 lines
881 B
C++
#include "ConnAckPacket.hpp"
|
|
|
|
using AsyncMqttClientInternals::ConnAckPacket;
|
|
|
|
ConnAckPacket::ConnAckPacket(ParsingInformation* parsingInformation, OnConnAckInternalCallback callback)
|
|
: _parsingInformation(parsingInformation)
|
|
, _callback(callback)
|
|
, _bytePosition(0)
|
|
, _sessionPresent(false)
|
|
, _connectReturnCode(0) {
|
|
}
|
|
|
|
ConnAckPacket::~ConnAckPacket() {
|
|
}
|
|
|
|
void ConnAckPacket::parseVariableHeader(char* data, size_t len, size_t* currentBytePosition) {
|
|
char currentByte = data[(*currentBytePosition)++];
|
|
if (_bytePosition++ == 0) {
|
|
_sessionPresent = (currentByte << 7) >> 7;
|
|
} else {
|
|
_connectReturnCode = currentByte;
|
|
_parsingInformation->bufferState = BufferState::NONE;
|
|
_callback(_sessionPresent, _connectReturnCode);
|
|
}
|
|
}
|
|
|
|
void ConnAckPacket::parsePayload(char* data, size_t len, size_t* currentBytePosition) {
|
|
(void)data;
|
|
(void)currentBytePosition;
|
|
}
|