|
|
| version 1.1.1.1.2.12, 2012/04/27 15:15:12 | version 1.1.1.1.2.15, 2012/06/11 08:37:41 |
|---|---|
| Line 224 inline void mqtt_msgFree(mqtt_msg_t ** __restrict msg, | Line 224 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 302 inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num | Line 309 inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num |
| * 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); |
| /* | |
| * mqtt_subCopy() - Copy subscription structure to another one | |
| * | |
| * @dst = destination subscription | |
| * @src = source subscription | |
| * return: =NULL error or !=NULL successful copied a structure | |
| */ | |
| inline mqtt_subscr_t *mqtt_subCopy(mqtt_subscr_t * __restrict dst, mqtt_subscr_t * __restrict src); | |
| /*** SENDER FUNCTIONS ***/ | /*** SENDER FUNCTIONS ***/ |
| Line 507 int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf); | Line 522 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 |
| * @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 data buffer | |
| */ | */ |
| void *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 |
| * | * |