mirror/lwip
1
0
Fork 0
mirror of https://github.com/lwip-tcpip/lwip.git synced 2024-06-30 18:09:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

mqtt: Fix typos on 'incomming'

Browse Source
This commit is contained in:
Jonathan Demeyer 2022-03-14 16:07:07 +01:00 committed by Erik Ekman
parent 52b4649636
commit 234d282936
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/apps/mqtt/mqtt.c
View File

@ -652,7 +652,7 @@ pub_ack_rec_rel_response(mqtt_client_t *client, u8_t msg, u16_t pkt_id, u8_t qos
* @param result Result code from server
*/
static void
mqtt_incomming_suback(struct mqtt_request_t *r, u8_t result)
mqtt_incoming_suback(struct mqtt_request_t *r, u8_t result)
{
if (r->cb != NULL) {
r->cb(r->arg, result < 3 ? ERR_OK : ERR_ABRT);
@ -757,7 +757,7 @@ mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u
payload_length = length - after_topic;
payload_offset = after_topic;
LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_incomming_publish: Received message with QoS %d at topic: %s, payload length %"U32_F"\n",
LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_incoming_publish: Received message with QoS %d at topic: %s, payload length %"U32_F"\n",
qos, topic, remaining_length + payload_length));
if (client->pub_cb != NULL) {
client->pub_cb(client->inpub_arg, (const char *)topic, remaining_length + payload_length);
@ -777,7 +777,7 @@ mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u
if (remaining_length == 0 && qos > 0) {
/* Send PUBACK for QoS 1 or PUBREC for QoS 2 */
u8_t resp_msg = (qos == 1) ? MQTT_MSG_TYPE_PUBACK : MQTT_MSG_TYPE_PUBREC;
LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_incomming_publish: Sending publish response: %s with pkt_id: %d\n",
LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_incoming_publish: Sending publish response: %s with pkt_id: %d\n",
mqtt_msg_type_to_str(resp_msg), client->inpub_pkt_id));
pub_ack_rec_rel_response(client, resp_msg, client->inpub_pkt_id, 0);
}
@ -812,7 +812,7 @@ mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u
LWIP_DEBUGF(MQTT_DEBUG_WARN, ("mqtt_message_received: To small SUBACK packet\n"));
goto out_disconnect;
} else {
mqtt_incomming_suback(r, var_hdr_payload[2]);
mqtt_incoming_suback(r, var_hdr_payload[2]);
}
} else if (r->cb != NULL) {
r->cb(r->arg, ERR_OK);