--- libaitmqtt/inc/aitmqtt.h 2022/09/14 21:44:21 1.3.4.11 +++ libaitmqtt/inc/aitmqtt.h 2022/09/16 04:14:03 1.3.4.14 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitmqtt.h,v 1.3.4.11 2022/09/14 21:44:21 misho Exp $ +* $Id: aitmqtt.h,v 1.3.4.14 2022/09/16 04:14:03 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -238,7 +238,7 @@ typedef struct { /* MQTT structures */ typedef struct { - unsigned char sub_ret; + unsigned char sub_qos; mqtt_msg_t sub_topic; mqtt_msg_t sub_value; } mqtt_subscr_t; @@ -472,12 +472,9 @@ mqtt_msg_t *mqtt_msgPUBCOMP(unsigned short msgID); * * @Topics = MQTT subscription topics * @msgID = MessageID - * @Dup = Duplicate message - * @QOS = QoS * return: NULL error or allocated SUBSCRIBE message */ -mqtt_msg_t *mqtt_msgSUBSCRIBE(mqtt_subscr_t ** __restrict Topics, - unsigned short msgID, unsigned char Dup, unsigned char QOS); +mqtt_msg_t *mqtt_msgSUBSCRIBE(mqtt_subscr_t * __restrict Topics, unsigned short msgID); /* * mqtt_msgSUBACK() Create SUBACK message * @@ -485,7 +482,7 @@ mqtt_msg_t *mqtt_msgSUBSCRIBE(mqtt_subscr_t ** __restr * @msgID = MessageID * return: NULL error or allocated SUBACK message */ -mqtt_msg_t *mqtt_msgSUBACK(mqtt_subscr_t ** __restrict Topics, unsigned short msgID); +mqtt_msg_t *mqtt_msgSUBACK(mqtt_subscr_t * __restrict Topics, unsigned short msgID); /* * mqtt_msgUNSUBSCRIBE() Create UNSUBSCRIBE message * @@ -495,7 +492,7 @@ mqtt_msg_t *mqtt_msgSUBACK(mqtt_subscr_t ** __restrict * @QOS = QoS * return: NULL error or allocated UNSUBSCRIBE message */ -mqtt_msg_t *mqtt_msgUNSUBSCRIBE(mqtt_subscr_t ** __restrict Topics, +mqtt_msg_t *mqtt_msgUNSUBSCRIBE(mqtt_subscr_t * __restrict Topics, unsigned short msgID, unsigned char Dup, unsigned char QOS); /* * mqtt_msgUNSUBACK() Create UNSUBACK message @@ -519,8 +516,8 @@ mqtt_msg_t *mqtt_msgUNSUBACK(unsigned short msgID); * @userLen = Username length * @psPass = Password for Username, only if csUser is set * @passLen = Password length - * @psWillTopic = Will Topic if !=NULL Will Flags set into message and must be free() - * @psWillMessage = Will Message, may be NULL if !NULL must be free() after use! + * @psWillTopic = Will Topic if !=NULL Will Flags set into message and must be e_free() + * @psWillMessage = Will Message, may be NULL if !NULL must be e_free() after use! * return: .reserved == 1 is error or == 0 connection flags & msg ok */ mqtthdr_connack_t mqtt_readCONNECT(mqtt_msg_t * __restrict buf, unsigned short *KASec, @@ -612,7 +609,7 @@ int mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, un * * @buf = Message buffer * @msgID = MessageID - * @subqos = Subscribes QoS, must be free after use with free() + * @subqos = Subscribes QoS, must be free after use with e_free() * return: -1 error or >-1 readed subscribes QoS elements */ int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, unsigned short *msgID, unsigned char **subqos);