version 1.1.1.1.2.28, 2011/12/06 09:04:55
|
version 1.1.1.1.2.30, 2011/12/06 12:36:45
|
Line 214 inline void mqtt_subFree(mqtt_subscr_t ** __restrict s
|
Line 214 inline void mqtt_subFree(mqtt_subscr_t ** __restrict s
|
* 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_subAlloc(unsigned short num); |
inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num); |
|
/* |
|
* mqtt_subRealloc() Reallocate array from subscribe variables |
|
* |
|
* @subs = Subscribe array |
|
* @num = Number of elements |
|
* 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); |
|
|
|
|
/*** SENDER FUNCTIONS ***/ |
/*** SENDER FUNCTIONS ***/ |
Line 455 u_short mqtt_readPUBREL(mqtt_msg_t * __restrict buf);
|
Line 463 u_short mqtt_readPUBREL(mqtt_msg_t * __restrict buf);
|
*/ |
*/ |
u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf); |
u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf); |
|
|
|
/* |
|
* mqtt_readSUBSCRIBE() Read SUBSCRIBE message |
|
* |
|
* @buf = Message buffer |
|
* @msgID = MessageID |
|
* @subscr = Subscriptions, must be free after use with mqtt_subFree() |
|
* return: NULL error or !=NULL MQTT fixed header |
|
*/ |
|
struct mqtthdr *mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, |
|
mqtt_subscr_t **subscr); |
|
/* |
|
* mqtt_readSUBACK() Read SUBACK message |
|
* |
|
* @buf = Message buffer |
|
* @msgID = MessageID |
|
* @subqos = Subscribes QoS, must be free after use with free() |
|
* return: -1 error or >-1 readed subscribes QoS elements |
|
*/ |
|
int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, u_short *msgID, unsigned char **subqos); |
|
/* |
|
* mqtt_readUNSUBSCRIBE() Read UNSUBSCRIBE message |
|
* |
|
* @buf = Message buffer |
|
* @msgID = MessageID |
|
* @subscr = Subscriptions, must be free after use with mqtt_subFree() |
|
* return: NULL error or !=NULL MQTT fixed header |
|
*/ |
|
struct mqtthdr *mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, |
|
mqtt_subscr_t **subscr); |
/* |
/* |
* mqtt_readUNSUBACK() Read UNSUBACK message |
* mqtt_readUNSUBACK() Read UNSUBACK message |
* |
* |