libaitmqtt/inc/aitmqtt.h - diff

Return to aitmqtt.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitmqtt / inc

Diff for /libaitmqtt/inc/aitmqtt.h between versions 1.3.4.6 and 1.3.4.8

version 1.3.4.6, 2022/09/13 20:12:15	version 1.3.4.8, 2022/09/13 22:20:59
Line 47 SUCH DAMAGE.	Line 47 SUCH DAMAGE.
#define __AITMQTT_H	#define __AITMQTT_H


#define MAX_CONNID 24	#define MQTT_CONNID_MAX 24
#define MAX_CRED 13	#define MQTT_CRED_MAX 13
#define MQTTMSG_MAX 65535	#define MQTTMSG_MAX 65535
#define MQTTMSG_BIN_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 3
#define MQTT_PROTO_DEFVER 5	#define MQTT_PROTO_VER_311 4
#define MQTT_KEEPALIVE 10	#define MQTT_PROTO_VER_5 5
#define MQTT_DEFAULT_MSGID 0xDEBA	#define MQTT_KEEPALIVE 60

/* FIXED HEADER */	/* FIXED HEADER */

Line 75 struct mqtthdr {	Line 75 struct mqtthdr {
#define MQTTHDR_MSGINIT(x) (assert((x)), (x)->mqtt_msg.val ^= (x)->mqtt_msg.val, *(x)->mqtt_len = 0)	#define MQTTHDR_MSGINIT(x) (assert((x)), (x)->mqtt_msg.val ^= (x)->mqtt_msg.val, *(x)->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))

	typedef union {
	struct {
	unsigned short m:8,
	l:8;
	} sb;
	unsigned short val;
	} __attribute__((packed)) mqtt_len_t;

	typedef struct {
	mqtt_len_t var_sb;
	unsigned char var_data[0];
	} __attribute__((packed)) mqtthdr_var_t;
	#define MQTTHDR_VAR_SIZEOF(x) (assert((x)), sizeof(mqtt_len_t) + ntohs((x)->var_sb.val))

	typedef union {
	struct {
	unsigned char reserved:1,
	clean_sess:1,
	will_flg:1,
	will_qos:2,
	will_retain:1,
	password:1,
	username:1;
	};
	unsigned char flags;
	} __attribute__((packed)) mqtthdr_connflgs_t;

	typedef struct {
	unsigned char reserved;
	unsigned char retcode;
	} __attribute__((packed)) mqtthdr_connack_t;

#define MQTT_TYPE_UNKNOWN 0 /* reserved */	#define MQTT_TYPE_UNKNOWN 0 /* reserved */
#define MQTT_TYPE_CONNECT 1 /* client request to connect to server (CLI) */	#define MQTT_TYPE_CONNECT 1 /* client request to connect to server (CLI) */
#define MQTT_TYPE_CONNACK 2 /* connect acknowledgment (SRV) [ret_no_data] */	#define MQTT_TYPE_CONNACK 2 /* connect acknowledgment (SRV) [ret_no_data] */
Line 205 typedef struct {	Line 237 typedef struct {

/* MQTT structures */	/* MQTT structures */

typedef union {
struct {
unsigned short m:8,
l:8;
} sb;
unsigned short val;
} mqtt_len_t;

typedef struct {	typedef struct {
unsigned char sub_ret;	unsigned char sub_ret;
mqtt_msg_t sub_topic;	mqtt_msg_t sub_topic;
mqtt_msg_t sub_value;	mqtt_msg_t sub_value;
} mqtt_subscr_t;	} mqtt_subscr_t;

typedef struct {
mqtt_len_t var_sb;
unsigned char var_data[0];
} __attribute__((packed)) mqtthdr_var_t;
#define MQTTHDR_VAR_SIZEOF(x) (assert((x)), sizeof(mqtt_len_t) + ntohs((x)->var_sb.val))

typedef unsigned char mqtthdr_protover_t;

typedef union {
struct {
unsigned char reserved:1,
clean_sess:1,
will_flg:1,
will_qos:2,
will_retain:1,
password:1,
username:1;
};
unsigned char flags;
} __attribute__((packed)) mqtthdr_connflgs_t;

typedef struct {
unsigned char reserved;
unsigned char retcode;
} __attribute__((packed)) mqtthdr_connack_t;


// -------------------------------------------------------	// -------------------------------------------------------
// mqtt_GetErrno() Get error code of last operation	// mqtt_GetErrno() Get error code of last operation
int mqtt_GetErrno();	int mqtt_GetErrno();
Line 265 mqtt_msg_t *mqtt_msgAlloc(unsigned int len);	Line 263 mqtt_msg_t *mqtt_msgAlloc(unsigned int len);
* mqtt_msgFree() Free MQTT message	* mqtt_msgFree() Free MQTT message
*	*
* @msg = Message buffer	* @msg = Message buffer
* @all = !=0 Destroy entire message, if MQTT Message allocated with mqtt_msgAlloc()	* @keepmsg = !=0 just free message content
* return: none	* return: none
*/	*/
void mqtt_msgFree(mqtt_msg_t ** __restrict msg, int all);	void mqtt_msgFree(mqtt_msg_t ** __restrict msg, int keepmsg);
/*	/*
* mqtt_msgRealloc() Reallocate MQTT message buffer	* mqtt_msgRealloc() Reallocate MQTT message buffer
*	*
Line 383 mqtt_subscr_t mqtt_subCopy(mqtt_subscr_t __restrict	Line 381 mqtt_subscr_t mqtt_subCopy(mqtt_subscr_t __restrict
/*	/*
* mqtt_msgCONNECT() Create CONNECT message	* mqtt_msgCONNECT() Create CONNECT message
*	*
* @buf = Message buffer
* @csConnID = ConnectID	* @csConnID = ConnectID
* @kasec = Keep alive timeout, if =0 default timeout for MQTT	* @Version = MQTT version
	* @KASec = Keep alive timeout, if =0 default timeout for MQTT
* @csUser = Username if !=NULL	* @csUser = Username if !=NULL
* @csPass = Password for Username, only if csUser is set	* @csPass = Password for Username, only if csUser is set
* @csWillTopic = Will Topic if !=NULL Will Flags set into message	* @csWillTopic = Will Topic if !=NULL Will Flags set into message
Line 393 mqtt_subscr_t mqtt_subCopy(mqtt_subscr_t __restrict	Line 391 mqtt_subscr_t mqtt_subCopy(mqtt_subscr_t __restrict
* @ClrSess = Clear Session subscriptions after disconnect	* @ClrSess = Clear Session subscriptions after disconnect
* @WillQOS = Will QOS if csWillTopic is set	* @WillQOS = Will QOS if csWillTopic is set
* @WillRetain = Will Retain Will Message if csWillTopic is set	* @WillRetain = Will Retain Will Message if csWillTopic is set
* return: -1 error or >-1 message size for send	* return: NULL error or allocated connect message
*/	*/
int mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const char *csConnID,	mqtt_msg_t mqtt_msgCONNECT(const char csConnID, unsigned char Version,
unsigned short kasec, const char csUser, const char csPass,	unsigned short KASec, const char csUser, const char csPass,
const char csWillTopic, const char csWillMessage,	const char csWillTopic, const char csWillMessage,
unsigned char ClrSess, unsigned char WillQOS, unsigned char WillRetain);	unsigned char ClrSess, unsigned char WillQOS, unsigned char WillRetain);
/*	/*

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.3.4.6
changed lines
	Added in v.1.3.4.8