|
|
| version 1.1.1.1.2.14, 2012/04/27 16:02:16 | version 1.1.1.1.2.16, 2012/06/20 08:15:12 |
|---|---|
| Line 71 struct mqtthdr { | Line 71 struct mqtthdr { |
| 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) |
| #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 */ |
| Line 224 inline void mqtt_msgFree(mqtt_msg_t ** __restrict msg, | Line 225 inline void mqtt_msgFree(mqtt_msg_t ** __restrict msg, |
| * return: -1 error or >-1 old buffer length | * return: -1 error or >-1 old buffer length |
| */ | */ |
| inline int mqtt_msgRealloc(mqtt_msg_t * __restrict msg, unsigned short len); | inline int mqtt_msgRealloc(mqtt_msg_t * __restrict msg, unsigned short len); |
| /* | |
| * mqtt_msgDup() - Duplicate message buffer | |
| * | |
| * @msg = Message | |
| * return: NULL error or !=NULL duplicated message, after use must call mqtt_msgFree() with all!=0 | |
| */ | |
| inline mqtt_msg_t *mqtt_msgDup(mqtt_msg_t * __restrict msg); | |
| /* | /* |
| * mqtt_expandTopic() - Expanding topic to regular expression | * mqtt_expandTopic() - Expanding topic to regular expression |
| Line 270 inline unsigned int mqtt_decodeLen(void * __restrict l | Line 278 inline unsigned int mqtt_decodeLen(void * __restrict l |
| */ | */ |
| inline char mqtt_sizeLen(unsigned int len); | inline char mqtt_sizeLen(unsigned int len); |
| /* | /* |
| * mqtt_pktLen() - Get total packet length | |
| * | |
| * @hdr = MQTT packet header | |
| * return: packet length | |
| */ | |
| inline unsigned int mqtt_pktLen(struct mqtthdr * __restrict hdr); | |
| /* | |
| * mqtt_str2subs Create MQTT subscribe variable from string(s) | * mqtt_str2subs Create MQTT subscribe variable from string(s) |
| * | * |
| * @csStr = null terminated string array | * @csStr = null terminated string array |
| Line 515 int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf); | Line 530 int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf); |
| * @psTopic = Topic | * @psTopic = Topic |
| * @topicLen = Topic length | * @topicLen = Topic length |
| * @msgID = MessageID | * @msgID = MessageID |
| * @pData = Data buffer | * @pData = Data buffer, may be NULL |
| * return: -1 error or !=-1 allocated data buffer length | * return: -1 error or !=-1 allocated data buffer length |
| */ | */ |
| int mqtt_readPUBLISH(mqtt_msg_t * __restrict buf, char * __restrict psTopic, | int mqtt_readPUBLISH(mqtt_msg_t * __restrict buf, char * __restrict psTopic, |