mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2026-05-14 01:36:09 +02:00
Code Issues Projects Releases Wiki Activity

CLEANUP: mqtt: fix spelling of shared_subscription_available

Browse Source 
The struct member 'shared_subsription_available' was misspelled (missing
'c' in 'subscription'). Let's fix it to ease maintenance.
This commit is contained in:
Willy Tarreau 2026-05-11 17:28:21 +02:00
parent 82d723dd8e
commit 57c3e4b4e2
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/haproxy/mqtt-t.h
View File

@ -278,7 +278,7 @@ struct connack {
} user_props[MQTT_PROP_USER_PROPERTY_ENTRIES];
uint8_t wildcard_subscription_available;
uint8_t subscription_identifiers_available;
uint8_t shared_subsription_available;
uint8_t shared_subscription_available;
uint16_t server_keepalive;
struct ist response_information;
struct ist server_reference;

6
src/mqtt.c
View File

@ -671,7 +671,7 @@ struct ist mqtt_field_value(struct ist msg, int type, int fieldname_id)
case MQTT_FN_SHARED_SUBSCRIPTION_AVAILABLE:
if (mpkt.data.connack.var_hdr.protocol_version != MQTT_VERSION_5_0)
goto not_found_or_invalid;
if (!mqtt_uint2str(trash, mpkt.data.connack.var_hdr.props.shared_subsription_available))
if (!mqtt_uint2str(trash, mpkt.data.connack.var_hdr.props.shared_subscription_available))
goto not_found_or_invalid;
res = ist2(trash->area, trash->data);
goto end;
@ -1140,9 +1140,9 @@ static int mqtt_parse_connack(struct ist parser, struct mqtt_pkt *mpkt)
case MQTT_PROP_SHARED_SUBSRIPTION_AVAILABLE:
if (fields & MQTT_FN_BIT_SHARED_SUBSCRIPTION_AVAILABLE)
goto end;
props = mqtt_read_1byte_int(istnext(props), &mpkt->data.connack.var_hdr.props.shared_subsription_available);
props = mqtt_read_1byte_int(istnext(props), &mpkt->data.connack.var_hdr.props.shared_subscription_available);
/* can have only 2 values: 0 or 1 */
if (mpkt->data.connack.var_hdr.props.shared_subsription_available > 1)
if (mpkt->data.connack.var_hdr.props.shared_subscription_available > 1)
goto end;
fields |= MQTT_FN_BIT_SHARED_SUBSCRIPTION_AVAILABLE;
break;