dunkelstern/libmqtt
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Bugfix: Missing flags in publish message

Browse source
This commit is contained in:
Johannes Schriewer 2018-07-28 17:58:20 +02:00
parent 7a03c95889
commit 6590736a9d
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/packet.c
View file

@ -353,6 +353,15 @@ Buffer *encode_publish(PublishPayload *payload) {
Buffer *buffer = make_buffer_for_header(sz, PacketTypePublish); Buffer *buffer = make_buffer_for_header(sz, PacketTypePublish);
// Flags in header
if (payload->retain) {
buffer->data[buffer->position - 2] |= 1;
}
buffer->data[buffer->position - 2] |= (payload->qos << 1);
if (payload->duplicate) {
buffer->data[buffer->position - 2] |= 8;
}
// Variable header // Variable header
utf8_string_encode(payload->topic, buffer); utf8_string_encode(payload->topic, buffer);
buffer->data[buffer->position++] = (payload->packet_id & 0xff00) >> 8; buffer->data[buffer->position++] = (payload->packet_id & 0xff00) >> 8;