version 1.1.1.1.2.14, 2011/11/22 12:02:17
|
version 1.1.1.1.2.17, 2011/11/22 14:00:09
|
Line 10
|
Line 10
|
/* FIXED HEADER */ |
/* FIXED HEADER */ |
|
|
struct mqtthdr { |
struct mqtthdr { |
struct { | union { |
unsigned char retain:1, | struct { |
qos:2, | unsigned char retain:1, |
dup:1, | qos:2, |
type:4; | dup:1, |
| type:4; |
| }; |
| 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 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 */ |
Line 143 inline const char *mqtt_GetError();
|
Line 147 inline const char *mqtt_GetError();
|
|
|
/* |
/* |
* mqtt_msgAlloc() Allocate memory for MQTT Message |
* mqtt_msgAlloc() Allocate memory for MQTT Message |
|
* |
* @len = >0 Allocate buffer with length |
* @len = >0 Allocate buffer with length |
* return: NULL error or Message, after use must call mqtt_msgFree() with all!=0 |
* return: NULL error or Message, after use must call mqtt_msgFree() with all!=0 |
*/ |
*/ |
inline mqtt_msg_t *mqtt_msgAlloc(unsigned short len); |
inline mqtt_msg_t *mqtt_msgAlloc(unsigned short 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() |
* @all = !=0 Destroy entire message, if MQTT Message allocated with mqtt_msgAlloc() |
* return: none |
* return: none |
Line 156 inline mqtt_msg_t *mqtt_msgAlloc(unsigned short len);
|
Line 162 inline mqtt_msg_t *mqtt_msgAlloc(unsigned short len);
|
inline void mqtt_msgFree(mqtt_msg_t ** __restrict msg, int all); |
inline void mqtt_msgFree(mqtt_msg_t ** __restrict msg, int all); |
/* |
/* |
* mqtt_msgRealloc() Reallocate MQTT message buffer |
* mqtt_msgRealloc() Reallocate MQTT message buffer |
|
* |
* @msg = MQTT message |
* @msg = MQTT message |
* @len = new length |
* @len = new length |
* return: -1 error or >-1 old buffer length |
* return: -1 error or >-1 old buffer length |
Line 164 inline int mqtt_msgRealloc(mqtt_msg_t * __restrict msg
|
Line 171 inline int mqtt_msgRealloc(mqtt_msg_t * __restrict msg
|
|
|
/* |
/* |
* mqtt_encodeLen() Encode number to MQTT length field |
* mqtt_encodeLen() Encode number to MQTT length field |
|
* |
* @num = number for encode |
* @num = number for encode |
* return: -1 error or >-1 length |
* return: -1 error or >-1 length |
*/ |
*/ |
inline unsigned int mqtt_encodeLen(unsigned int num); |
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 |
* @n = sizeof bytes, if !=NULL |
* @n = sizeof bytes, if !=NULL |
* return: -1 error, >-1 length of message |
* return: -1 error, >-1 length of message |
Line 177 inline unsigned int mqtt_encodeLen(unsigned int num);
|
Line 186 inline unsigned int mqtt_encodeLen(unsigned int num);
|
inline unsigned int mqtt_decodeLen(unsigned int len, char *n); |
inline unsigned int mqtt_decodeLen(unsigned int len, char *n); |
/* |
/* |
* mqtt_sizeLen Return sizeof len field |
* mqtt_sizeLen Return sizeof len field |
|
* |
* @len = length |
* @len = length |
* return: -1 error, >-1 sizeof len in bytes |
* return: -1 error, >-1 sizeof len in bytes |
*/ |
*/ |
inline char mqtt_sizeLen(unsigned int len); |
inline char mqtt_sizeLen(unsigned int len); |
/* |
/* |
* mqtt_str2sub Create MQTT subscribe variable from string(s) |
* mqtt_str2sub Create MQTT subscribe variable from string(s) |
|
* |
* @csStr = strings |
* @csStr = strings |
* @strnum = number of strings elements |
* @strnum = number of strings elements |
* @qoses = QoS elements applied to subscribe variable, |
* @qoses = QoS elements applied to subscribe variable, |
Line 191 inline char mqtt_sizeLen(unsigned int len);
|
Line 202 inline char mqtt_sizeLen(unsigned int len);
|
*/ |
*/ |
inline mqtt_subscr_t *mqtt_str2sub(const char **csStr, unsigned short strnum, unsigned char *qoses); |
inline mqtt_subscr_t *mqtt_str2sub(const char **csStr, unsigned short strnum, unsigned char *qoses); |
/* |
/* |
* mqtt_freeSub() Free array from subscribe variables | * mqtt_subFree() Free array from subscribe variables |
* |
* |
* @subs = Subscribe variables |
* @subs = Subscribe variables |
* @freeall = if !=0 free and subs pointer |
|
* return: none |
* return: none |
*/ |
*/ |
inline void mqtt_freeSub(mqtt_subscr_t ** __restrict subs, int freeeall); | inline void mqtt_subFree(mqtt_subscr_t ** __restrict subs); |
| /* |
| * mqtt_subAlloc() Create array from subscribe variables |
| * |
| * @num = Number of elements |
| * return: NULL error or subscribe array, after use must call mqtt_subFree() |
| */ |
| inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num); |
|
|
/* |
/* |
* mqtt_msgCONNECT() Create CONNECT message |
* mqtt_msgCONNECT() Create CONNECT message |
Line 288 inline int mqtt_msgPUBCOMP(mqtt_msg_t * __restrict buf
|
Line 305 inline int mqtt_msgPUBCOMP(mqtt_msg_t * __restrict buf
|
int |
int |
mqtt_msgSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, |
mqtt_msgSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, |
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
|
/* |
|
* mqtt_msgSUBACK() Create SUBACK message |
|
* |
|
* @buf = Message buffer |
|
* @Topics = MQTT subscription topics |
|
* @msgID = MessageID |
|
* return: -1 error or >-1 message size for send |
|
*/ |
|
int mqtt_msgSUBACK(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, |
|
unsigned short msgID); |
|
/* |
|
* mqtt_msgUNSUBSCRIBE() Create UNSUBSCRIBE message |
|
* |
|
* @buf = Message buffer |
|
* @Topics = MQTT subscription topics |
|
* @msgID = MessageID |
|
* @Dup = Duplicate message |
|
* @QOS = QoS |
|
* return: -1 error or >-1 message size for send |
|
*/ |
|
int |
|
mqtt_msgUNSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, |
|
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
|
/* |
|
* mqtt_msgUNSUBACK() Create UNSUBACK message |
|
* |
|
* @buf = Message buffer |
|
* @msgID = MessageID |
|
* return: -1 error or >-1 message size for send |
|
*/ |
|
int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsigned short msgID); |
|
|
|
|
#endif |
#endif |