--- mqtt/inc/Attic/aitmqtt.h 2011/12/06 10:33:37 1.1.1.1.2.29 +++ mqtt/inc/Attic/aitmqtt.h 2011/12/06 12:36:45 1.1.1.1.2.30 @@ -474,6 +474,25 @@ u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf); 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 * * @buf = Message buffer