From 3a98dbb918b994f643b836b4a1e3eda30fefc5b4 Mon Sep 17 00:00:00 2001 From: Chunho Lee Date: Wed, 2 Feb 2022 16:46:20 -0800 Subject: [PATCH] ss: mqtt: fix wrong QoS value on Birth message --- lib/secure-streams/protocols/ss-mqtt.c | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/lib/secure-streams/protocols/ss-mqtt.c b/lib/secure-streams/protocols/ss-mqtt.c index f13eea4a5..9d58cf887 100644 --- a/lib/secure-streams/protocols/ss-mqtt.c +++ b/lib/secure-streams/protocols/ss-mqtt.c @@ -1,7 +1,7 @@ /* * libwebsockets - small server side websockets and web server implementation * - * Copyright (C) 2019 - 2021 Andy Green + * Copyright (C) 2019 - 2022 Andy Green * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to @@ -187,6 +187,7 @@ secstream_mqtt_publish(struct lws *wsi, uint8_t *buf, size_t buflen, mqpp.topic_len = (uint16_t)strlen(mqpp.topic); mqpp.packet_id = (uint16_t)(h->txord - 1); + mqpp.qos = qos; mqpp.payload = buf; if (h->writeable_len) mqpp.payload_len = (uint32_t)h->writeable_len; @@ -196,8 +197,6 @@ secstream_mqtt_publish(struct lws *wsi, uint8_t *buf, size_t buflen, lwsl_notice("%s: payload len %d\n", __func__, (int)mqpp.payload_len); - mqpp.qos = h->policy->u.mqtt.qos; - if (lws_mqtt_client_send_publish(wsi, &mqpp, (const char *)buf, (uint32_t)buflen,