version 1.1.1.1.2.1, 2012/01/26 14:44:33
|
version 1.1.1.1.2.2, 2012/01/26 14:57:57
|
Line 501 struct mqtthdr *mqtt_readPUBLISH(mqtt_msg_t * __restri
|
Line 501 struct mqtthdr *mqtt_readPUBLISH(mqtt_msg_t * __restri
|
* @buf = Message buffer |
* @buf = Message buffer |
* return: -1 error or MessageID |
* return: -1 error or MessageID |
*/ |
*/ |
u_short mqtt_readPUBACK(mqtt_msg_t * __restrict buf); | unsigned short mqtt_readPUBACK(mqtt_msg_t * __restrict buf); |
/* |
/* |
* mqtt_readPUBREC() Read PUBREC message |
* mqtt_readPUBREC() Read PUBREC message |
* |
* |
* @buf = Message buffer |
* @buf = Message buffer |
* return: -1 error or MessageID |
* return: -1 error or MessageID |
*/ |
*/ |
u_short mqtt_readPUBREC(mqtt_msg_t * __restrict buf); | unsigned short mqtt_readPUBREC(mqtt_msg_t * __restrict buf); |
/* |
/* |
* mqtt_readPUBREL() Read PUBREL message |
* mqtt_readPUBREL() Read PUBREL message |
* |
* |
* @buf = Message buffer |
* @buf = Message buffer |
* return: -1 error or MessageID |
* return: -1 error or MessageID |
*/ |
*/ |
u_short mqtt_readPUBREL(mqtt_msg_t * __restrict buf); | unsigned short mqtt_readPUBREL(mqtt_msg_t * __restrict buf); |
/* |
/* |
* mqtt_readPUBCOMP() Read PUBCOMP message |
* mqtt_readPUBCOMP() Read PUBCOMP message |
* |
* |
* @buf = Message buffer |
* @buf = Message buffer |
* return: -1 error or MessageID |
* return: -1 error or MessageID |
*/ |
*/ |
u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf); | unsigned short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf); |
|
|
/* |
/* |
* mqtt_readSUBSCRIBE() Read SUBSCRIBE message |
* mqtt_readSUBSCRIBE() Read SUBSCRIBE message |
Line 542 struct mqtthdr *mqtt_readSUBSCRIBE(mqtt_msg_t * __rest
|
Line 542 struct mqtthdr *mqtt_readSUBSCRIBE(mqtt_msg_t * __rest
|
* @subqos = Subscribes QoS, must be free after use with free() |
* @subqos = Subscribes QoS, must be free after use with free() |
* return: -1 error or >-1 readed subscribes QoS elements |
* return: -1 error or >-1 readed subscribes QoS elements |
*/ |
*/ |
int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, u_short *msgID, unsigned char **subqos); | int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, unsigned short *msgID, unsigned char **subqos); |
/* |
/* |
* mqtt_readUNSUBSCRIBE() Read UNSUBSCRIBE message |
* mqtt_readUNSUBSCRIBE() Read UNSUBSCRIBE message |
* |
* |
Line 559 struct mqtthdr *mqtt_readUNSUBSCRIBE(mqtt_msg_t * __re
|
Line 559 struct mqtthdr *mqtt_readUNSUBSCRIBE(mqtt_msg_t * __re
|
* @buf = Message buffer |
* @buf = Message buffer |
* return: -1 error or MessageID |
* return: -1 error or MessageID |
*/ |
*/ |
u_short mqtt_readUNSUBACK(mqtt_msg_t * __restrict buf); | unsigned short mqtt_readUNSUBACK(mqtt_msg_t * __restrict buf); |
| |
/*** ENGINE FUNCTIONS ***/ | |
| |
/* | |
* mqttInitCallbacks() Init callback array for dispatcher | |
* | |
* return: NULL error or !=NULL allocated callback array, after use free with mqttFiniCallbacks() | |
*/ | |
mqtt_cb_t *mqttInitCallbacks(void); | |
/* | |
* mqttFiniCallbacks() Free callback array | |
* | |
* @cb = Callback array | |
* return: none | |
*/ | |
void mqttFiniCallbacks(mqtt_cb_t ** __restrict cb); | |
/* | |
* MQTT_CALLBACK() Assign function to callback array for MQTT dispatcher | |
* | |
* @_cbs = Callback array | |
* @_x = MQTT Message type, like MQTT_TYPE_* ... | |
* @_func = Function | |
* return: none | |
*/ | |
#define MQTT_CALLBACK(_cbs, _x, _func) (assert((_cbs)), (_cbs)[(_x)] = (_func)) | |
/* | |
* mqttDispatcher() MQTT Message type dispatcher | |
* | |
* @cb = Callback array | |
* @buf = Received MQTT message | |
* return: -1 error or >-1 return value from executed callback | |
*/ | |
inline int mqttDispatcher(mqtt_cb_t * __restrict cb, mqtt_msg_t * __restrict buf); | |
|
|
|
|
#endif |
#endif |