version 1.3.4.10, 2022/09/14 17:37:13
|
version 1.3.4.11, 2022/09/14 21:44:21
|
Line 470 mqtt_msg_t *mqtt_msgPUBCOMP(unsigned short msgID);
|
Line 470 mqtt_msg_t *mqtt_msgPUBCOMP(unsigned short msgID);
|
/* |
/* |
* mqtt_msgSUBSCRIBE() Create SUBSCRIBE message |
* mqtt_msgSUBSCRIBE() Create SUBSCRIBE message |
* |
* |
* @buf = Message buffer |
|
* @Topics = MQTT subscription topics |
* @Topics = MQTT subscription topics |
* @msgID = MessageID |
* @msgID = MessageID |
* @Dup = Duplicate message |
* @Dup = Duplicate message |
* @QOS = QoS |
* @QOS = QoS |
* return: -1 error or >-1 message size for send | * return: NULL error or allocated SUBSCRIBE message |
*/ |
*/ |
int | mqtt_msg_t *mqtt_msgSUBSCRIBE(mqtt_subscr_t ** __restrict Topics, |
mqtt_msgSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, | |
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
/* |
/* |
* mqtt_msgSUBACK() Create SUBACK message |
* mqtt_msgSUBACK() Create SUBACK message |
* |
* |
* @buf = Message buffer |
|
* @Topics = MQTT subscription topics |
* @Topics = MQTT subscription topics |
* @msgID = MessageID |
* @msgID = MessageID |
* return: -1 error or >-1 message size for send | * return: NULL error or allocated SUBACK message |
*/ |
*/ |
int mqtt_msgSUBACK(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, | mqtt_msg_t *mqtt_msgSUBACK(mqtt_subscr_t ** __restrict Topics, unsigned short msgID); |
unsigned short msgID); | |
/* |
/* |
* mqtt_msgUNSUBSCRIBE() Create UNSUBSCRIBE message |
* mqtt_msgUNSUBSCRIBE() Create UNSUBSCRIBE message |
* |
* |
* @buf = Message buffer |
|
* @Topics = MQTT subscription topics |
* @Topics = MQTT subscription topics |
* @msgID = MessageID |
* @msgID = MessageID |
* @Dup = Duplicate message |
* @Dup = Duplicate message |
* @QOS = QoS |
* @QOS = QoS |
* return: -1 error or >-1 message size for send | * return: NULL error or allocated UNSUBSCRIBE message |
*/ |
*/ |
int | mqtt_msg_t *mqtt_msgUNSUBSCRIBE(mqtt_subscr_t ** __restrict Topics, |
mqtt_msgUNSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, | |
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
/* |
/* |
* mqtt_msgUNSUBACK() Create UNSUBACK message |
* mqtt_msgUNSUBACK() Create UNSUBACK message |
* |
* |
* @buf = Message buffer |
|
* @msgID = MessageID |
* @msgID = MessageID |
* return: -1 error or >-1 message size for send | * return: NULL error or allocated UNSUBACK message |
*/ |
*/ |
int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsigned short msgID); | mqtt_msg_t *mqtt_msgUNSUBACK(unsigned short msgID); |
|
|
|
|
/*** RECEIVER FUNCTIONS ***/ |
/*** RECEIVER FUNCTIONS ***/ |