version 1.1.1.1.2.13, 2012/04/27 15:49:07
|
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 |
* 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, |