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.28 and 1.2

version 1.1.1.1.2.28, 2011/12/06 09:04:55	version 1.2, 2012/01/27 15:05:38
Line 108 typedef struct {	Line 108 typedef struct {

typedef unsigned char mqtthdr_protover_t;	typedef unsigned char mqtthdr_protover_t;

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

typedef struct {	typedef struct {
Line 214 inline void mqtt_subFree(mqtt_subscr_t ** __restrict s	Line 217 inline void mqtt_subFree(mqtt_subscr_t ** __restrict s
* return: NULL error or subscribe array, after use must call mqtt_subFree()	* return: NULL error or subscribe array, after use must call mqtt_subFree()
*/	*/
inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num);	inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num);
	/*
	* mqtt_subRealloc() Reallocate array from subscribe variables
	*
	* @subs = Subscribe array
	* @num = Number of elements
	* return: NULL error or subscribe array, after use must call mqtt_subFree()
	*/
	inline mqtt_subscr_t mqtt_subRealloc(mqtt_subscr_t __restrict subs, unsigned short num);


/* SENDER FUNCTIONS */	/* SENDER FUNCTIONS */
Line 223 inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num	Line 234 inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num
*	*
* @buf = Message buffer	* @buf = Message buffer
* @csConnID = ConnectID	* @csConnID = ConnectID
	* @kasec = Keep alive timeout
* @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 233 inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num	Line 245 inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num
* return: -1 error or >-1 message size for send	* return: -1 error or >-1 message size for send
*/	*/
int mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const char *csConnID,	int mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const char *csConnID,
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);
/*	/*
Line 374 int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi	Line 386 int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi
* @userLen = Username length	* @userLen = Username length
* @psPass = Password for Username, only if csUser is set	* @psPass = Password for Username, only if csUser is set
* @passLen = Password length	* @passLen = Password length
* @psWillTopic = Will Topic if !=NULL Will Flags set into message	* @psWillTopic = Will Topic if !=NULL Will Flags set into message and must be free()
* @topicLen = Will Topic length	* @psWillMessage = Will Message, may be NULL if !NULL must be free() after use!
* @psWillMessage = Will Message, may be NULL
* @msgLen = Will Message length
* return: .reserved == 1 is error or == 0 connection flags & msg ok	* return: .reserved == 1 is error or == 0 connection flags & msg ok
*/	*/
mqtthdr_connflgs_t mqtt_readCONNECT(mqtt_msg_t * __restrict buf, unsigned short *kasec,	mqtthdr_connack_t mqtt_readCONNECT(mqtt_msg_t * __restrict buf, unsigned short *kasec,
char * __restrict psConnID, int connLen,	char * __restrict psConnID, int connLen,
char * __restrict psUser, int userLen, char * __restrict psPass, int passLen,	char * __restrict psUser, int userLen, char * __restrict psPass, int passLen,
char * __restrict psWillTopic, int topicLen, char * __restrict psWillMessage, int msgLen);	char __restrict psWillTopic, char __restrict psWillMessage);
/*	/*
* mqtt_readCONNACK() Read CONNACK message	* mqtt_readCONNACK() Read CONNACK message
*	*
Line 455 u_short mqtt_readPUBREL(mqtt_msg_t * __restrict buf);	Line 465 u_short mqtt_readPUBREL(mqtt_msg_t * __restrict buf);
*/	*/
u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf);	u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf);

	/*
	* mqtt_readSUBSCRIBE() Read SUBSCRIBE message
	*
	* @buf = Message buffer
	* @msgID = MessageID
	* @subscr = Subscriptions, must be free after use with mqtt_subFree()
	* return: NULL error or !=NULL MQTT fixed header
	*/
	struct mqtthdr mqtt_readSUBSCRIBE(mqtt_msg_t __restrict buf, unsigned short *msgID,
	mqtt_subscr_t **subscr);
	/*
	* mqtt_readSUBACK() Read SUBACK message
	*
	* @buf = Message buffer
	* @msgID = MessageID
	* @subqos = Subscribes QoS, must be free after use with free()
	* return: -1 error or >-1 readed subscribes QoS elements
	*/
	int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, u_short msgID, unsigned char *subqos);
	/*
	* mqtt_readUNSUBSCRIBE() Read UNSUBSCRIBE message
	*
	* @buf = Message buffer
	* @msgID = MessageID
	* @subscr = Subscriptions, must be free after use with mqtt_subFree()
	* return: NULL error or !=NULL MQTT fixed header
	*/
	struct mqtthdr mqtt_readUNSUBSCRIBE(mqtt_msg_t __restrict buf, unsigned short *msgID,
	mqtt_subscr_t **subscr);
/*	/*
* mqtt_readUNSUBACK() Read UNSUBACK message	* mqtt_readUNSUBACK() Read UNSUBACK message
*	*

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

Removed from v.1.1.1.1.2.28
changed lines
	Added in v.1.2