in src/mqtt_codec.c [305:334]
static BUFFER_HANDLE constructPublishReply(CONTROL_PACKET_TYPE type, uint8_t flags, uint16_t packetId)
{
BUFFER_HANDLE result = BUFFER_new();
if (result != NULL)
{
if (BUFFER_pre_build(result, 4) != 0)
{
BUFFER_delete(result);
result = NULL;
}
else
{
uint8_t* iterator = BUFFER_u_char(result);
if (iterator == NULL)
{
BUFFER_delete(result);
result = NULL;
}
else
{
*iterator = (uint8_t)type | flags;
iterator++;
*iterator = 0x2;
iterator++;
byteutil_writeInt(&iterator, packetId);
}
}
}
return result;
}