/builds/wireshark/wireshark/epan/dissectors/packet-mqtt.c

Bug Summary

File:	builds/wireshark/wireshark/epan/dissectors/packet-mqtt.c
Warning:	line 1227, column 29 Access to field 'topic' results in a dereference of a null pointer (loaded from variable 'pdu_data')
Annotated Source Code

Press '?' to see keyboard shortcuts
Show analyzer invocation
clang -cc1 -cc1 -triple x86_64-pc-linux-gnu -analyze -disable-free -clear-ast-before-backend -disable-llvm-verifier -discard-value-names -main-file-name packet-mqtt.c -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -setup-static-analyzer -mrelocation-model pic -pic-level 2 -fhalf-no-semantic-interposition -fno-delete-null-pointer-checks -mframe-pointer=all -relaxed-aliasing -fmath-errno -ffp-contract=on -fno-rounding-math -ffloat16-excess-precision=fast -fbfloat16-excess-precision=fast -mconstructor-aliases -funwind-tables=2 -target-cpu x86-64 -tune-cpu generic -debugger-tuning=gdb -fdebug-compilation-dir=/builds/wireshark/wireshark/build -fcoverage-compilation-dir=/builds/wireshark/wireshark/build -resource-dir /usr/lib/llvm-22/lib/clang/22 -isystem /usr/include/glib-2.0 -isystem /usr/lib/x86_64-linux-gnu/glib-2.0/include -isystem /builds/wireshark/wireshark/epan/dissectors -isystem /builds/wireshark/wireshark/build/epan/dissectors -isystem /usr/include/mit-krb5 -isystem /builds/wireshark/wireshark/epan -isystem /usr/include/libxml2 -D CARES_NO_DEPRECATED -D G_DISABLE_DEPRECATED -D G_DISABLE_SINGLE_INCLUDES -D WS_BUILD_DLL -D WS_DEBUG -D WS_DEBUG_UTF_8 -I /builds/wireshark/wireshark/build -I /builds/wireshark/wireshark -I /builds/wireshark/wireshark/include -D _GLIBCXX_ASSERTIONS -internal-isystem /usr/lib/llvm-22/lib/clang/22/include -internal-isystem /usr/local/include -internal-isystem /usr/lib/gcc/x86_64-linux-gnu/16/../../../../x86_64-linux-gnu/include -internal-externc-isystem /usr/include/x86_64-linux-gnu -internal-externc-isystem /include -internal-externc-isystem /usr/include -fmacro-prefix-map=/builds/wireshark/wireshark/= -fmacro-prefix-map=/builds/wireshark/wireshark/build/= -fmacro-prefix-map=../= -Wno-format-nonliteral -std=gnu17 -ferror-limit 19 -fvisibility=hidden -fwrapv -fwrapv-pointer -fstrict-flex-arrays=3 -stack-protector 2 -fstack-clash-protection -fcf-protection=full -fgnuc-version=4.2.1 -fskip-odr-check-in-gmf -fexceptions -fcolor-diagnostics -analyzer-output=html -faddrsig -fdwarf2-cfi-asm -o /builds/wireshark/wireshark/sbout/2026-11-13-100306-3661-1 -x c /builds/wireshark/wireshark/epan/dissectors/packet-mqtt.c
1/* packet-mqtt.c
* Routines for MQTT Protocol dissection
*
* MQTT v5.0 support sponsored by 1byt3 <customers at 1byt3.com>
*
* By Lakshmi Narayana Madala  <[email protected]>
*    Stig Bjorlykke  <[email protected]>
*
* Wireshark - Network traffic analyzer
* By Gerald Combs <[email protected]>
* Copyright 1998 Gerald Combs
*
* SPDX-License-Identifier: GPL-2.0-or-later
*/

16/*
* Protocol description:
*
* MQTT is a Client Server publish/subscribe messaging transport
* protocol. The protocol runs over TCP/IP, or over other network
* protocols that provide ordered, lossless, bi-directional
* connections.
*
* MQTT v3.1 specification:
* http://public.dhe.ibm.com/software/dw/webservices/ws-mqtt/mqtt-v3r1.html
*
* MQTT v3.1.1 specification:
* http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/
*
* MQTT v5.0 specification:
* http://docs.oasis-open.org/mqtt/mqtt/v5.0/
*
*/

35#include "config.h"
36#include <epan/expert.h>
37#include <epan/packet.h>
38#include <epan/proto_data.h>
39#include <epan/tfs.h>
40#include <wsutil/array.h>
41#include <epan/uat.h>
42#include "packet-tcp.h"
43#include "packet-tls.h"

45#define MQTT_DEFAULT_PORT1883     1883 /* IANA registered under service name as mqtt */
46#define MQTT_SSL_DEFAULT_PORT8883 8883 /* IANA registered under service name secure-mqtt */

48/* MQTT Protocol Versions */
49#define MQTT_PROTO_V313      3
50#define MQTT_PROTO_V3114     4
51#define MQTT_PROTO_V505      5

53#define MQTT_HDR_SIZE_BEFORE_LEN1 1

55/* MQTT Message Types */
56#define MQTT_RESERVED0        0
57#define MQTT_CONNECT1         1
58#define MQTT_CONNACK2         2
59#define MQTT_PUBLISH3         3
60#define MQTT_PUBACK4          4
61#define MQTT_PUBREC5          5
62#define MQTT_PUBREL6          6
63#define MQTT_PUBCOMP7         7
64#define MQTT_SUBSCRIBE8       8
65#define MQTT_SUBACK9          9
66#define MQTT_UNSUBSCRIBE10    10
67#define MQTT_UNSUBACK11       11
68#define MQTT_PINGREQ12        12
69#define MQTT_PINGRESP13       13
70#define MQTT_DISCONNECT14     14
71#define MQTT_AUTH15           15
72#define MQTT_RESERVED_1616    16

74/* Flag Values to extract fields */
75#define MQTT_MASK_MSG_TYPE0xF0          0xF0
76#define MQTT_MASK_HDR_RESERVED0x0F      0x0F
77#define MQTT_MASK_HDR_DUP_RESERVED0x07  0x07
78#define MQTT_MASK_QOS0x06               0x06
79#define MQTT_MASK_DUP_FLAG0x08          0x08
80#define MQTT_MASK_RETAIN0x01            0x01

82/* MQTT v5.0 Flag Values for the Subscription Options @ Subscribe Packet */
83#define MQTT_MASK_SUBS_QOS0x03          0x03
84#define MQTT_MASK_SUBS_NL0x04           0x04
85#define MQTT_MASK_SUBS_RAP0x08          0x08
86#define MQTT_MASK_SUBS_RETAIN0x30       0x30
87#define MQTT_MASK_SUBS_RESERVED0xC0     0xC0

89void proto_register_mqtt(void);
90void proto_reg_handoff_mqtt(void);

92static dissector_table_t media_type_dissector_table;

94static const value_string mqtt_protocol_version_vals[] = {
{ MQTT_PROTO_V313,        "MQTT v3.1" },
{ MQTT_PROTO_V3114,       "MQTT v3.1.1" },
{ MQTT_PROTO_V505,        "MQTT v5.0" },
{ 0,                     NULL((void*)0) }
99};

101static const enum_val_t mqtt_protocol_version_enumvals[] = {
  { "none",  "None",         0 },
  { "v31",   "MQTT v3.1",    MQTT_PROTO_V313 },
  { "v311",  "MQTT v3.1.1",  MQTT_PROTO_V3114 },
  { "v50",   "MQTT v5.0",    MQTT_PROTO_V505 },
  { NULL((void*)0),    NULL((void*)0),           0 }
107};

109static const value_string mqtt_msgtype_vals[] = {
{ MQTT_RESERVED0,          "Reserved" },
{ MQTT_CONNECT1,           "Connect Command" },
{ MQTT_CONNACK2,           "Connect Ack" },
{ MQTT_PUBLISH3,           "Publish Message" },
{ MQTT_PUBACK4,            "Publish Ack" },
{ MQTT_PUBREC5,            "Publish Received" },
{ MQTT_PUBREL6,            "Publish Release" },
{ MQTT_PUBCOMP7,           "Publish Complete" },
{ MQTT_SUBSCRIBE8,         "Subscribe Request" },
{ MQTT_SUBACK9,            "Subscribe Ack" },
{ MQTT_UNSUBSCRIBE10,       "Unsubscribe Request" },
{ MQTT_UNSUBACK11,          "Unsubscribe Ack" },
{ MQTT_PINGREQ12,           "Ping Request" },
{ MQTT_PINGRESP13,          "Ping Response" },
{ MQTT_DISCONNECT14,        "Disconnect Req" },
{ MQTT_AUTH15,              "Authentication Exchange" },
{ MQTT_RESERVED_1616,       "Reserved" },
{ 0,                      NULL((void*)0) }
128};
129static value_string_ext mqtt_msgtype_vals_ext = VALUE_STRING_EXT_INIT(mqtt_msgtype_vals){ _try_val_to_str_ext_init, 0, (sizeof (mqtt_msgtype_vals) / sizeof
 ((mqtt_msgtype_vals)[0]))-1, mqtt_msgtype_vals, "mqtt_msgtype_vals"
, ((void*)0) };

131#define MQTT_QOS_ATMOST_ONCE0      0
132#define MQTT_QOS_ATLEAST_ONCE1     1
133#define MQTT_QOS_EXACTLY_ONCE2     2
134#define MQTT_QOS_RESERVED3         3

136static const value_string mqtt_qos_vals[] = {
{ MQTT_QOS_ATMOST_ONCE0,       "At most once delivery (Fire and Forget)" },
{ MQTT_QOS_ATLEAST_ONCE1,      "At least once delivery (Acknowledged deliver)" },
{ MQTT_QOS_EXACTLY_ONCE2,      "Exactly once delivery (Assured Delivery)" },
{ MQTT_QOS_RESERVED3,          "Reserved" },
{ 0,                          NULL((void*)0) }
142};

144#define MQTT_SUBACK_FAILURE128  128

146static const value_string mqtt_subqos_vals[] = {
{ MQTT_QOS_ATMOST_ONCE0,       "At most once delivery (Fire and Forget)" },
{ MQTT_QOS_ATLEAST_ONCE1,      "At least once delivery (Acknowledged deliver)" },
{ MQTT_QOS_EXACTLY_ONCE2,      "Exactly once delivery (Assured Delivery)" },
{ MQTT_QOS_RESERVED3,          "Reserved" },
{ MQTT_SUBACK_FAILURE128,        "Failure" },
{ 0,                          NULL((void*)0) }
153};

155#define MQTT_CON_ACCEPTED0                   0
156#define MQTT_CON_REFUSED_VERSION_MISMATCH1   1
157#define MQTT_CON_REFUSED_ID_REJECTED2        2
158#define MQTT_CON_REFUSED_SERVER_UNAVAILABLE3 3
159#define MQTT_CON_REFUSED_BAD_USER_PASSWD4    4
160#define MQTT_CON_REFUSED_UNAUTHORIZED5       5

162static const value_string mqtt_conack_vals[] = {
{ MQTT_CON_ACCEPTED0,                   "Connection Accepted" },
{ MQTT_CON_REFUSED_VERSION_MISMATCH1,   "Connection Refused: unacceptable protocol version" },
{ MQTT_CON_REFUSED_ID_REJECTED2,        "Connection Refused: identifier rejected" },
{ MQTT_CON_REFUSED_SERVER_UNAVAILABLE3, "Connection Refused: server unavailable" },
{ MQTT_CON_REFUSED_BAD_USER_PASSWD4,    "Connection Refused: bad user name or password" },
{ MQTT_CON_REFUSED_UNAUTHORIZED5,       "Connection Refused: not authorized" },
{ 0,                                   NULL((void*)0) }
170};

172#define MQTT_CONMASK_USER0x80        0x80
173#define MQTT_CONMASK_PASSWD0x40      0x40
174#define MQTT_CONMASK_RETAIN0x20      0x20
175#define MQTT_CONMASK_QOS0x18         0x18
176#define MQTT_CONMASK_WILLFLAG0x04    0x04
177#define MQTT_CONMASK_CLEANSESS0x02   0x02
178#define MQTT_CONMASK_RESERVED0x01    0x01

180#define MQTT_CONACKMASK_RESERVED0xFE 0xFE
181#define MQTT_CONACKMASK_SP0x01       0x01

183/* The protocol version is present in the CONNECT message. */
184typedef struct {
  uint8_t runtime_proto_version;
  wmem_map_t *topic_alias_map;
187} mqtt_conv_t;

189typedef struct _mqtt_message_decode_t {
unsigned   match_criteria;
char   *topic_pattern;
GRegex *topic_regex;
unsigned   msg_decoding;
char   *payload_proto_name;
dissector_handle_t payload_proto;
196} mqtt_message_decode_t;

198typedef struct _mqtt_properties_t {
const char   *content_type;
uint32_t      topic_alias;
201} mqtt_properties_t;

203#define MATCH_CRITERIA_EQUAL0        0
204#define MATCH_CRITERIA_CONTAINS1     1
205#define MATCH_CRITERIA_STARTS_WITH2  2
206#define MATCH_CRITERIA_ENDS_WITH3    3
207#define MATCH_CRITERIA_REGEX4        4

209static const value_string match_criteria[] = {
{ MATCH_CRITERIA_EQUAL0,       "Equal to" },
{ MATCH_CRITERIA_CONTAINS1,    "Contains" },
{ MATCH_CRITERIA_STARTS_WITH2, "Starts with" },
{ MATCH_CRITERIA_ENDS_WITH3,   "Ends with" },
{ MATCH_CRITERIA_REGEX4,       "Regular Expression" },
{ 0, NULL((void*)0) }
216};

218#define MSG_DECODING_NONE0        0
219#define MSG_DECODING_COMPRESSED1  1

221static const value_string msg_decoding[] = {
{ MSG_DECODING_NONE0,       "none" },
{ MSG_DECODING_COMPRESSED1, "compressed" },
{ 0, NULL((void*)0) }
225};

227#define PROP_PAYLOAD_FORMAT_INDICATOR0x01          0x01
228#define PROP_PUBLICATION_EXPIRY_INTERVAL0x02       0x02
229#define PROP_CONTENT_TYPE0x03                      0x03
230#define PROP_RESPONSE_TOPIC0x08                    0x08
231#define PROP_CORRELATION_DATA0x09                  0x09
232#define PROP_SUBSCRIPTION_IDENTIFIER0x0B           0x0B
233#define PROP_SESSION_EXPIRY_INTERVAL0x11           0x11
234#define PROP_ASSIGNED_CLIENT_IDENTIFIER0x12        0x12
235#define PROP_SERVER_KEEP_ALIVE0x13                 0x13
236#define PROP_AUTH_METHOD0x15                       0x15
237#define PROP_AUTH_DATA0x16                         0x16
238#define PROP_REQUEST_PROBLEM_INFORMATION0x17       0x17
239#define PROP_WILL_DELAY_INTERVAL0x18               0x18
240#define PROP_REQUEST_RESPONSE_INFORMATION0x19      0x19
241#define PROP_RESPONSE_INFORMATION0x1A              0x1A
242#define PROP_SERVER_REFERENCE0x1C                  0x1C
243#define PROP_REASON_STRING0x1F                     0x1F
244#define PROP_RECEIVE_MAXIMUM0x21                   0x21
245#define PROP_TOPIC_ALIAS_MAXIMUM0x22               0x22
246#define PROP_TOPIC_ALIAS0x23                       0x23
247#define PROP_MAXIMUM_QOS0x24                       0x24
248#define PROP_RETAIN_AVAILABLE0x25                  0x25
249#define PROP_USER_PROPERTY0x26                     0x26
250#define PROP_MAXIMUM_PACKET_SIZE0x27               0x27
251#define PROP_WILDCARD_SUBSCRIPTION_AVAILABLE0x28   0x28
252#define PROP_SUBSCRIPTION_IDENTIFIER_AVAILABLE0x29 0x29
253#define PROP_SHARED_SUBSCRIPTION_AVAILABLE0x2A     0x2A

255static const value_string mqtt_property_vals[] = {
{ PROP_PAYLOAD_FORMAT_INDICATOR0x01,          "Payload Format Indicator" },
{ PROP_PUBLICATION_EXPIRY_INTERVAL0x02,       "Publication Expiry Interval" },
{ PROP_CONTENT_TYPE0x03,                      "Content Type" },
{ PROP_RESPONSE_TOPIC0x08,                    "Response Topic" },
{ PROP_CORRELATION_DATA0x09,                  "Correlation Data" },
{ PROP_SUBSCRIPTION_IDENTIFIER0x0B,           "Subscription Identifier" },
{ PROP_SESSION_EXPIRY_INTERVAL0x11,           "Session Expiry Interval" },
{ PROP_ASSIGNED_CLIENT_IDENTIFIER0x12,        "Assigned Client Identifier" },
{ PROP_SERVER_KEEP_ALIVE0x13,                 "Server Keep Alive" },
{ PROP_AUTH_METHOD0x15,                       "Authentication Method" },
{ PROP_AUTH_DATA0x16,                         "Authentication Data" },
{ PROP_REQUEST_PROBLEM_INFORMATION0x17,       "Request Problem Information" },
{ PROP_WILL_DELAY_INTERVAL0x18,               "Will Delay Interval" },
{ PROP_REQUEST_RESPONSE_INFORMATION0x19,      "Request Response Information" },
{ PROP_RESPONSE_INFORMATION0x1A,              "Response Information" },
{ PROP_SERVER_REFERENCE0x1C,                  "Server Reference" },
{ PROP_REASON_STRING0x1F,                     "Reason String" },
{ PROP_RECEIVE_MAXIMUM0x21,                   "Receive Maximum" },
{ PROP_TOPIC_ALIAS_MAXIMUM0x22,               "Topic Alias Maximum" },
{ PROP_TOPIC_ALIAS0x23,                       "Topic Alias" },
{ PROP_MAXIMUM_QOS0x24,                       "Maximum QoS" },
{ PROP_RETAIN_AVAILABLE0x25,                  "Retain Available" },
{ PROP_USER_PROPERTY0x26,                     "User Property" },
{ PROP_MAXIMUM_PACKET_SIZE0x27,               "Maximum Packet Size" },
{ PROP_WILDCARD_SUBSCRIPTION_AVAILABLE0x28,   "Wildcard Subscription Available" },
{ PROP_SUBSCRIPTION_IDENTIFIER_AVAILABLE0x29, "Subscription Identifier Available" },
{ PROP_SHARED_SUBSCRIPTION_AVAILABLE0x2A,     "Shared Subscription Available" },
{ 0, NULL((void*)0) }
284};

286/* MQTT v5.0 Subscription Options, Retain Handling option */
287#define SUBSCRIPTION_RETAIN_SEND0x00            0x00
288#define SUBSCRIPTION_RETAIN_SEND_DONT_EXIST0x01 0x01
289#define SUBSCRIPTION_RETAIN_DONT_SEND0x02       0x02
290#define SUBSCRIPTION_RETAIN_RESERVED0x03        0x03

292static const value_string mqtt_subscription_retain_handling[] = {
{ SUBSCRIPTION_RETAIN_SEND0x00,            "Send msgs at subscription time" },
{ SUBSCRIPTION_RETAIN_SEND_DONT_EXIST0x01, "Send msgs if subscription does not exist" },
{ SUBSCRIPTION_RETAIN_DONT_SEND0x02,       "Do not send msgs at subscription time" },
{ SUBSCRIPTION_RETAIN_RESERVED0x03,        "Reserved" },
{ 0, NULL((void*)0) }
298};

300/* MQTT v5.0 Reason Codes */
301#define RC_SUCCESS0x00                                0x00
302#define RC_NORMAL_DISCONNECTION0x00                   0x00
303#define RC_GRANTED_QOS00x00                           0x00
304#define RC_GRANTED_QOS10x01                           0x01
305#define RC_GRANTED_QOS20x02                           0x02
306#define RC_DISCONNECT_WILL0x04                        0x04
307#define RC_NO_MATCHING_SUBSCRIBERS0x10                0x10
308#define RC_NO_SUBSCRIPTION_EXISTED0x11                0x11
309#define RC_CONTINUE_AUTHENTICATION0x18                0x18
310#define RC_RE_AUTHENTICATE0x19                        0x19
311#define RC_UNSPECIFIED_ERROR0x80                      0x80
312#define RC_MALFORMED_PACKET0x81                       0x81
313#define RC_PROTOCOL_ERROR0x82                         0x82
314#define RC_IMPLEMENTATION_SPECIFIC_ERROR0x83          0x83
315#define RC_UNSUPPORTED_PROTOCOL_VERSION0x84           0x84
316#define RC_CLIENT_IDENTIFIER_NOT_VALID0x85            0x85
317#define RC_BAD_USER_NAME_OR_PASSWORD0x86              0x86
318#define RC_NOT_AUTHORIZED0x87                         0x87
319#define RC_SERVER_UNAVAILABLE0x88                     0x88
320#define RC_SERVER_BUSY0x89                            0x89
321#define RC_BANNED0x8A                                 0x8A
322#define RC_SERVER_SHUTTING_DOWN0x8B                   0x8B
323#define RC_BAD_AUTHENTICATION_METHOD0x8C              0x8C
324#define RC_KEEP_ALIVE_TIMEOUT0x8D                     0x8D
325#define RC_SESSION_TAKEN_OVER0x8E                     0x8E
326#define RC_TOPIC_FILTER_INVALID0x8F                   0x8F
327#define RC_TOPIC_NAME_INVALID0x90                     0x90
328#define RC_PACKET_IDENTIFIER_IN_USE0x91               0x91
329#define RC_PACKET_IDENTIFIER_NOT_FOUND0x92            0x92
330#define RC_RECEIVE_MAXIMUM_EXCEEDED0x93               0x93
331#define RC_TOPIC_ALIAS_INVALID0x94                    0x94
332#define RC_PACKET_TOO_LARGE0x95                       0x95
333#define RC_MESSAGE_RATE_TOO_HIGH0x96                  0x96
334#define RC_QUOTA_EXCEEDED0x97                         0x97
335#define RC_ADMINISTRATIVE_ACTION0x98                  0x98
336#define RC_PAYLOAD_FORMAT_INVALID0x99                 0x99
337#define RC_RETAIN_NOT_SUPPORTED0x9A                   0x9A
338#define RC_QOS_NOT_SUPPORTED0x9B                      0x9B
339#define RC_USE_ANOTHER_SERVER0x9C                     0x9C
340#define RC_SERVER_MOVED0x9D                           0x9D
341#define RC_SHARED_SUBSCRIPTION_NOT_SUPPORTED0x9E      0x9E
342#define RC_CONNECTION_RATE_EXCEEDED0x9F               0x9F
343#define RC_MAXIMUM_CONNECT_TIME0xA0                   0xA0
344#define RC_SUBSCRIPTION_IDENTIFIERS_NOT_SUPPORTED0xA1 0xA1
345#define RC_WILDCARD_SUBSCRIPTION_NOT_SUPPORTED0xA2    0xA2

347#define RC_SUCCESS_STR"Success"                                "Success"
348#define RC_NORMAL_DISCONNECTION_STR"Normal disconnection"                   "Normal disconnection"
349#define RC_GRANTED_QOS0_STR"Granted QoS 0"                           "Granted QoS 0"
350#define RC_GRANTED_QOS1_STR"Granted QoS 1"                           "Granted QoS 1"
351#define RC_GRANTED_QOS2_STR"Granted QoS 2"                           "Granted QoS 2"
352#define RC_DISCONNECT_WILL_STR"Disconnect with Will Message"                        "Disconnect with Will Message"
353#define RC_NO_MATCHING_SUBSCRIBERS_STR"No matching subscribers"                "No matching subscribers"
354#define RC_NO_SUBSCRIPTION_EXISTED_STR"No subscription existed"                "No subscription existed"
355#define RC_CONTINUE_AUTHENTICATION_STR"Continue authentication"                "Continue authentication"
356#define RC_RE_AUTHENTICATE_STR"Re-authenticate"                        "Re-authenticate"
357#define RC_UNSPECIFIED_ERROR_STR"Unspecified error"                      "Unspecified error"
358#define RC_MALFORMED_PACKET_STR"Malformed Packet"                       "Malformed Packet"
359#define RC_PROTOCOL_ERROR_STR"Protocol Error"                         "Protocol Error"
360#define RC_IMPLEMENTATION_SPECIFIC_ERROR_STR"Implementation specific error"          "Implementation specific error"
361#define RC_UNSUPPORTED_PROTOCOL_VERSION_STR"Unsupported Protocol Version"           "Unsupported Protocol Version"
362#define RC_CLIENT_IDENTIFIER_NOT_VALID_STR"Client Identifier not valid"            "Client Identifier not valid"
363#define RC_BAD_USER_NAME_OR_PASSWORD_STR"Bad User Name or Password"              "Bad User Name or Password"
364#define RC_NOT_AUTHORIZED_STR"Not authorized"                         "Not authorized"
365#define RC_SERVER_UNAVAILABLE_STR"Server unavailable"                     "Server unavailable"
366#define RC_SERVER_BUSY_STR"Server busy"                            "Server busy"
367#define RC_BANNED_STR"Banned"                                 "Banned"
368#define RC_SERVER_SHUTTING_DOWN_STR"Server shutting down"                   "Server shutting down"
369#define RC_BAD_AUTHENTICATION_METHOD_STR"Bad authentication method"              "Bad authentication method"
370#define RC_KEEP_ALIVE_TIMEOUT_STR"Keep Alive timeout"                     "Keep Alive timeout"
371#define RC_SESSION_TAKEN_OVER_STR"Session taken over"                     "Session taken over"
372#define RC_TOPIC_FILTER_INVALID_STR"Topic Filter invalid"                   "Topic Filter invalid"
373#define RC_TOPIC_NAME_INVALID_STR"Topic Name invalid"                     "Topic Name invalid"
374#define RC_PACKET_IDENTIFIER_IN_USE_STR"Packet Identifier in use"               "Packet Identifier in use"
375#define RC_PACKET_IDENTIFIER_NOT_FOUND_STR"Packet Identifier not found"            "Packet Identifier not found"
376#define RC_RECEIVE_MAXIMUM_EXCEEDED_STR"Receive Maximum exceeded"               "Receive Maximum exceeded"
377#define RC_TOPIC_ALIAS_INVALID_STR"Topic Alias invalid"                    "Topic Alias invalid"
378#define RC_PACKET_TOO_LARGE_STR"Packet too large"                       "Packet too large"
379#define RC_MESSAGE_RATE_TOO_HIGH_STR"Message rate too high"                  "Message rate too high"
380#define RC_QUOTA_EXCEEDED_STR"Quota exceeded"                         "Quota exceeded"
381#define RC_ADMINISTRATIVE_ACTION_STR"Administrative action"                  "Administrative action"
382#define RC_PAYLOAD_FORMAT_INVALID_STR"Payload format invalid"                 "Payload format invalid"
383#define RC_RETAIN_NOT_SUPPORTED_STR"Retain not supported"                   "Retain not supported"
384#define RC_QOS_NOT_SUPPORTED_STR"QoS not supported"                      "QoS not supported"
385#define RC_USE_ANOTHER_SERVER_STR"Use another server"                     "Use another server"
386#define RC_SERVER_MOVED_STR"Server moved"                           "Server moved"
387#define RC_SHARED_SUBSCRIPTION_NOT_SUPPORTED_STR"Shared Subscription not supported"      "Shared Subscription not supported"
388#define RC_CONNECTION_RATE_EXCEEDED_STR"Connection rate exceeded"               "Connection rate exceeded"
389#define RC_MAXIMUM_CONNECT_TIME_STR"Maximum connect time"                   "Maximum connect time"
390#define RC_SUBSCRIPTION_IDENTIFIERS_NOT_SUPPORTED_STR"Subscription Identifiers not supported" "Subscription Identifiers not supported"
391#define RC_WILDCARD_SUBSCRIPTION_NOT_SUPPORTED_STR"Wildcard Subscription not supported"    "Wildcard Subscription not supported"

393static const value_string mqtt_reason_code_connack_vals[] = {
{ RC_SUCCESS0x00,                                RC_SUCCESS_STR"Success" },
{ RC_UNSPECIFIED_ERROR0x80,                      RC_UNSPECIFIED_ERROR_STR"Unspecified error" },
{ RC_MALFORMED_PACKET0x81,                       RC_MALFORMED_PACKET_STR"Malformed Packet" },
{ RC_PROTOCOL_ERROR0x82,                         RC_PROTOCOL_ERROR_STR"Protocol Error" },
{ RC_IMPLEMENTATION_SPECIFIC_ERROR0x83,          RC_IMPLEMENTATION_SPECIFIC_ERROR_STR"Implementation specific error" },
{ RC_UNSUPPORTED_PROTOCOL_VERSION0x84,           RC_UNSUPPORTED_PROTOCOL_VERSION_STR"Unsupported Protocol Version" },
{ RC_CLIENT_IDENTIFIER_NOT_VALID0x85,            RC_CLIENT_IDENTIFIER_NOT_VALID_STR"Client Identifier not valid" },
{ RC_BAD_USER_NAME_OR_PASSWORD0x86,              RC_BAD_USER_NAME_OR_PASSWORD_STR"Bad User Name or Password" },
{ RC_NOT_AUTHORIZED0x87,                         RC_NOT_AUTHORIZED_STR"Not authorized" },
{ RC_SERVER_UNAVAILABLE0x88,                     RC_SERVER_UNAVAILABLE_STR"Server unavailable" },
{ RC_SERVER_BUSY0x89,                            RC_SERVER_BUSY_STR"Server busy" },
{ RC_BANNED0x8A,                                 RC_BANNED_STR"Banned" },
{ RC_BAD_AUTHENTICATION_METHOD0x8C,              RC_BAD_AUTHENTICATION_METHOD_STR"Bad authentication method" },
{ RC_TOPIC_NAME_INVALID0x90,                     RC_TOPIC_NAME_INVALID_STR"Topic Name invalid" },
{ RC_PACKET_TOO_LARGE0x95,                       RC_PACKET_TOO_LARGE_STR"Packet too large" },
{ RC_QUOTA_EXCEEDED0x97,                         RC_QUOTA_EXCEEDED_STR"Quota exceeded" },
{ RC_RETAIN_NOT_SUPPORTED0x9A,                   RC_RETAIN_NOT_SUPPORTED_STR"Retain not supported" },
{ RC_QOS_NOT_SUPPORTED0x9B,                      RC_QOS_NOT_SUPPORTED_STR"QoS not supported" },
{ RC_USE_ANOTHER_SERVER0x9C,                     RC_USE_ANOTHER_SERVER_STR"Use another server" },
{ RC_SERVER_MOVED0x9D,                           RC_SERVER_MOVED_STR"Server moved" },
{ RC_CONNECTION_RATE_EXCEEDED0x9F,               RC_CONNECTION_RATE_EXCEEDED_STR"Connection rate exceeded" },
{ 0, NULL((void*)0) }
416};

418static const value_string mqtt_reason_code_puback_vals[] = {
{ RC_SUCCESS0x00,                                RC_SUCCESS_STR"Success" },
{ RC_NO_MATCHING_SUBSCRIBERS0x10,                RC_NO_MATCHING_SUBSCRIBERS_STR"No matching subscribers" },
{ RC_UNSPECIFIED_ERROR0x80,                      RC_UNSPECIFIED_ERROR_STR"Unspecified error" },
{ RC_IMPLEMENTATION_SPECIFIC_ERROR0x83,          RC_IMPLEMENTATION_SPECIFIC_ERROR_STR"Implementation specific error" },
{ RC_NOT_AUTHORIZED0x87,                         RC_NOT_AUTHORIZED_STR"Not authorized" },
{ RC_TOPIC_NAME_INVALID0x90,                     RC_TOPIC_NAME_INVALID_STR"Topic Name invalid" },
{ RC_PACKET_IDENTIFIER_IN_USE0x91,               RC_PACKET_IDENTIFIER_IN_USE_STR"Packet Identifier in use" },
{ RC_QUOTA_EXCEEDED0x97,                         RC_QUOTA_EXCEEDED_STR"Quota exceeded" },
{ RC_PAYLOAD_FORMAT_INVALID0x99,                 RC_PAYLOAD_FORMAT_INVALID_STR"Payload format invalid" },
{ 0, NULL((void*)0) }
429};

431static const value_string mqtt_reason_code_pubrel_vals[] = {
{ RC_SUCCESS0x00,                                RC_SUCCESS_STR"Success" },
{ RC_PACKET_IDENTIFIER_NOT_FOUND0x92,            RC_PACKET_IDENTIFIER_NOT_FOUND_STR"Packet Identifier not found" },
{ 0, NULL((void*)0) }
435};

437static const value_string mqtt_reason_code_suback_vals[] = {
{ RC_GRANTED_QOS00x00,                           RC_GRANTED_QOS0_STR"Granted QoS 0" },
{ RC_GRANTED_QOS10x01,                           RC_GRANTED_QOS1_STR"Granted QoS 1" },
{ RC_GRANTED_QOS20x02,                           RC_GRANTED_QOS2_STR"Granted QoS 2" },
{ RC_UNSPECIFIED_ERROR0x80,                      RC_UNSPECIFIED_ERROR_STR"Unspecified error" },
{ RC_IMPLEMENTATION_SPECIFIC_ERROR0x83,          RC_IMPLEMENTATION_SPECIFIC_ERROR_STR"Implementation specific error" },
{ RC_NOT_AUTHORIZED0x87,                         RC_NOT_AUTHORIZED_STR"Not authorized" },
{ RC_TOPIC_FILTER_INVALID0x8F,                   RC_TOPIC_FILTER_INVALID_STR"Topic Filter invalid" },
{ RC_PACKET_IDENTIFIER_IN_USE0x91,               RC_PACKET_IDENTIFIER_IN_USE_STR"Packet Identifier in use" },
{ RC_QUOTA_EXCEEDED0x97,                         RC_QUOTA_EXCEEDED_STR"Quota exceeded" },
{ RC_SHARED_SUBSCRIPTION_NOT_SUPPORTED0x9E,      RC_SHARED_SUBSCRIPTION_NOT_SUPPORTED_STR"Shared Subscription not supported" },
{ RC_SUBSCRIPTION_IDENTIFIERS_NOT_SUPPORTED0xA1, RC_SUBSCRIPTION_IDENTIFIERS_NOT_SUPPORTED_STR"Subscription Identifiers not supported" },
{ RC_WILDCARD_SUBSCRIPTION_NOT_SUPPORTED0xA2,    RC_WILDCARD_SUBSCRIPTION_NOT_SUPPORTED_STR"Wildcard Subscription not supported" },
{ 0, NULL((void*)0) }
451};

453static const value_string mqtt_reason_code_unsuback_vals[] = {
{ RC_SUCCESS0x00,                                RC_SUCCESS_STR"Success" },
{ RC_NO_SUBSCRIPTION_EXISTED0x11,                RC_NO_SUBSCRIPTION_EXISTED_STR"No subscription existed" },
{ RC_IMPLEMENTATION_SPECIFIC_ERROR0x83,          RC_IMPLEMENTATION_SPECIFIC_ERROR_STR"Implementation specific error" },
{ RC_NOT_AUTHORIZED0x87,                         RC_NOT_AUTHORIZED_STR"Not authorized" },
{ RC_TOPIC_FILTER_INVALID0x8F,                   RC_TOPIC_FILTER_INVALID_STR"Topic Filter invalid" },
{ RC_PACKET_IDENTIFIER_IN_USE0x91,               RC_PACKET_IDENTIFIER_IN_USE_STR"Packet Identifier in use" },
{ 0, NULL((void*)0) }
461};

463static const value_string mqtt_reason_code_disconnect_vals[] = {
{ RC_NORMAL_DISCONNECTION0x00,                   RC_NORMAL_DISCONNECTION_STR"Normal disconnection" },
{ RC_DISCONNECT_WILL0x04,                        RC_DISCONNECT_WILL_STR"Disconnect with Will Message" },
{ RC_UNSPECIFIED_ERROR0x80,                      RC_UNSPECIFIED_ERROR_STR"Unspecified error" },
{ RC_MALFORMED_PACKET0x81,                       RC_MALFORMED_PACKET_STR"Malformed Packet" },
{ RC_PROTOCOL_ERROR0x82,                         RC_PROTOCOL_ERROR_STR"Protocol Error" },
{ RC_IMPLEMENTATION_SPECIFIC_ERROR0x83,          RC_IMPLEMENTATION_SPECIFIC_ERROR_STR"Implementation specific error" },
{ RC_NOT_AUTHORIZED0x87,                         RC_NOT_AUTHORIZED_STR"Not authorized" },
{ RC_SERVER_BUSY0x89,                            RC_SERVER_BUSY_STR"Server busy" },
{ RC_SERVER_SHUTTING_DOWN0x8B,                   RC_SERVER_SHUTTING_DOWN_STR"Server shutting down" },
/* Bad authentication method: check Table 2.6 and Table 3.13 */
{ RC_BAD_AUTHENTICATION_METHOD0x8C,              RC_BAD_AUTHENTICATION_METHOD_STR"Bad authentication method" },
{ RC_KEEP_ALIVE_TIMEOUT0x8D,                     RC_KEEP_ALIVE_TIMEOUT_STR"Keep Alive timeout" },
{ RC_SESSION_TAKEN_OVER0x8E,                     RC_SESSION_TAKEN_OVER_STR"Session taken over" },
{ RC_TOPIC_FILTER_INVALID0x8F,                   RC_TOPIC_FILTER_INVALID_STR"Topic Filter invalid" },
{ RC_TOPIC_NAME_INVALID0x90,                     RC_TOPIC_NAME_INVALID_STR"Topic Name invalid" },
{ RC_RECEIVE_MAXIMUM_EXCEEDED0x93,               RC_RECEIVE_MAXIMUM_EXCEEDED_STR"Receive Maximum exceeded" },
{ RC_TOPIC_ALIAS_INVALID0x94,                    RC_TOPIC_ALIAS_INVALID_STR"Topic Alias invalid" },
{ RC_PACKET_TOO_LARGE0x95,                       RC_PACKET_TOO_LARGE_STR"Packet too large" },
{ RC_MESSAGE_RATE_TOO_HIGH0x96,                  RC_MESSAGE_RATE_TOO_HIGH_STR"Message rate too high" },
{ RC_QUOTA_EXCEEDED0x97,                         RC_QUOTA_EXCEEDED_STR"Quota exceeded" },
{ RC_ADMINISTRATIVE_ACTION0x98,                  RC_ADMINISTRATIVE_ACTION_STR"Administrative action" },
{ RC_PAYLOAD_FORMAT_INVALID0x99,                 RC_PAYLOAD_FORMAT_INVALID_STR"Payload format invalid" },
{ RC_RETAIN_NOT_SUPPORTED0x9A,                   RC_RETAIN_NOT_SUPPORTED_STR"Retain not supported" },
{ RC_QOS_NOT_SUPPORTED0x9B,                      RC_QOS_NOT_SUPPORTED_STR"QoS not supported" },
{ RC_USE_ANOTHER_SERVER0x9C,                     RC_USE_ANOTHER_SERVER_STR"Use another server" },
{ RC_SERVER_MOVED0x9D,                           RC_SERVER_MOVED_STR"Server moved" },
{ RC_SHARED_SUBSCRIPTION_NOT_SUPPORTED0x9E,      RC_SHARED_SUBSCRIPTION_NOT_SUPPORTED_STR"Shared Subscription not supported" },
{ RC_CONNECTION_RATE_EXCEEDED0x9F,               RC_CONNECTION_RATE_EXCEEDED_STR"Connection rate exceeded" },
{ RC_MAXIMUM_CONNECT_TIME0xA0,                   RC_MAXIMUM_CONNECT_TIME_STR"Maximum connect time" },
{ RC_SUBSCRIPTION_IDENTIFIERS_NOT_SUPPORTED0xA1, RC_SUBSCRIPTION_IDENTIFIERS_NOT_SUPPORTED_STR"Subscription Identifiers not supported" },
{ RC_WILDCARD_SUBSCRIPTION_NOT_SUPPORTED0xA2,    RC_WILDCARD_SUBSCRIPTION_NOT_SUPPORTED_STR"Wildcard Subscription not supported" },
{ 0, NULL((void*)0) }
496};

498static const value_string mqtt_reason_code_auth_vals[] = {
{ RC_SUCCESS0x00,                                RC_SUCCESS_STR"Success" },
{ RC_CONTINUE_AUTHENTICATION0x18,                RC_CONTINUE_AUTHENTICATION_STR"Continue authentication" },
{ RC_RE_AUTHENTICATE0x19,                        RC_RE_AUTHENTICATE_STR"Re-authenticate" },
{ 0, NULL((void*)0) }
503};

505static mqtt_message_decode_t *mqtt_message_decodes;
506static unsigned num_mqtt_message_decodes;
507static int default_protocol_version;

509static dissector_handle_t mqtt_handle;

511static heur_dissector_list_t mqtt_topic_subdissector;

513/* Initialize the protocol and registered fields */
514typedef struct {
uint8_t version;
char *topic;
517} mqtt_pdu_data_t;

519static int proto_mqtt;

521/* Message */
522static int hf_mqtt_hdrflags;
523static int hf_mqtt_msg_len;
524static int hf_mqtt_msg_type;
525static int hf_mqtt_reserved;
526static int hf_mqtt_dup_flag;
527static int hf_mqtt_qos_level;
528static int hf_mqtt_retain;
529static int hf_mqtt_retain_reserved;
530static int hf_mqtt_conack_reserved;
531static int hf_mqtt_conack_flags;
532static int hf_mqtt_conackflag_reserved;
533static int hf_mqtt_conackflag_sp;
534static int hf_mqtt_conack_code;
535static int hf_mqtt_msgid;
536static int hf_mqtt_sub_qos;
537static int hf_mqtt_suback_qos;
538static int hf_mqtt_topic_len;
539static int hf_mqtt_topic;
540static int hf_mqtt_will_topic_len;
541static int hf_mqtt_will_topic;
542static int hf_mqtt_will_msg_len;
543static int hf_mqtt_will_msg;
544static int hf_mqtt_will_msg_text;
545static int hf_mqtt_username_len;
546static int hf_mqtt_username;
547static int hf_mqtt_passwd_len;
548static int hf_mqtt_passwd;
549static int hf_mqtt_pubmsg;
550static int hf_mqtt_pubmsg_text;
551static int hf_mqtt_pubmsg_decoded;
552static int hf_mqtt_proto_len;
553static int hf_mqtt_proto_name;
554static int hf_mqtt_client_id_len;
555static int hf_mqtt_client_id;
556static int hf_mqtt_proto_ver;
557static int hf_mqtt_conflags;
558static int hf_mqtt_conflag_user;
559static int hf_mqtt_conflag_passwd;
560static int hf_mqtt_conflag_will_retain;
561static int hf_mqtt_conflag_will_qos;
562static int hf_mqtt_conflag_will_flag;
563static int hf_mqtt_conflag_clean_sess;
564static int hf_mqtt_conflag_reserved;
565static int hf_mqtt_keep_alive;
566static int hf_mqtt_subscription_options;

568/* MQTT v5.0 Reason Codes */
569static int hf_mqtt_reason_code_connack;
570static int hf_mqtt_reason_code_puback;
571static int hf_mqtt_reason_code_pubrec;
572static int hf_mqtt_reason_code_pubrel;
573static int hf_mqtt_reason_code_pubcomp;
574static int hf_mqtt_reason_code_suback;
575static int hf_mqtt_reason_code_unsuback;
576static int hf_mqtt_reason_code_disconnect;
577static int hf_mqtt_reason_code_auth;

579/* MQTT v5.0 Subscribe Options */
580static int hf_mqtt_subscription_qos;
581static int hf_mqtt_subscription_nl;
582static int hf_mqtt_subscription_rap;
583static int hf_mqtt_subscription_retain;
584static int hf_mqtt_subscription_reserved;

586/* MQTT v5.0 Properties */
587static int hf_mqtt_property_len;
588static int hf_mqtt_property;
589static int hf_mqtt_will_property;
590static int hf_mqtt_property_id;
591static int hf_mqtt_prop_num;
592static int hf_mqtt_prop_content_type;
593static int hf_mqtt_prop_max_qos;
594static int hf_mqtt_prop_topic_alias;
595static int hf_mqtt_prop_unknown;
596static int hf_mqtt_prop_string_len;
597static int hf_mqtt_prop_string;
598static int hf_mqtt_prop_key_len;
599static int hf_mqtt_prop_key;
600static int hf_mqtt_prop_value_len;
601static int hf_mqtt_prop_value;

603/* Initialize the subtree pointers */
604static int ett_mqtt_hdr;
605static int ett_mqtt_msg;
606static int ett_mqtt_hdr_flags;
607static int ett_mqtt_con_flags;
608static int ett_mqtt_conack_flags;
609static int ett_mqtt_property;
610static int ett_mqtt_subscription_flags;

612/* Initialize the expert fields */
613static expert_field ei_illegal_length;
614static expert_field ei_unknown_version;
615static expert_field ei_unknown_topic_alias;

617/* Reassemble SMPP TCP segments */
618static bool_Bool reassemble_mqtt_over_tcp = true1;

620/* Show Publish Message as text */
621static bool_Bool show_msg_as_text;

623static unsigned get_mqtt_pdu_len(packet_info *pinfo _U___attribute__((unused)), tvbuff_t *tvb,
                            int offset, void *data _U___attribute__((unused)))
625{
uint64_t msg_len;
unsigned len_offset;

len_offset = tvb_get_varint(tvb, (offset + MQTT_HDR_SIZE_BEFORE_LEN1), FT_VARINT_MAX_LEN10, &msg_len, ENC_VARINT_PROTOBUF0x00000002);

/* Explicitly downcast the value, because the length can never be more than 4 bytes */
return (unsigned)(msg_len + len_offset + MQTT_HDR_SIZE_BEFORE_LEN1);
633}

635static void *mqtt_message_decode_copy_cb(void *dest, const void *orig, size_t len _U___attribute__((unused)))
636{
const mqtt_message_decode_t *o = (const mqtt_message_decode_t *)orig;
mqtt_message_decode_t *d = (mqtt_message_decode_t *)dest;

d->match_criteria = o->match_criteria;
d->topic_pattern = g_strdup(o->topic_pattern)g_strdup_inline (o->topic_pattern);
d->msg_decoding = o->msg_decoding;
d->payload_proto_name = g_strdup(o->payload_proto_name)g_strdup_inline (o->payload_proto_name);
d->payload_proto = o->payload_proto;

return d;
647}

649static bool_Bool mqtt_message_decode_update_cb(void *record, char **error)
650{
mqtt_message_decode_t *u = (mqtt_message_decode_t *)record;

if (u->topic_pattern == NULL((void*)0) || strlen(u->topic_pattern) == 0)
{
  *error = g_strdup("Missing topic pattern")g_strdup_inline ("Missing topic pattern");
  return false0;
}

if (u->payload_proto_name == NULL((void*)0) || strlen(u->payload_proto_name) == 0)
{
  *error = g_strdup("Missing payload protocol")g_strdup_inline ("Missing payload protocol");
  return false0;
}

if (u->match_criteria == MATCH_CRITERIA_REGEX4)
{
  u->topic_regex = g_regex_new(u->topic_pattern, (GRegexCompileFlags) G_REGEX_OPTIMIZE, (GRegexMatchFlags) 0, NULL((void*)0));
  if (!u->topic_regex)
  {
    *error = ws_strdup_printf("Invalid regex: %s", u->topic_pattern)wmem_strdup_printf(((void*)0), "Invalid regex: %s", u->topic_pattern
);
    return false0;
  }
}

return true1;
676}

678static void mqtt_message_decode_free_cb(void *record)
679{
mqtt_message_decode_t *u = (mqtt_message_decode_t *)record;

g_free(u->topic_pattern)(__builtin_object_size ((u->topic_pattern), 0) != ((size_t
) - 1)) ? g_free_sized (u->topic_pattern, __builtin_object_size
 ((u->topic_pattern), 0)) : (g_free) (u->topic_pattern);
if (u->topic_regex)
{
  g_regex_unref(u->topic_regex);
}
g_free(u->payload_proto_name)(__builtin_object_size ((u->payload_proto_name), 0) != ((size_t
) - 1)) ? g_free_sized (u->payload_proto_name, __builtin_object_size
 ((u->payload_proto_name), 0)) : (g_free) (u->payload_proto_name
);
688}

690UAT_VS_DEF(message_decode, match_criteria, mqtt_message_decode_t, unsigned, MATCH_CRITERIA_EQUAL, "Equal to")static void message_decode_match_criteria_set_cb(void* rec, const
 char* buf, unsigned len, const void* vs, const void* u2 __attribute__
((unused))) { unsigned i; char* str = g_strndup(buf,len); const
 char* cstr; ((mqtt_message_decode_t*)rec)->match_criteria
 = 0; for(i=0; ( cstr = ((const value_string*)vs)[i].strptr )
 ;i++) { if ((strcmp ((const char *) (cstr), (const char *) (
str)) == 0)) { ((mqtt_message_decode_t*)rec)->match_criteria
 = (unsigned)((const value_string*)vs)[i].value; (__builtin_object_size
 ((str), 0) != ((size_t) - 1)) ? g_free_sized (str, __builtin_object_size
 ((str), 0)) : (g_free) (str); return; } } (__builtin_object_size
 ((str), 0) != ((size_t) - 1)) ? g_free_sized (str, __builtin_object_size
 ((str), 0)) : (g_free) (str); } static void message_decode_match_criteria_tostr_cb
(void* rec, char** out_ptr, unsigned* out_len, const void* vs
, const void* u2 __attribute__((unused))) { unsigned i; for(i
=0;((const value_string*)vs)[i].strptr;i++) { if ( ((const value_string
*)vs)[i].value == ((mqtt_message_decode_t*)rec)->match_criteria
 ) { *out_ptr = g_strdup_inline (((const value_string*)vs)[i]
.strptr); *out_len = (unsigned)strlen(*out_ptr); return; } } *
out_ptr = g_strdup_inline ("Equal to"); *out_len = (unsigned)
strlen("Equal to"); }
691UAT_CSTRING_CB_DEF(message_decode, topic_pattern, mqtt_message_decode_t)static void message_decode_topic_pattern_set_cb(void* rec, const
 char* buf, unsigned len, const void* u1 __attribute__((unused
)), const void* u2 __attribute__((unused))) { char* new_buf =
 g_strndup(buf,len); (__builtin_object_size (((((mqtt_message_decode_t
*)rec)->topic_pattern)), 0) != ((size_t) - 1)) ? g_free_sized
 ((((mqtt_message_decode_t*)rec)->topic_pattern), __builtin_object_size
 (((((mqtt_message_decode_t*)rec)->topic_pattern)), 0)) : (
g_free) ((((mqtt_message_decode_t*)rec)->topic_pattern)); (
((mqtt_message_decode_t*)rec)->topic_pattern) = new_buf; }
 static void message_decode_topic_pattern_tostr_cb(void* rec,
 char** out_ptr, unsigned* out_len, const void* u1 __attribute__
((unused)), const void* u2 __attribute__((unused))) { if (((mqtt_message_decode_t
*)rec)->topic_pattern ) { *out_ptr = g_strdup_inline ((((mqtt_message_decode_t
*)rec)->topic_pattern)); *out_len = (unsigned)strlen((((mqtt_message_decode_t
*)rec)->topic_pattern)); } else { *out_ptr = g_strdup_inline
 (""); *out_len = 0; } }
692UAT_VS_DEF(message_decode, msg_decoding, mqtt_message_decode_t, unsigned, MSG_DECODING_NONE, "none")static void message_decode_msg_decoding_set_cb(void* rec, const
 char* buf, unsigned len, const void* vs, const void* u2 __attribute__
((unused))) { unsigned i; char* str = g_strndup(buf,len); const
 char* cstr; ((mqtt_message_decode_t*)rec)->msg_decoding =
 0; for(i=0; ( cstr = ((const value_string*)vs)[i].strptr ) ;
i++) { if ((strcmp ((const char *) (cstr), (const char *) (str
)) == 0)) { ((mqtt_message_decode_t*)rec)->msg_decoding = (
unsigned)((const value_string*)vs)[i].value; (__builtin_object_size
 ((str), 0) != ((size_t) - 1)) ? g_free_sized (str, __builtin_object_size
 ((str), 0)) : (g_free) (str); return; } } (__builtin_object_size
 ((str), 0) != ((size_t) - 1)) ? g_free_sized (str, __builtin_object_size
 ((str), 0)) : (g_free) (str); } static void message_decode_msg_decoding_tostr_cb
(void* rec, char** out_ptr, unsigned* out_len, const void* vs
, const void* u2 __attribute__((unused))) { unsigned i; for(i
=0;((const value_string*)vs)[i].strptr;i++) { if ( ((const value_string
*)vs)[i].value == ((mqtt_message_decode_t*)rec)->msg_decoding
 ) { *out_ptr = g_strdup_inline (((const value_string*)vs)[i]
.strptr); *out_len = (unsigned)strlen(*out_ptr); return; } } *
out_ptr = g_strdup_inline ("none"); *out_len = (unsigned)strlen
("none"); }
693UAT_DISSECTOR_DEF(message_decode, payload_proto, payload_proto, payload_proto_name, mqtt_message_decode_t)static void message_decode_payload_proto_set_cb(void* rec, const
 char* buf, unsigned len, const void* u1 __attribute__((unused
)), const void* u2 __attribute__((unused))) { if (len) { ((mqtt_message_decode_t
*)rec)->payload_proto_name = g_strndup(buf, len); g_strchomp
 (g_strchug (((mqtt_message_decode_t*)rec)->payload_proto_name
)); ((mqtt_message_decode_t*)rec)->payload_proto = find_dissector
(((mqtt_message_decode_t*)rec)->payload_proto_name); } else
 { ((mqtt_message_decode_t*)rec)->payload_proto = find_dissector
("data"); ((mqtt_message_decode_t*)rec)->payload_proto_name
 = ((void*)0); } } static void message_decode_payload_proto_tostr_cb
(void* rec, char** out_ptr, unsigned* out_len, const void* u1
 __attribute__((unused)), const void* u2 __attribute__((unused
))) { if ( ((mqtt_message_decode_t*)rec)->payload_proto_name
 ) { *out_ptr = g_strdup_inline ((((mqtt_message_decode_t*)rec
)->payload_proto_name)); *out_len = (unsigned)strlen(*out_ptr
); } else { *out_ptr = g_strdup_inline (""); *out_len = 0; } }

695static bool_Bool mqtt_user_decode_message(proto_tree *tree, proto_tree *mqtt_tree, packet_info *pinfo, const char *topic_str, tvbuff_t *msg_tvb)
696{
mqtt_message_decode_t *message_decode_entry = NULL((void*)0);
size_t topic_str_len = strlen(topic_str);
size_t topic_pattern_len;
bool_Bool match_found = false0;

if (topic_str_len == 0)
{
  /* No topic to match */
  return false0;
}

for (unsigned i = 0; i < num_mqtt_message_decodes && !match_found; i++)
{
  message_decode_entry = &mqtt_message_decodes[i];
  switch (message_decode_entry->match_criteria)
  {
    case MATCH_CRITERIA_EQUAL0:
      match_found = (strcmp(topic_str, message_decode_entry->topic_pattern) == 0);
      break;
    case MATCH_CRITERIA_CONTAINS1:
      match_found = (strstr(topic_str, message_decode_entry->topic_pattern) != NULL((void*)0));
      break;
    case MATCH_CRITERIA_STARTS_WITH2:
      topic_pattern_len = strlen(message_decode_entry->topic_pattern);
      match_found = ((topic_str_len >= topic_pattern_len) &&
                     (strncmp(topic_str, message_decode_entry->topic_pattern, topic_pattern_len) == 0));
      break;
    case MATCH_CRITERIA_ENDS_WITH3:
      topic_pattern_len = strlen(message_decode_entry->topic_pattern);
      match_found = ((topic_str_len >= topic_pattern_len) &&
                     (strcmp(topic_str + (topic_str_len - topic_pattern_len), message_decode_entry->topic_pattern) == 0));
      break;
    case MATCH_CRITERIA_REGEX4:
      if (message_decode_entry->topic_regex)
      {
        GMatchInfo *match_info = NULL((void*)0);
        /* DISSECTOR_ASSERT(g_utf8_validate(topic_str, -1, NULL)); */
        g_regex_match(message_decode_entry->topic_regex, topic_str, (GRegexMatchFlags) 0, &match_info);
        match_found = g_match_info_matches(match_info);
        g_match_info_free(match_info);
      }
      break;
    default:
      /* Unknown match criteria */
      break;
  }
}

if (match_found)
{
  if (message_decode_entry->msg_decoding == MSG_DECODING_COMPRESSED1)
  {
    msg_tvb = tvb_child_uncompress_zlib(msg_tvb, msg_tvb, 0, tvb_reported_length(msg_tvb));
    if (msg_tvb)
    {
      add_new_data_source(pinfo, msg_tvb, "Uncompressed Message");
    }
  }

  if (msg_tvb)
  {
    proto_item *ti = proto_tree_add_string(mqtt_tree, hf_mqtt_pubmsg_decoded, msg_tvb, 0, -1,
                                           message_decode_entry->payload_proto_name);
    proto_item_set_generated(ti);

    call_dissector(message_decode_entry->payload_proto, msg_tvb, pinfo, tree);
  }
}

return match_found;
767}

769static unsigned dissect_string(tvbuff_t *tvb, proto_tree *tree, unsigned offset, int hf_len, int hf_value)
770{
uint32_t prop_len;

proto_tree_add_item_ret_uint(tree, hf_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &prop_len);
proto_tree_add_item(tree, hf_value, tvb, offset + 2, prop_len, ENC_UTF_80x00000002|ENC_NA0x00000000);

return 2 + prop_len;
777}

779/* MQTT v5.0: Reason Codes */
780static void dissect_mqtt_reason_code(proto_tree *mqtt_tree, tvbuff_t *tvb, unsigned offset, uint8_t mqtt_msg_type)
781{
static int * const hf_rcode[] = {
  NULL((void*)0), /* RESERVED */
  NULL((void*)0), /* CONNECT */
  &hf_mqtt_reason_code_connack,
  NULL((void*)0), /* PUBLISH */
  &hf_mqtt_reason_code_puback,
  &hf_mqtt_reason_code_pubrec,
  &hf_mqtt_reason_code_pubrel,
  &hf_mqtt_reason_code_pubcomp,
  NULL((void*)0), /* SUBSCRIBE */
  &hf_mqtt_reason_code_suback,
  NULL((void*)0), /* UNSUBSCRIBE */
  &hf_mqtt_reason_code_unsuback,
  NULL((void*)0), /* PINGREQ */
  NULL((void*)0), /* PINGRESP */
  &hf_mqtt_reason_code_disconnect,
  &hf_mqtt_reason_code_auth
};

if (mqtt_msg_type < array_length(hf_rcode)(sizeof (hf_rcode) / sizeof (hf_rcode)[0]))
{
  const int *hfindex = hf_rcode[mqtt_msg_type];
  if (hfindex)
  {
    proto_tree_add_item(mqtt_tree, *hfindex, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000);
  }
}
809}

811/* MQTT v5.0: dissect the MQTT properties */
812static unsigned dissect_mqtt_properties(tvbuff_t *tvb, packet_info *pinfo, proto_tree *mqtt_tree, unsigned offset, int hf_property, mqtt_properties_t *mqtt_properties)
813{
proto_tree *mqtt_prop_tree;
proto_item *ti;
uint64_t vbi;

const unsigned mqtt_prop_offset = tvb_get_varint(tvb, offset, FT_VARINT_MAX_LEN10, &vbi, ENC_VARINT_PROTOBUF0x00000002);
/* Property Length field can be stored in uint32 */
unsigned mqtt_prop_len = (unsigned)vbi;
const unsigned remaining = tvb_reported_length_remaining(tvb, offset + mqtt_prop_offset);
if (vbi > remaining)
{
  mqtt_prop_len = remaining;
  expert_add_info(pinfo, mqtt_tree, &ei_illegal_length);
}

/* Add the MQTT branch to the main tree */
/* hf_property is usually hf_mqtt_property, but can also be
 * hf_mqtt_will_property when a Will is provided in a CONNECT packet */
ti = proto_tree_add_item(mqtt_tree, hf_property, tvb, offset, mqtt_prop_offset + mqtt_prop_len, ENC_NA0x00000000);
mqtt_prop_tree = proto_item_add_subtree(ti, ett_mqtt_property);

proto_tree_add_item(mqtt_prop_tree, hf_mqtt_property_len, tvb, offset, mqtt_prop_offset, ENC_VARINT_PROTOBUF0x00000002);
offset += mqtt_prop_offset;

const unsigned bytes_to_read = offset + mqtt_prop_len;
while (offset < bytes_to_read)
{
  uint32_t prop_id;
  proto_tree_add_item_ret_uint(mqtt_prop_tree, hf_mqtt_property_id, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000, &prop_id);
  offset += 1;

  switch (prop_id)
  {
    case PROP_PAYLOAD_FORMAT_INDICATOR0x01:
    case PROP_REQUEST_PROBLEM_INFORMATION0x17:
    case PROP_REQUEST_RESPONSE_INFORMATION0x19:
    case PROP_RETAIN_AVAILABLE0x25:
    case PROP_WILDCARD_SUBSCRIPTION_AVAILABLE0x28:
    case PROP_SUBSCRIPTION_IDENTIFIER_AVAILABLE0x29:
    case PROP_SHARED_SUBSCRIPTION_AVAILABLE0x2A:
      proto_tree_add_item(mqtt_prop_tree, hf_mqtt_prop_num, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000);
      offset += 1;
      break;

    case PROP_MAXIMUM_QOS0x24:
      proto_tree_add_item(mqtt_prop_tree, hf_mqtt_prop_max_qos, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000);
      offset += 1;
      break;

    case PROP_TOPIC_ALIAS0x23:
      proto_tree_add_item_ret_uint(mqtt_prop_tree, hf_mqtt_prop_topic_alias, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_properties->topic_alias);
      offset += 2;
      break;

    case PROP_SERVER_KEEP_ALIVE0x13:
    case PROP_RECEIVE_MAXIMUM0x21:
    case PROP_TOPIC_ALIAS_MAXIMUM0x22:
      proto_tree_add_item(mqtt_prop_tree, hf_mqtt_prop_num, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000);
      offset += 2;
      break;

    case PROP_PUBLICATION_EXPIRY_INTERVAL0x02:
    case PROP_SESSION_EXPIRY_INTERVAL0x11:
    case PROP_WILL_DELAY_INTERVAL0x18:
    case PROP_MAXIMUM_PACKET_SIZE0x27:
      proto_tree_add_item(mqtt_prop_tree, hf_mqtt_prop_num, tvb, offset, 4, ENC_BIG_ENDIAN0x00000000);
      offset += 4;
      break;

    case PROP_SUBSCRIPTION_IDENTIFIER0x0B:
    {
      unsigned vbi_len;
      proto_tree_add_item_ret_length(mqtt_prop_tree, hf_mqtt_prop_num, tvb, offset, -1, ENC_LITTLE_ENDIAN0x80000000|ENC_VARINT_PROTOBUF0x00000002, &vbi_len);
      offset += vbi_len;
      break;
    }

    case PROP_CONTENT_TYPE0x03:
    {
      unsigned length;
      proto_tree_add_item_ret_string_and_length(mqtt_prop_tree, hf_mqtt_prop_content_type, tvb, offset, 2, ENC_UTF_80x00000002, pinfo->pool, (const uint8_t**)&mqtt_properties->content_type, &length);
      offset += length;
      break;
    }

    case PROP_RESPONSE_TOPIC0x08:
    case PROP_CORRELATION_DATA0x09:
    case PROP_ASSIGNED_CLIENT_IDENTIFIER0x12:
    case PROP_AUTH_METHOD0x15:
    case PROP_AUTH_DATA0x16:
    case PROP_RESPONSE_INFORMATION0x1A:
    case PROP_SERVER_REFERENCE0x1C:
    case PROP_REASON_STRING0x1F:
      offset += dissect_string(tvb, mqtt_prop_tree, offset, hf_mqtt_prop_string_len, hf_mqtt_prop_string);
      break;

    case PROP_USER_PROPERTY0x26:
      offset += dissect_string(tvb, mqtt_prop_tree, offset, hf_mqtt_prop_key_len, hf_mqtt_prop_key);
      offset += dissect_string(tvb, mqtt_prop_tree, offset, hf_mqtt_prop_value_len, hf_mqtt_prop_value);
      break;

    default:
      proto_tree_add_item(mqtt_prop_tree, hf_mqtt_prop_unknown, tvb, offset, bytes_to_read - offset, ENC_UTF_80x00000002);
      offset += (bytes_to_read - offset);
      break;
  }
}

return mqtt_prop_offset + mqtt_prop_len;
922}

924/* Dissect the MQTT message */
925static int dissect_mqtt(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, void* data _U___attribute__((unused)))
926{
uint8_t mqtt_fixed_hdr;
uint8_t mqtt_msg_type;
proto_item *ti;
const char *topic_str = "";
proto_item *mqtt_ti;
proto_tree *mqtt_tree;
uint64_t    mqtt_con_flags;
uint64_t    msg_len      = 0;
int         mqtt_msg_len = 0;
uint32_t    mqtt_str_len;
uint16_t    mqtt_len_offset;
int         mqtt_payload_len;
uint32_t    mqtt_msgid;
conversation_t *conv;
mqtt_conv_t *mqtt;
mqtt_conv_t saved_mqtt;
mqtt_pdu_data_t *pdu_data;
unsigned pdu_idx = GPOINTER_TO_UINT(p_get_proto_data(pinfo->pool, pinfo, proto_mqtt, 0))((guint) (gulong) (p_get_proto_data(pinfo->pool, pinfo, proto_mqtt
, 0)));
mqtt_properties_t mqtt_properties = { 0 };
mqtt_properties_t mqtt_will_properties = { 0 };
unsigned    offset = 0;
bool_Bool        msg_handled = false0;

static int * const publish_fields[] = {
  &hf_mqtt_msg_type,
  &hf_mqtt_dup_flag,
  &hf_mqtt_qos_level,
  &hf_mqtt_retain,
  NULL((void*)0)
};

static int * const v31_pubrel_sub_unsub_fields[] = {
  &hf_mqtt_msg_type,
  &hf_mqtt_dup_flag,
  &hf_mqtt_qos_level,
  &hf_mqtt_retain_reserved,
  NULL((void*)0)
};

static int * const other_fields[] = {
  &hf_mqtt_msg_type,
  &hf_mqtt_reserved,
  NULL((void*)0)
};

static int * const connect_flags[] = {
  &hf_mqtt_conflag_user,
  &hf_mqtt_conflag_passwd,
  &hf_mqtt_conflag_will_retain,
  &hf_mqtt_conflag_will_qos,
  &hf_mqtt_conflag_will_flag,
  &hf_mqtt_conflag_clean_sess,
  &hf_mqtt_conflag_reserved,
  NULL((void*)0)
};

static int * const connack_flags[] = {
  &hf_mqtt_conackflag_reserved,
  &hf_mqtt_conackflag_sp,
  NULL((void*)0)
};

static int * const v50_subscription_flags[] = {
  &hf_mqtt_subscription_reserved,
  &hf_mqtt_subscription_retain,
  &hf_mqtt_subscription_rap,
  &hf_mqtt_subscription_nl,
  &hf_mqtt_subscription_qos,
  NULL((void*)0)
};

/* Extract the message ID */
/* A TCP frame may contain several PDUs, including reassembled PDUs. */
p_set_proto_data(pinfo->pool, pinfo, proto_mqtt, 0, GUINT_TO_POINTER(pdu_idx + 1)((gpointer) (gulong) (pdu_idx + 1)));

mqtt_fixed_hdr = tvb_get_uint8(tvb, offset);
mqtt_msg_type = mqtt_fixed_hdr >> 4;

col_set_str(pinfo->cinfo, COL_PROTOCOL, "MQTT");
col_append_sep_str(pinfo->cinfo, COL_INFO, ", ", val_to_str_ext(pinfo->pool, mqtt_msg_type, &mqtt_msgtype_vals_ext, "Unknown (0x%02x)"));

/* Add the MQTT branch to the main tree */
mqtt_ti = proto_tree_add_item(tree, proto_mqtt, tvb, 0, -1, ENC_NA0x00000000);
mqtt_tree = proto_item_add_subtree(mqtt_ti, ett_mqtt_hdr);

conv = find_or_create_conversation(pinfo);
mqtt = (mqtt_conv_t *)conversation_get_proto_data(conv, proto_mqtt);
if (mqtt == NULL((void*)0))
1
Assuming 'mqtt' is equal to NULL→
2
←
Taking true branch→
{
  mqtt = wmem_new0(wmem_file_scope(), mqtt_conv_t)((mqtt_conv_t*)wmem_alloc0((wmem_file_scope()), sizeof(mqtt_conv_t
)));
  mqtt->runtime_proto_version = default_protocol_version;
  conversation_add_proto_data(conv, proto_mqtt, mqtt);
  mqtt->topic_alias_map = wmem_map_new(wmem_file_scope(), g_direct_hash, g_direct_equal);
}

mqtt_len_offset = tvb_get_varint(tvb, (offset + MQTT_HDR_SIZE_BEFORE_LEN1), FT_VARINT_MAX_LEN10, &msg_len, ENC_VARINT_PROTOBUF0x00000002);

/* Explicit downcast, typically maximum length of message could be 4 bytes */
mqtt_msg_len = (int) msg_len;

/* Add the type to the MQTT tree item */
proto_item_append_text(mqtt_tree, ", %s", val_to_str_ext(pinfo->pool, mqtt_msg_type, &mqtt_msgtype_vals_ext, "Unknown (0x%02x)"));

/* Save each PDU's initial state, including an unresolved topic alias. */
if (!PINFO_FD_VISITED(pinfo)((pinfo)->fd->visited))
3
←
Assuming field 'visited' is not equal to 0→
4
←
Taking false branch→
{
  pdu_data = wmem_new0(wmem_file_scope(), mqtt_pdu_data_t)((mqtt_pdu_data_t*)wmem_alloc0((wmem_file_scope()), sizeof(mqtt_pdu_data_t
)));
  pdu_data->version = mqtt->runtime_proto_version;
  p_add_proto_data(wmem_file_scope(), pinfo, proto_mqtt, pdu_idx, pdu_data);
}
else
{
  pdu_data = (mqtt_pdu_data_t *)p_get_proto_data(wmem_file_scope(), pinfo, proto_mqtt, pdu_idx);
5
←
Value assigned to 'pdu_data'→
  saved_mqtt = *mqtt;
  mqtt = &saved_mqtt;
  if (pdu_data != NULL((void*)0))
6
←
Assuming 'pdu_data' is equal to NULL→
    mqtt->runtime_proto_version = pdu_data->version;
}

if ((mqtt_msg_type != MQTT_CONNECT1) && (mqtt->runtime_proto_version == 0))
7
←
Assuming 'mqtt_msg_type' is not equal to MQTT_CONNECT→
8
←
Assuming field 'runtime_proto_version' is not equal to 0→
9
←
Taking false branch→
{
  expert_add_info(pinfo, mqtt_ti, &ei_unknown_version);
}

if (mqtt_msg_type == MQTT_PUBLISH3)
10
←
Assuming 'mqtt_msg_type' is equal to MQTT_PUBLISH→
11
←
Taking true branch→
{
  proto_tree_add_bitmask(mqtt_tree, tvb, offset, hf_mqtt_hdrflags, ett_mqtt_hdr_flags, publish_fields, ENC_BIG_ENDIAN0x00000000);
}
else if (mqtt->runtime_proto_version == MQTT_PROTO_V313 &&
         (mqtt_msg_type == MQTT_PUBREL6 ||
          mqtt_msg_type == MQTT_SUBSCRIBE8 ||
          mqtt_msg_type == MQTT_UNSUBSCRIBE10))
{
  proto_tree_add_bitmask(mqtt_tree, tvb, offset, hf_mqtt_hdrflags, ett_mqtt_hdr_flags, v31_pubrel_sub_unsub_fields, ENC_BIG_ENDIAN0x00000000);
}
else
{
  proto_tree_add_bitmask(mqtt_tree, tvb, offset, hf_mqtt_hdrflags, ett_mqtt_hdr_flags, other_fields, ENC_BIG_ENDIAN0x00000000);
}

offset += 1;

/* Add the MQTT message length */
proto_tree_add_uint64(mqtt_tree, hf_mqtt_msg_len, tvb, offset, mqtt_len_offset, msg_len);
offset += mqtt_len_offset;

switch (mqtt_msg_type)
12
←
Control jumps to 'case 3:'  at line 1188→
{
  case MQTT_CONNECT1:
    proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_proto_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
    offset += 2;

    proto_tree_add_item(mqtt_tree, hf_mqtt_proto_name, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002);
    offset += mqtt_str_len;

    mqtt->runtime_proto_version = tvb_get_uint8(tvb, offset);

    proto_tree_add_item(mqtt_tree, hf_mqtt_proto_ver, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000);
    offset += 1;

    proto_tree_add_bitmask_ret_uint64(mqtt_tree, tvb, offset, hf_mqtt_conflags,
                                      ett_mqtt_con_flags, connect_flags, ENC_BIG_ENDIAN0x00000000, &mqtt_con_flags);
    offset += 1;

    proto_tree_add_item(mqtt_tree, hf_mqtt_keep_alive, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000);
    offset += 2;

    if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
    {
      offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);
    }

    proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_client_id_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
    offset += 2;

    proto_tree_add_item(mqtt_tree, hf_mqtt_client_id, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002);
    offset += mqtt_str_len;

    if (mqtt_con_flags & MQTT_CONMASK_WILLFLAG0x04)
    {
      if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
      {
        offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_will_property, &mqtt_will_properties);
      }

      ti = proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_will_topic_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
      offset += 2;

      if (mqtt_str_len > 0)
      {
        proto_tree_add_item(mqtt_tree, hf_mqtt_will_topic, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002);
        offset += mqtt_str_len;
      }
      else
      {
        expert_add_info(pinfo, ti, &ei_illegal_length);
      }

      proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_will_msg_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
      offset += 2;

      if (show_msg_as_text)
      {
        proto_tree_add_item(mqtt_tree, hf_mqtt_will_msg_text, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002);
      }
      else
      {
        proto_tree_add_item(mqtt_tree, hf_mqtt_will_msg, tvb, offset, mqtt_str_len, ENC_NA0x00000000);
      }
      offset += mqtt_str_len;
    }

    if ((mqtt_con_flags & MQTT_CONMASK_USER0x80) && (tvb_reported_length_remaining(tvb, offset) > 0))
    {
      proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_username_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
      offset += 2;

      proto_tree_add_item(mqtt_tree, hf_mqtt_username, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002);
      offset += mqtt_str_len;
    }

    if ((mqtt_con_flags & MQTT_CONMASK_PASSWD0x40) && (tvb_reported_length_remaining(tvb, offset) > 0))
    {
      proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_passwd_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
      offset += 2;

      proto_tree_add_item(mqtt_tree, hf_mqtt_passwd, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002);
    }
    break;

  case MQTT_CONNACK2:
    if (mqtt->runtime_proto_version == MQTT_PROTO_V313)
    {
      /* v3.1 Connection Ack only contains a reserved byte and the Return Code. */
      proto_tree_add_item(mqtt_tree, hf_mqtt_conack_reserved, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000);
    }
    else
    {
      /* v3.1.1 Conn Ack contains the Conn Ack Flags and the Return Code. */
      proto_tree_add_bitmask(mqtt_tree, tvb, offset, hf_mqtt_conack_flags,
                             ett_mqtt_conack_flags, connack_flags, ENC_BIG_ENDIAN0x00000000);
    }
    offset += 1;

    if ((mqtt->runtime_proto_version == MQTT_PROTO_V313) ||
        (mqtt->runtime_proto_version == MQTT_PROTO_V3114))
    {
      proto_tree_add_item(mqtt_tree, hf_mqtt_conack_code, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000);
    }
    else
    {
      dissect_mqtt_reason_code(mqtt_tree, tvb, offset, mqtt_msg_type);
    }
    offset += 1;

    if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
    {
      offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);
    }
    break;

  case MQTT_PUBLISH3:
    /* TopicName|MsgID|Message| */
    ti = proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_topic_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
    offset += 2;

    if (mqtt_str_len > 0)
13
←
Assuming 'mqtt_str_len' is <= 0→
14
←
Taking false branch→
    {
      /* 'topic_regex' requires topic_str to be valid UTF-8. */
      proto_tree_add_item_ret_string(mqtt_tree, hf_mqtt_topic, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002|ENC_NA0x00000000,
                                     pinfo->pool, (const uint8_t**)&topic_str);
      offset += mqtt_str_len;
    }

    /* Message ID is included only when QoS > 0 */
    if (mqtt_fixed_hdr & MQTT_MASK_QOS0x06)
15
←
Assuming the condition is false→
16
←
Taking false branch→
    {
      proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_msgid, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_msgid);
      offset += 2;
      col_append_fstr(pinfo->cinfo, COL_INFO, " (id=%u)", mqtt_msgid);
    }

    if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
17
←
Assuming field 'runtime_proto_version' is equal to MQTT_PROTO_V50→
18
←
Taking true branch→
    {
      offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);

      if (mqtt_properties.topic_alias != 0)
19
←
Assuming field 'topic_alias' is not equal to 0→
20
←
Taking true branch→
      {
        char *topic = NULL((void*)0);
        if (!PINFO_FD_VISITED(pinfo)((pinfo)->fd->visited))
21
←
Assuming field 'visited' is 0→
22
←
Taking true branch→
        {
          if (mqtt_str_len22.1
'mqtt_str_len' is <= 0
 > 0)
23
←
Taking false branch→
          {
            topic = wmem_strdup(wmem_file_scope(), topic_str);
            wmem_map_insert(mqtt->topic_alias_map, GUINT_TO_POINTER(mqtt_properties.topic_alias)((gpointer) (gulong) (mqtt_properties.topic_alias)), topic);
          }
          else
          {
            topic = (char *)wmem_map_lookup(mqtt->topic_alias_map, GUINT_TO_POINTER(mqtt_properties.topic_alias)((gpointer) (gulong) (mqtt_properties.topic_alias)));
          }
          pdu_data->topic = topic;
24
←
Access to field 'topic' results in a dereference of a null pointer (loaded from variable 'pdu_data')
        }
        else if (pdu_data != NULL((void*)0))
        {
          topic = pdu_data->topic;
        }

        if (mqtt_str_len == 0)
        {
          if (topic != NULL((void*)0))
          {
            topic_str = topic;
          }

          ti = proto_tree_add_string(mqtt_tree, hf_mqtt_topic, tvb, offset, 0, topic_str);
          proto_item_set_generated(ti);

          if (topic == NULL((void*)0))
          {
            expert_add_info(pinfo, ti, &ei_unknown_topic_alias);
          }
        }
      }
    }

    if ((mqtt_str_len == 0) && (mqtt_properties.topic_alias == 0))
    {
      expert_add_info(pinfo, ti, &ei_illegal_length);
    }

    col_append_fstr(pinfo->cinfo, COL_INFO, " [%s]", topic_str);

    mqtt_payload_len = tvb_reported_length(tvb) - offset;
    if (show_msg_as_text)
    {
      proto_tree_add_item(mqtt_tree, hf_mqtt_pubmsg_text, tvb, offset, mqtt_payload_len, ENC_UTF_80x00000002);
    }
    else
    {
      proto_tree_add_item(mqtt_tree, hf_mqtt_pubmsg, tvb, offset, mqtt_payload_len, ENC_NA0x00000000);
    }

    if (num_mqtt_message_decodes > 0)
    {
      tvbuff_t *msg_tvb = tvb_new_subset_length(tvb, offset, mqtt_payload_len);
      msg_handled = mqtt_user_decode_message(tree, mqtt_tree, pinfo, topic_str, msg_tvb);
    }

    if (mqtt_properties.content_type)
    {
      tvbuff_t *msg_tvb = tvb_new_subset_length(tvb, offset, mqtt_payload_len);
      int bytes_read = dissector_try_string_with_data(media_type_dissector_table, mqtt_properties.content_type,
                                            msg_tvb, pinfo, tree, true1, NULL((void*)0));

      msg_handled = msg_handled | (bytes_read != 0);
    }

    /* No UAT or content property match, try the heuristic dissectors, pass the topic string as data */
    if (!msg_handled) {
      heur_dtbl_entry_t *hdtbl_entry;
      tvbuff_t *msg_tvb = tvb_new_subset_length(tvb, offset, mqtt_payload_len);
      char *sub_data = wmem_strdup(pinfo->pool, (const char*)topic_str);
      (void) dissector_try_heuristic(mqtt_topic_subdissector, msg_tvb, pinfo, tree, &hdtbl_entry, sub_data);
    }
    break;

  case MQTT_SUBSCRIBE8:
    /* After the Message Id field is found, the following fields must appear
     * at least once:
     * |TopicName|QoS|
     */
    proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_msgid, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_msgid);
    offset += 2;
    col_append_fstr(pinfo->cinfo, COL_INFO, " (id=%u)", mqtt_msgid);

    if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
    {
      offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);
    }

    while (offset < tvb_reported_length(tvb))
    {
      ti = proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_topic_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
      offset += 2;

      if (mqtt_str_len > 0)
      {
        proto_tree_add_item_ret_string(mqtt_tree, hf_mqtt_topic, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002|ENC_NA0x00000000,
                                       pinfo->pool, (const uint8_t**)&topic_str);
        offset += mqtt_str_len;
      }
      else
      {
        expert_add_info(pinfo, ti, &ei_illegal_length);
      }

      col_append_fstr(pinfo->cinfo, COL_INFO, " [%s]", topic_str);

      if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
      {
        proto_tree_add_bitmask(mqtt_tree, tvb, offset, hf_mqtt_subscription_options,
                               ett_mqtt_subscription_flags, v50_subscription_flags, ENC_BIG_ENDIAN0x00000000);
      }
      else
      {
        proto_tree_add_item(mqtt_tree, hf_mqtt_sub_qos, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000);
      }
      offset += 1;
    }
    break;

  case MQTT_UNSUBSCRIBE10:
    /* After the Message Id field is found, the following fields must appear
     * at least once:
     * |TopicName|
     */
    proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_msgid, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_msgid);
    offset += 2;
    col_append_fstr(pinfo->cinfo, COL_INFO, " (id=%u)", mqtt_msgid);

    if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
    {
      offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);
    }

    while (offset < tvb_reported_length(tvb))
    {
      ti = proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_topic_len, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_str_len);
      offset += 2;

      if (mqtt_str_len > 0)
      {
        proto_tree_add_item(mqtt_tree, hf_mqtt_topic, tvb, offset, mqtt_str_len, ENC_UTF_80x00000002);
        offset += mqtt_str_len;
      }
      else
      {
        expert_add_info(pinfo, ti, &ei_illegal_length);
      }
    }
    break;

  case MQTT_SUBACK9:
    /* The SUBACK message contains a list of granted QoS levels that come
     * after the Message Id field. The size of each QoS entry is 1 byte.
     */
    proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_msgid, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_msgid);
    offset += 2;
    col_append_fstr(pinfo->cinfo, COL_INFO, " (id=%u)", mqtt_msgid);

    if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
    {
      offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);
    }

    while (offset < tvb_reported_length(tvb))
    {
      if ((mqtt->runtime_proto_version == MQTT_PROTO_V313) ||
          (mqtt->runtime_proto_version == MQTT_PROTO_V3114))
      {
        proto_tree_add_item(mqtt_tree, hf_mqtt_suback_qos, tvb, offset, 1, ENC_BIG_ENDIAN0x00000000);
      }
      else
      {
        dissect_mqtt_reason_code(mqtt_tree, tvb, offset, mqtt_msg_type);
      }
      offset += 1;
    }
    break;

  case MQTT_PUBACK4:
  case MQTT_PUBREC5:
  case MQTT_PUBREL6:
  case MQTT_PUBCOMP7:
    proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_msgid, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_msgid);
    offset += 2;
    col_append_fstr(pinfo->cinfo, COL_INFO, " (id=%u)", mqtt_msgid);

    /* MQTT v5.0: The Reason Code and Property Length can be omitted if the
     * Reason Code is 0x00 and there are no Properties.
     * In this case, the PUB* has a Remaining Length of 2.
     */
    if (mqtt->runtime_proto_version == MQTT_PROTO_V505 && mqtt_msg_len > 2)
    {
      dissect_mqtt_reason_code(mqtt_tree, tvb, offset, mqtt_msg_type);
      offset += 1;

      /* If the Remaining Length is less than 4, the Property Length is not
       * present and has a value of 0.
       */
      if (mqtt_msg_len > 3)
      {
        offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);
      }
    }
    break;

  case MQTT_UNSUBACK11:
    proto_tree_add_item_ret_uint(mqtt_tree, hf_mqtt_msgid, tvb, offset, 2, ENC_BIG_ENDIAN0x00000000, &mqtt_msgid);
    offset += 2;
    col_append_fstr(pinfo->cinfo, COL_INFO, " (id=%u)", mqtt_msgid);

    if (mqtt->runtime_proto_version == MQTT_PROTO_V505)
    {
      offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);

      while (offset < tvb_reported_length(tvb))
      {
        dissect_mqtt_reason_code(mqtt_tree, tvb, offset, mqtt_msg_type);
        offset += 1;
      }
    }
    break;

    /* The following messages don't have variable header */
  case MQTT_PINGREQ12:
  case MQTT_PINGRESP13:
    break;

  case MQTT_DISCONNECT14:
    /* MQTT v5.0: Byte 1 in the Variable Header is the Disconnect Reason Code.
     * If the Remaining Length is less than 1 the value of 0x00
     * (Normal disconnection) is used.
     */
    /* FALLTHROUGH */
  case MQTT_AUTH15:
    /* MQTT v5.0: The Reason Code and Property Length can be omitted if
     * the Reason Code is 0x00 (Success) and there are no Properties.
     * In this case the AUTH has a Remaining Length of 0.
     */
    if (mqtt->runtime_proto_version == MQTT_PROTO_V505 && mqtt_msg_len > 0)
    {
      dissect_mqtt_reason_code(mqtt_tree, tvb, offset, mqtt_msg_type);
      offset += 1;

      /* 3.14.2.2 DISCONNECT Properties:
       * If the Remaining Length is less than 2, a value of 0 is used.
       * Let's assume that it also applies to AUTH, why? DISCONNECT and AUTH
       * share the same structure with no payload.
       */
      if (mqtt_msg_len >= 2)
      {
        offset += dissect_mqtt_properties(tvb, pinfo, mqtt_tree, offset, hf_mqtt_property, &mqtt_properties);
      }
    }
    break;
}

return offset;
1476}

1478/**
1479"The minimum size of MQTT Packet is 2 bytes(Ping Req, Ping Rsp,
1480Disconnect), and the maximum size is 256MB.  Hence minimum fixed
1481length should be 2 bytes for tcp_dissect_pdu.

1483If the length field is spread across two TCP segments, then we have a
1484problem, because exception will be raised.  So long as MQTT length
1485field(although spread over 4 bytes) is present within single TCP
1486segment we shouldn't have any issue by calling tcp_dissect_pdu with
1487minimum length set to 2."

1489XXX: ToDo: Commit a fix for the case of the length field spread across TCP segments.
1490**/

1492static int dissect_mqtt_data(tvbuff_t *tvb, packet_info *pinfo, proto_tree *tree, void* data)
1493{
col_clear(pinfo->cinfo, COL_INFO);

tcp_dissect_pdus(tvb, pinfo, tree,
                 reassemble_mqtt_over_tcp,
                 2,                           /* Length can be determined within 5 bytes */
                 get_mqtt_pdu_len,
                 dissect_mqtt, data);

return tvb_captured_length(tvb);
1503}

1505/*
* Register the protocol with Wireshark
*/
1508void proto_register_mqtt(void)
1509{
static hf_register_info hf_mqtt[] = {
  { &hf_mqtt_msg_len,
    { "Msg Len", "mqtt.len",
      FT_UINT64, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_hdrflags,
    { "Header Flags", "mqtt.hdrflags",
      FT_UINT8, BASE_HEX, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_msg_type,
    { "Message Type", "mqtt.msgtype",
      FT_UINT8, BASE_DEC | BASE_EXT_STRING0x00000200, &mqtt_msgtype_vals_ext, MQTT_MASK_MSG_TYPE0xF0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reserved,
    { "Reserved", "mqtt.hdr_reserved",
      FT_UINT8, BASE_DEC, NULL((void*)0), MQTT_MASK_HDR_RESERVED0x0F,
      "Fixed Header Reserved Field", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_retain_reserved,
    { "Reserved", "mqtt.retain_reserved",
      FT_UINT8, BASE_DEC, NULL((void*)0), MQTT_MASK_RETAIN0x01,
      "Fixed Header Reserved Field", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_dup_flag,
    { "DUP Flag", "mqtt.dupflag",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_MASK_DUP_FLAG0x08,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_qos_level,
    { "QoS Level", "mqtt.qos",
      FT_UINT8, BASE_DEC, VALS(mqtt_qos_vals)((0 ? (const struct _value_string*)0 : ((mqtt_qos_vals)))), MQTT_MASK_QOS0x06,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_retain,
    { "Retain", "mqtt.retain",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_MASK_RETAIN0x01,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  /* Conn-Ack */
  { &hf_mqtt_conack_reserved,
    { "Reserved", "mqtt.conack.flags.reserved",
      FT_BOOLEAN, BASE_NONE, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conack_flags,
    { "Acknowledge Flags", "mqtt.conack.flags",
      FT_UINT8, BASE_HEX, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conackflag_reserved,
    { "Reserved", "mqtt.conack.flags.reserved",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_CONACKMASK_RESERVED0xFE,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conackflag_sp,
    { "Session Present", "mqtt.conack.flags.sp",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_CONACKMASK_SP0x01,
      "Session Present (version 3.1.1)", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conack_code,
    { "Return Code", "mqtt.conack.val",
      FT_UINT8, BASE_DEC, VALS(mqtt_conack_vals)((0 ? (const struct _value_string*)0 : ((mqtt_conack_vals)))), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  /* Publish-Ack / Publish-Rec / Publish-Rel / Publish-Comp / Unsubscribe-Ack */
  { &hf_mqtt_msgid,
    { "Message Identifier", "mqtt.msgid",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_sub_qos,
    { "Requested QoS", "mqtt.sub.qos",
      FT_UINT8, BASE_DEC, VALS(mqtt_qos_vals)((0 ? (const struct _value_string*)0 : ((mqtt_qos_vals)))), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_suback_qos,
    { "Granted QoS", "mqtt.suback.qos",
      FT_UINT8, BASE_DEC, VALS(mqtt_subqos_vals)((0 ? (const struct _value_string*)0 : ((mqtt_subqos_vals)))), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_topic_len,
    { "Topic Length", "mqtt.topic_len",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_topic,
    { "Topic", "mqtt.topic",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_will_topic_len,
    { "Will Topic Length", "mqtt.willtopic_len",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_will_topic,
    { "Will Topic", "mqtt.willtopic",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_will_msg,
    { "Will Message", "mqtt.willmsg",
      FT_BYTES, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_will_msg_text,
    { "Will Message", "mqtt.willmsg_text",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_will_msg_len,
    { "Will Message Length", "mqtt.willmsg_len",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_username_len,
    { "User Name Length", "mqtt.username_len",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_username,
    { "User Name", "mqtt.username",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_passwd_len,
    { "Password Length", "mqtt.passwd_len",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_passwd,
    { "Password", "mqtt.passwd",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_pubmsg,
    { "Message", "mqtt.msg",
      FT_BYTES, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_pubmsg_text,
    { "Message", "mqtt.msg_text",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_pubmsg_decoded,
    { "Message decoded as", "mqtt.msg_decoded_as",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_proto_len,
    { "Protocol Name Length", "mqtt.proto_len",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_proto_name,
    { "Protocol Name", "mqtt.protoname",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_client_id_len,
    { "Client ID Length", "mqtt.clientid_len",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_client_id,
    { "Client ID", "mqtt.clientid",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_proto_ver,
    { "Version", "mqtt.ver",
      FT_UINT8, BASE_DEC, VALS(mqtt_protocol_version_vals)((0 ? (const struct _value_string*)0 : ((mqtt_protocol_version_vals
)))), 0,
      "MQTT version", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  /* Connect Flags */
  { &hf_mqtt_conflags,
    { "Connect Flags", "mqtt.conflags",
      FT_UINT8, BASE_HEX, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conflag_user,
    { "User Name Flag", "mqtt.conflag.uname",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_CONMASK_USER0x80,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conflag_passwd,
    { "Password Flag", "mqtt.conflag.passwd",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_CONMASK_PASSWD0x40,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conflag_will_retain,
    { "Will Retain", "mqtt.conflag.retain",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_CONMASK_RETAIN0x20,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conflag_will_qos,
    { "QoS Level", "mqtt.conflag.qos",
      FT_UINT8, BASE_DEC, VALS(mqtt_qos_vals)((0 ? (const struct _value_string*)0 : ((mqtt_qos_vals)))), MQTT_CONMASK_QOS0x18,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conflag_will_flag,
    { "Will Flag", "mqtt.conflag.willflag",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_CONMASK_WILLFLAG0x04,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conflag_clean_sess,
    { "Clean Session Flag", "mqtt.conflag.cleansess",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_CONMASK_CLEANSESS0x02,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_conflag_reserved,
    { "(Reserved)", "mqtt.conflag.reserved",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_CONMASK_RESERVED0x01,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_keep_alive,
    { "Keep Alive", "mqtt.kalive",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_subscription_options,
    { "Subscription Options", "mqtt.subscription_options",
      FT_UINT8, BASE_HEX, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_subscription_qos,
    { "QoS", "mqtt.subscription_options_qos",
      FT_UINT8, BASE_DEC, VALS(mqtt_qos_vals)((0 ? (const struct _value_string*)0 : ((mqtt_qos_vals)))), MQTT_MASK_SUBS_QOS0x03,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_subscription_nl,
    { "No Local", "mqtt.subscription_options_nl",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_MASK_SUBS_NL0x04,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_subscription_rap,
    { "Retain As Published", "mqtt.subscription_options_rap",
      FT_BOOLEAN, 8, TFS(&tfs_set_notset)((0 ? (const struct true_false_string*)0 : ((&tfs_set_notset
)))), MQTT_MASK_SUBS_RAP0x08,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_subscription_retain,
    { "Retain Handling", "mqtt.subscription_options_retain",
      FT_UINT8, BASE_DEC, VALS(mqtt_subscription_retain_handling)((0 ? (const struct _value_string*)0 : ((mqtt_subscription_retain_handling
)))), MQTT_MASK_SUBS_RETAIN0x30,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_subscription_reserved,
    { "Reserved", "mqtt.subscription_options_reserved",
      FT_UINT8, BASE_HEX, NULL((void*)0), MQTT_MASK_SUBS_RESERVED0xC0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},

  /* v5.0 Reason Codes */
  { &hf_mqtt_reason_code_connack,
    { "Reason Code", "mqtt.connack.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_connack_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_connack_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reason_code_puback,
    { "Reason Code", "mqtt.puback.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_puback_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_puback_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reason_code_pubrec,
    { "Reason Code", "mqtt.pubrec.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_puback_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_puback_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reason_code_pubrel,
    { "Reason Code", "mqtt.pubrel.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_pubrel_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_pubrel_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reason_code_pubcomp,
    { "Reason Code", "mqtt.pubcomp.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_pubrel_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_pubrel_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reason_code_suback,
    { "Reason Code", "mqtt.suback.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_suback_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_suback_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reason_code_unsuback,
    { "Reason Code", "mqtt.unsuback.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_unsuback_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_unsuback_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reason_code_disconnect,
    { "Reason Code", "mqtt.disconnect.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_disconnect_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_disconnect_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_reason_code_auth,
    { "Reason Code", "mqtt.auth.reason_code",
      FT_UINT8, BASE_DEC, VALS(mqtt_reason_code_auth_vals)((0 ? (const struct _value_string*)0 : ((mqtt_reason_code_auth_vals
)))), 0,
      "MQTT Reason Code", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},

  /* Properties */
  { &hf_mqtt_property,
    { "Properties", "mqtt.properties",
      FT_NONE, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_will_property,
    { "Will Properties", "mqtt.will_properties",
      FT_NONE, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_property_len,
    { "Total Length", "mqtt.property_len",
      FT_UINT64, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_property_id,
    { "ID", "mqtt.property_id",
      FT_UINT8, BASE_HEX, VALS(mqtt_property_vals)((0 ? (const struct _value_string*)0 : ((mqtt_property_vals))
)), 0,
      "Property Id", HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_num,
    { "Value", "mqtt.prop_number",
      FT_UINT32, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_content_type,
    { "Content Type", "mqtt.property.content_type",
      FT_UINT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_max_qos,
    { "QoS", "mqtt.property.max_qos",
      FT_UINT8, BASE_DEC, VALS(mqtt_qos_vals)((0 ? (const struct _value_string*)0 : ((mqtt_qos_vals)))), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_topic_alias,
    { "Topic Alias", "mqtt.property.topic_alias",
      FT_UINT16, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_unknown,
    { "Unknown Property", "mqtt.prop_unknown",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_string_len,
    { "Length", "mqtt.prop_string_len",
      FT_UINT32, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_string,
    { "Value", "mqtt.prop_string",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_key_len,
    { "Key Length", "mqtt.prop_key_len",
      FT_UINT32, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_key,
    { "Key", "mqtt.prop_key",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_value_len,
    { "Value Length", "mqtt.prop_value_len",
      FT_UINT32, BASE_DEC, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
  { &hf_mqtt_prop_value,
    { "Value", "mqtt.prop_value",
      FT_STRING, BASE_NONE, NULL((void*)0), 0,
      NULL((void*)0), HFILL-1, 0, HF_REF_TYPE_NONE, -1, ((void*)0) }},
};

/* Setup protocol subtree arrays */
static int* ett_mqtt[] = {
  &ett_mqtt_hdr,
  &ett_mqtt_msg,
  &ett_mqtt_hdr_flags,
  &ett_mqtt_con_flags,
  &ett_mqtt_conack_flags,
  &ett_mqtt_property,
  &ett_mqtt_subscription_flags,
};

static ei_register_info ei[] = {
  { &ei_illegal_length,
    { "mqtt.illegal_topic_length", PI_PROTOCOL0x09000000, PI_WARN0x00600000, "Length cannot be 0", EXPFILL0, ((void*)0), 0, ((void*)0), {0, {((void*)0), ((void*)0), FT_NONE
, BASE_NONE, ((void*)0), 0, ((void*)0), -1, 0, HF_REF_TYPE_NONE
, -1, ((void*)0)}} } },
  { &ei_unknown_version,
    { "mqtt.unknown_version", PI_PROTOCOL0x09000000, PI_NOTE0x00400000, "Unknown version (missing the CONNECT packet?)", EXPFILL0, ((void*)0), 0, ((void*)0), {0, {((void*)0), ((void*)0), FT_NONE
, BASE_NONE, ((void*)0), 0, ((void*)0), -1, 0, HF_REF_TYPE_NONE
, -1, ((void*)0)}} } },
  { &ei_unknown_topic_alias,
    { "mqtt.unknown_topic_alias", PI_PROTOCOL0x09000000, PI_NOTE0x00400000, "Unknown topic alias", EXPFILL0, ((void*)0), 0, ((void*)0), {0, {((void*)0), ((void*)0), FT_NONE
, BASE_NONE, ((void*)0), 0, ((void*)0), -1, 0, HF_REF_TYPE_NONE
, -1, ((void*)0)}} } }
};

static uat_field_t mqtt_message_decode_flds[] = {
  UAT_FLD_VS(message_decode, match_criteria, "Match criteria", match_criteria, "Match criteria"){"match_criteria", "Match criteria", PT_TXTMOD_ENUM,{uat_fld_chk_enum
,message_decode_match_criteria_set_cb,message_decode_match_criteria_tostr_cb
},{&(match_criteria),&(match_criteria),&(match_criteria
)},&(match_criteria),"Match criteria",((void*)0)},
  UAT_FLD_CSTRING(message_decode, topic_pattern, "Topic pattern", "Pattern to match for the topic"){"topic_pattern", "Topic pattern", PT_TXTMOD_STRING,{uat_fld_chk_str
,message_decode_topic_pattern_set_cb,message_decode_topic_pattern_tostr_cb
},{0,0,0},0,"Pattern to match for the topic",((void*)0)},
  UAT_FLD_VS(message_decode, msg_decoding, "Decoding", msg_decoding, "Decode message before dissecting as protocol"){"msg_decoding", "Decoding", PT_TXTMOD_ENUM,{uat_fld_chk_enum
,message_decode_msg_decoding_set_cb,message_decode_msg_decoding_tostr_cb
},{&(msg_decoding),&(msg_decoding),&(msg_decoding
)},&(msg_decoding),"Decode message before dissecting as protocol"
,((void*)0)},
  UAT_FLD_DISSECTOR(message_decode, payload_proto, "Payload dissector",{"payload_proto", "Payload dissector", PT_TXTMOD_DISSECTOR,{uat_fld_chk_proto
,message_decode_payload_proto_set_cb,message_decode_payload_proto_tostr_cb
},{0,0,0},0,"Dissector to be used for the message part of the matching topic"
,((void*)0)}
                "Dissector to be used for the message part of the matching topic"){"payload_proto", "Payload dissector", PT_TXTMOD_DISSECTOR,{uat_fld_chk_proto
,message_decode_payload_proto_set_cb,message_decode_payload_proto_tostr_cb
},{0,0,0},0,"Dissector to be used for the message part of the matching topic"
,((void*)0)},
  UAT_END_FIELDS{((void*)0),((void*)0),PT_TXTMOD_NONE,{0,0,0},{0,0,0},0,0,((void
*)0)}
};

uat_t *message_uat = uat_new("Message Decoding",
                             sizeof(mqtt_message_decode_t),
                             "mqtt_message_decoding",
                             true1,
                             &mqtt_message_decodes,
                             &num_mqtt_message_decodes,
                             UAT_AFFECTS_DISSECTION0x00000001, /* affects dissection of packets, but not set of named fields */
                             NULL((void*)0),
                             mqtt_message_decode_copy_cb,
                             mqtt_message_decode_update_cb,
                             mqtt_message_decode_free_cb,
                             NULL((void*)0),
                             NULL((void*)0),
                             mqtt_message_decode_flds);

module_t *mqtt_module;
expert_module_t* expert_mqtt;

/* Register protocol names and descriptions */
proto_mqtt = proto_register_protocol("MQ Telemetry Transport Protocol", "MQTT", "mqtt");

/* Register the dissector */
mqtt_handle = register_dissector("mqtt", dissect_mqtt_data, proto_mqtt);

proto_register_field_array(proto_mqtt, hf_mqtt, array_length(hf_mqtt)(sizeof (hf_mqtt) / sizeof (hf_mqtt)[0]));
proto_register_subtree_array(ett_mqtt, array_length(ett_mqtt)(sizeof (ett_mqtt) / sizeof (ett_mqtt)[0]));

mqtt_topic_subdissector = register_heur_dissector_list_with_description("mqtt.topic", "MQTT message topic", proto_mqtt);

expert_mqtt = expert_register_protocol(proto_mqtt);
expert_register_field_array(expert_mqtt, ei, array_length(ei)(sizeof (ei) / sizeof (ei)[0]));

mqtt_module = prefs_register_protocol(proto_mqtt, NULL((void*)0));

prefs_register_uat_preference(mqtt_module, "message_decode_table",
                              "Message Decoding",
                              "A table that enumerates custom message decodes to be used for a certain topic",
                              message_uat);

prefs_register_enum_preference(mqtt_module, "default_version",
                               "Default Version",
                               "Select the MQTT version to use as protocol version if the CONNECT packet is not captured",
                               &default_protocol_version, mqtt_protocol_version_enumvals, false0);

prefs_register_bool_preference(mqtt_module, "show_msg_as_text",
                               "Show Message as text",
                               "Show Publish Message as text",
                               &show_msg_as_text);

1894}

1896/*
*  Dissector Handoff
*/
1899void proto_reg_handoff_mqtt(void)
1900{
dissector_add_uint_with_preference("tcp.port", MQTT_DEFAULT_PORT1883, mqtt_handle);
ssl_dissector_add(MQTT_SSL_DEFAULT_PORT8883, mqtt_handle);

media_type_dissector_table = find_dissector_table("media_type");
dissector_add_string("quic.proto", "mqtt", mqtt_handle);
1906}

1908/*
* Editor modelines  -  https://www.wireshark.org/tools/modelines.html
*
* Local variables:
* c-basic-offset: 2
* tab-width: 8
* indent-tabs-mode: nil
* End:
*
* vi: set shiftwidth=2 tabstop=8 expandtab:
* :indentSize=2:tabSize=8:noTabs=true:
*/