version 1.1.1.1.2.8, 2012/04/26 11:49:12
|
version 1.1.1.1.2.13, 2012/04/27 15:49:07
|
Line 104 struct mqtthdr {
|
Line 104 struct mqtthdr {
|
#define MQTT_QOS_EXACTLY 2 /* Exactly once, Assured delivery, =1 */ |
#define MQTT_QOS_EXACTLY 2 /* Exactly once, Assured delivery, =1 */ |
#define MQTT_QOS_RESERVED 3 /* reserved */ |
#define MQTT_QOS_RESERVED 3 /* reserved */ |
|
|
|
#define MQTT_QOS_DENY 0 /* Not granted QoS for SUBACK */ |
|
#define MQTT_QOS_PASS 2 /* Granted QoS for SUBACK */ |
|
|
#define MQTT_FLAG_RETAIN 1 /* This flag is only used on PUBLISH messages. |
#define MQTT_FLAG_RETAIN 1 /* This flag is only used on PUBLISH messages. |
|
|
When a client sends a PUBLISH to a server, |
When a client sends a PUBLISH to a server, |
Line 267 inline unsigned int mqtt_decodeLen(void * __restrict l
|
Line 270 inline unsigned int mqtt_decodeLen(void * __restrict l
|
*/ |
*/ |
inline char mqtt_sizeLen(unsigned int len); |
inline char mqtt_sizeLen(unsigned int len); |
/* |
/* |
* mqtt_str2sub Create MQTT subscribe variable from string(s) | * mqtt_str2subs Create MQTT subscribe variable from string(s) |
* |
* |
* @csStr = strings | * @csStr = null terminated string array |
* @strnum = number of strings elements | * @strnum = copy at most number of strings elements |
* @qoses = QoS elements applied to subscribe variable, |
* @qoses = QoS elements applied to subscribe variable, |
* count of elements must be equal with csStr elements |
* count of elements must be equal with csStr elements |
* return: NULL error or != subscribe variables array, must be free after use with mqtt_freeSub() |
* return: NULL error or != subscribe variables array, must be free after use with mqtt_freeSub() |
*/ |
*/ |
inline mqtt_subscr_t *mqtt_str2sub(const char **csStr, unsigned short strnum, unsigned char *qoses); | inline mqtt_subscr_t *mqtt_str2subs(const char **csStr, unsigned short strnum, |
| unsigned char *qoses); |
/* |
/* |
* mqtt_subFree() Free array from subscribe variables |
* mqtt_subFree() Free array from subscribe variables |
* |
* |
Line 297 inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num
|
Line 301 inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num
|
* @num = Number of elements |
* @num = Number of elements |
* 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_subRealloc(mqtt_subscr_t * __restrict subs, unsigned short num); | inline mqtt_subscr_t *mqtt_subRealloc(mqtt_subscr_t ** __restrict subs, unsigned short num); |
|
|
|
|
/*** SENDER FUNCTIONS ***/ |
/*** SENDER FUNCTIONS ***/ |
Line 504 int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf);
|
Line 508 int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf);
|
* @topicLen = Topic length |
* @topicLen = Topic length |
* @msgID = MessageID |
* @msgID = MessageID |
* @pData = Data buffer |
* @pData = Data buffer |
* @datLen = Data buffer length, if *datLen == 0 allocate memory for pData | * return: -1 error or !=-1 allocated data buffer length |
* return: NULL error or !=NULL MQTT fixed header | |
*/ |
*/ |
struct mqtthdr *mqtt_readPUBLISH(mqtt_msg_t * __restrict buf, char * __restrict psTopic, | int mqtt_readPUBLISH(mqtt_msg_t * __restrict buf, char * __restrict psTopic, |
int topicLen, unsigned short *msgID, void * __restrict pData, int *datLen); | int topicLen, unsigned short *msgID, void ** __restrict pData); |
/* |
/* |
* mqtt_readPUBACK() Read PUBACK message |
* mqtt_readPUBACK() Read PUBACK message |
* |
* |