mqtt/inc/aitmqtt.h - diff

Return to aitmqtt.h CVS log

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

Diff for /mqtt/inc/Attic/aitmqtt.h between versions 1.1.1.1.2.18 and 1.1.1.1.2.25

version 1.1.1.1.2.18, 2011/11/22 14:13:03	version 1.1.1.1.2.25, 2011/12/05 15:30:49
Line 2	Line 2
#define __AITMQTT_H	#define __AITMQTT_H


#define MQTT_DATA_MAX 268435455
#define MQTT_CONN_STR "MQIsdp"
#define MQTT_PROTO_VER 3
#define MQTT_KEEPALIVE 10

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

struct mqtthdr {	struct mqtthdr {
Line 17 struct mqtthdr {	Line 12 struct mqtthdr {
dup:1,	dup:1,
type:4;	type:4;
};	};
unsigned char val;	unsigned char val;
} 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 */
} __packed;	} __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)

Line 38 struct mqtthdr {	Line 33 struct mqtthdr {
#define MQTT_TYPE_PINGREQ 12 /* PING request */	#define MQTT_TYPE_PINGREQ 12 /* PING request */
#define MQTT_TYPE_PINGRESP 13 /* PING response */	#define MQTT_TYPE_PINGRESP 13 /* PING response */
#define MQTT_TYPE_DISCONNECT 14 /* client is disconnecting */	#define MQTT_TYPE_DISCONNECT 14 /* client is disconnecting */
#define MQTT_TYPE_RESERVED 15 /* reserved */	#define MQTT_TYPE_MAX 15 /* reserved */

#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.
Line 100 typedef union {	Line 95 typedef union {
} mqtt_v_t;	} mqtt_v_t;

typedef struct {	typedef struct {
mqtt_v_t sub_sb;	unsigned char sub_ret;
char *sub_data;	struct __sbuf sub_topic;
unsigned char sub_qos;	struct __sbuf sub_value;
} mqtt_subscr_t;	} mqtt_subscr_t;

typedef struct {	typedef struct {
Line 136 typedef struct {	Line 131 typedef struct {
unsigned short msg_len;	unsigned short msg_len;
} mqtt_msg_t;	} mqtt_msg_t;

	/* MQTT dispatcher callbacks */

	typedef int (mqtt_cb_t)(void );


// -------------------------------------------------------	// -------------------------------------------------------
// mqtt_GetErrno() Get error code of last operation	// mqtt_GetErrno() Get error code of last operation
inline int mqtt_GetErrno();	inline int mqtt_GetErrno();
Line 179 inline unsigned int mqtt_encodeLen(unsigned int num);	Line 178 inline unsigned int mqtt_encodeLen(unsigned int num);
/*	/*
* mqtt_decodeLen() Decode length from MQTT packet	* mqtt_decodeLen() Decode length from MQTT packet
*	*
* @len = length	* @len = length from MQTT header
* @n = sizeof bytes, if !=NULL	* @n = sizeof bytes, if !=NULL
* return: -1 error, >-1 length of message	* return: -1 error, >-1 length of message
*/	*/
inline unsigned int mqtt_decodeLen(unsigned int len, char *n);	inline unsigned int mqtt_decodeLen(void * __restrict len, int * __restrict n);
/*	/*
* mqtt_sizeLen Return sizeof len field	* mqtt_sizeLen Return sizeof len field
*	*
Line 216 inline void mqtt_subFree(mqtt_subscr_t ** __restrict s	Line 215 inline void mqtt_subFree(mqtt_subscr_t ** __restrict s
*/	*/
inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num);	inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num);


	/* SENDER FUNCTIONS */

/*	/*
* mqtt_msgCONNECT() Create CONNECT message	* mqtt_msgCONNECT() Create CONNECT message
*	*
Line 357 mqtt_msgUNSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_	Line 359 mqtt_msgUNSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_
* return: -1 error or >-1 message size for send	* return: -1 error or >-1 message size for send
*/	*/
int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsigned short msgID);	int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsigned short msgID);


	/* RECEIVER FUNCTIONS */

	/*
	* mqtt_readCONNECT() Read elements from CONNECT message
	*
	* @buf = Message buffer
	* @kasec = Keep Alive in seconds for current connection
	* @psConnID = ConnectID
	* @connLen = ConnectID length
	* @psUser = Username if !=NULL
	* @userLen = Username length
	* @psPass = Password for Username, only if csUser is set
	* @passLen = Password length
	* @psWillTopic = Will Topic if !=NULL Will Flags set into message
	* @topicLen = Will Topic length
	* @psWillMessage = Will Message, may be NULL
	* @msgLen = Will Message length
	* return: .reserved == 1 is error or == 0 connection flags & msg ok
	*/
	mqtthdr_connflgs_t mqtt_readCONNECT(mqtt_msg_t * __restrict buf, unsigned short *kasec,
	char * __restrict psConnID, int connLen,
	char * __restrict psUser, int userLen, char * __restrict psPass, int passLen,
	char * __restrict psWillTopic, int topicLen, char * __restrict psWillMessage, int msgLen);
	/*
	* mqtt_readCONNACK() Read CONNACK message
	*
	* @buf = Message buffer
	* return: -1 error or >-1 CONNECT message return code
	*/
	unsigned char mqtt_readCONNACK(mqtt_msg_t * __restrict buf);


	/* ENGINE FUNCTIONS */

	/*
	* mqttInitCallbacks() Init callback array for dispatcher
	*
	* return: NULL error or !=NULL allocated callback array, after use free with mqttFiniCallbacks()
	*/
	mqtt_cb_t *mqttInitCallbacks(void);
	/*
	* mqttFiniCallbacks() Free callback array
	*
	* @cb = Callback array
	* return: none
	*/
	void mqttFiniCallbacks(mqtt_cb_t ** __restrict cb);
	/*
	* MQTT_CALLBACK() Assign function to callback array for MQTT dispatcher
	*
	* @_cbs = Callback array
	* @_x = MQTT Message type, like MQTT_TYPE_* ...
	* @_func = Function
	* return: none
	*/
	#define MQTT_CALLBACK(_cbs, _x, _func) (assert((_cbs)), (_cbs)[(_x)] = (_func))
	/*
	* mqttDispatcher() MQTT Message type dispatcher
	*
	* @cb = Callback array
	* @buf = Received MQTT message
	* return: -1 error or >-1 return value from executed callback
	*/
	inline int mqttDispatcher(mqtt_cb_t * __restrict cb, mqtt_msg_t * __restrict buf);


#endif	#endif

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

Removed from v.1.1.1.1.2.18
changed lines
	Added in v.1.1.1.1.2.25