--- 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 17:05:38 1.1.1.1.2.26 @@ -384,6 +384,34 @@ 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); /*** ENGINE FUNCTIONS ***/