--- libaitmqtt/inc/aitmqtt.h 2022/09/14 14:32:48 1.3.4.9 +++ libaitmqtt/inc/aitmqtt.h 2022/09/14 17:37:13 1.3.4.10 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitmqtt.h,v 1.3.4.9 2022/09/14 14:32:48 misho Exp $ +* $Id: aitmqtt.h,v 1.3.4.10 2022/09/14 17:37:13 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -426,7 +426,6 @@ mqtt_msg_t *mqtt_msgPINGRESP(); /* * mqtt_msgPUBLISH() Create PUBLISH message * - * @buf = Message buffer * @csTopic = Publish topic * @msgID = MessageID >0, if QOS != MQTT_QOS_ONCE * @Dup = Duplicate message @@ -434,43 +433,39 @@ mqtt_msg_t *mqtt_msgPINGRESP(); * @Retain = Retain message * @pData = Publish data into topic * @datlen = Publish data length - * return: -1 error or >-1 message size for send + * return: NULL error or allocated PUBLISH message */ -int mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const char *csTopic, - unsigned short msgID, unsigned char Dup, unsigned char QOS, +mqtt_msg_t *mqtt_msgPUBLISH(const char *csTopic, unsigned short msgID, + unsigned char Dup, unsigned char QOS, unsigned char Retain, const void *pData, int datlen); /* * mqtt_msgPUBACK() Create PUBACK message * - * @buf = Message buffer * @msgID = MessageID - * return: -1 error or >-1 message size for send + * return: NULL error or allocated PUBACK message */ -int mqtt_msgPUBACK(mqtt_msg_t * __restrict buf, unsigned short msgID); +mqtt_msg_t *mqtt_msgPUBACK(unsigned short msgID); /* * mqtt_msgPUBREC() Create PUBREC message * - * @buf = Message buffer * @msgID = MessageID - * return: -1 error or >-1 message size for send + * return: NULL error or allocated PUBREC message */ -int mqtt_msgPUBREC(mqtt_msg_t * __restrict buf, unsigned short msgID); +mqtt_msg_t *mqtt_msgPUBREC(unsigned short msgID); /* * mqtt_msgPUBREL() Create PUBREL message * - * @buf = Message buffer * @msgID = MessageID - * return: -1 error or >-1 message size for send + * return: NULL error or allocated PUBREL message */ -int mqtt_msgPUBREL(mqtt_msg_t * __restrict buf, unsigned short msgID); +mqtt_msg_t *mqtt_msgPUBREL(unsigned short msgID); /* * mqtt_msgPUBCOMP() Create PUBCOMP message * - * @buf = Message buffer * @msgID = MessageID - * return: -1 error or >-1 message size for send + * return: NULL error or allocated PUBCOMP message */ -int mqtt_msgPUBCOMP(mqtt_msg_t * __restrict buf, unsigned short msgID); +mqtt_msg_t *mqtt_msgPUBCOMP(unsigned short msgID); /* * mqtt_msgSUBSCRIBE() Create SUBSCRIBE message