--- mqtt/inc/Attic/aitmqtt.h 2011/12/05 15:30:49 1.1.1.1.2.25 +++ mqtt/inc/Attic/aitmqtt.h 2011/12/05 22:17:39 1.1.1.1.2.27 @@ -391,7 +391,64 @@ mqtthdr_connflgs_t mqtt_readCONNECT(mqtt_msg_t * __res * return: -1 error or >-1 CONNECT message return code */ unsigned char mqtt_readCONNACK(mqtt_msg_t * __restrict buf); +/* + * mqtt_readDISCONNECT() Read DISCONNECT message + * + * @buf = Message buffer + * return: -1 error, 0 ok, >0 undefined result + */ +int mqtt_readDISCONNECT(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPINGREQ() Read PINGREQ message + * + * @buf = Message buffer + * return: -1 error, 0 ok, >0 undefined result + */ +int mqtt_readPINGREQ(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPINGRESP() Read PINGRESP message + * + * @buf = Message buffer + * return: -1 error, 0 ok, >0 undefined result + */ +int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPUBACK() Read PUBACK message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readPUBACK(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPUBREC() Read PUBREC message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readPUBREC(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPUBREL() Read PUBREL message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readPUBREL(mqtt_msg_t * __restrict buf); +/* + * mqtt_readPUBCOMP() Read PUBCOMP message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf); + +/* + * mqtt_readUNSUBACK() Read UNSUBACK message + * + * @buf = Message buffer + * return: -1 error or MessageID + */ +u_short mqtt_readUNSUBACK(mqtt_msg_t * __restrict buf); /*** ENGINE FUNCTIONS ***/