--- mqtt/inc/Attic/aitmqtt.h 2011/12/05 14:11:47 1.1.1.1.2.24 +++ mqtt/inc/Attic/aitmqtt.h 2011/12/05 22:17:39 1.1.1.1.2.27 @@ -384,7 +384,71 @@ mqtthdr_connflgs_t mqtt_readCONNECT(mqtt_msg_t * __res char * __restrict psConnID, int connLen, char * __restrict psUser, int userLen, char * __restrict psPass, int passLen, char * __restrict psWillTopic, int topicLen, char * __restrict psWillMessage, int msgLen); +/* + * mqtt_readCONNACK() Read CONNACK message + * + * @buf = Message buffer + * 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 ***/