version 1.3.4.2, 2022/09/12 21:52:57
|
version 1.3.4.3, 2022/09/12 22:09:29
|
Line 50 SUCH DAMAGE.
|
Line 50 SUCH DAMAGE.
|
#define MAX_CONNID 24 |
#define MAX_CONNID 24 |
#define MAX_CRED 13 |
#define MAX_CRED 13 |
#define MQTTMSG_MAX 65535 |
#define MQTTMSG_MAX 65535 |
|
#define MQTTMSG_BIN_MAX 65535 |
#define MQTT_DATA_MAX 268435455 |
#define MQTT_DATA_MAX 268435455 |
|
|
#define MQTT_PROTO_VER 3 |
#define MQTT_PROTO_VER 3 |
Line 70 struct mqtthdr {
|
Line 71 struct mqtthdr {
|
} mqtt_msg; |
} mqtt_msg; |
unsigned char mqtt_len[1]; /* may be grow to 4 bytes */ |
unsigned char mqtt_len[1]; /* may be grow to 4 bytes */ |
} __attribute__((packed)); |
} __attribute__((packed)); |
#define MQTTHDR_MSGINIT(x) (assert((x)), (x)->mqtt_msg.val ^= (x)->mqtt_msg.val) | #define MQTTHDR_MSGINIT(x) (assert((x)), (x)->mqtt_msg.val ^= (x)->mqtt_msg.val, *mqtt_len = 0) |
#define MQTTHDR_DATA_SIZEOF(x) (assert((x)), mqtt_decodeLen((x)->mqtt_len, NULL)) |
#define MQTTHDR_DATA_SIZEOF(x) (assert((x)), mqtt_decodeLen((x)->mqtt_len, NULL)) |
|
|
#define MQTT_TYPE_UNKNOWN 0 /* reserved */ |
#define MQTT_TYPE_UNKNOWN 0 /* reserved */ |
#define MQTT_TYPE_CONNECT 1 /* client request to connect to server */ | #define MQTT_TYPE_CONNECT 1 /* client request to connect to server (CLI) */ |
#define MQTT_TYPE_CONNACK 2 /* connect acknowledgment */ | #define MQTT_TYPE_CONNACK 2 /* connect acknowledgment (SRV) */ |
#define MQTT_TYPE_PUBLISH 3 /* publish message */ |
#define MQTT_TYPE_PUBLISH 3 /* publish message */ |
#define MQTT_TYPE_PUBACK 4 /* publish acknowledgment */ |
#define MQTT_TYPE_PUBACK 4 /* publish acknowledgment */ |
#define MQTT_TYPE_PUBREC 5 /* publish received (assured delivery part 1) */ |
#define MQTT_TYPE_PUBREC 5 /* publish received (assured delivery part 1) */ |
#define MQTT_TYPE_PUBREL 6 /* publish release (assured delivery part 2) */ |
#define MQTT_TYPE_PUBREL 6 /* publish release (assured delivery part 2) */ |
#define MQTT_TYPE_PUBCOMP 7 /* publish complete (assured delivery part 3) */ |
#define MQTT_TYPE_PUBCOMP 7 /* publish complete (assured delivery part 3) */ |
#define MQTT_TYPE_SUBSCRIBE 8 /* client subscribe request */ | #define MQTT_TYPE_SUBSCRIBE 8 /* client subscribe request (CLI) */ |
#define MQTT_TYPE_SUBACK 9 /* subscribe acknowledgment */ | #define MQTT_TYPE_SUBACK 9 /* subscribe acknowledgment (SRV) */ |
#define MQTT_TYPE_UNSUBSCRIBE 10 /* client unsubscribe request */ | #define MQTT_TYPE_UNSUBSCRIBE 10 /* client unsubscribe request (CLI) */ |
#define MQTT_TYPE_UNSUBACK 11 /* unsubscribe acknowledgment */ | #define MQTT_TYPE_UNSUBACK 11 /* unsubscribe acknowledgment (SRV) */ |
#define MQTT_TYPE_PINGREQ 12 /* PING request */ | #define MQTT_TYPE_PINGREQ 12 /* PING request (CLI) */ |
#define MQTT_TYPE_PINGRESP 13 /* PING response */ | #define MQTT_TYPE_PINGRESP 13 /* PING response (SRV) */ |
#define MQTT_TYPE_DISCONNECT 14 /* client is disconnecting */ |
#define MQTT_TYPE_DISCONNECT 14 /* client is disconnecting */ |
#define MQTT_TYPE_AUTH 15 /* authentication exchange */ |
#define MQTT_TYPE_AUTH 15 /* authentication exchange */ |
#define MQTT_TYPE_MAX 15 /* reserved */ | |
| #define MQTT_TYPE_MAX 15 |
|
|
#define MQTT_FLAG_DUP 1 /* This flag is set when the client or server attempts to re-deliver |
#define MQTT_FLAG_DUP 1 /* This flag is set when the client or server attempts to re-deliver |
a PUBLISH, PUBREL, SUBSCRIBE or UNSUBSCRIBE message. |
a PUBLISH, PUBREL, SUBSCRIBE or UNSUBSCRIBE message. |