version 1.3.4.9, 2022/09/14 14:32:48
|
version 1.3.4.11, 2022/09/14 21:44:21
|
Line 426 mqtt_msg_t *mqtt_msgPINGRESP();
|
Line 426 mqtt_msg_t *mqtt_msgPINGRESP();
|
/* |
/* |
* mqtt_msgPUBLISH() Create PUBLISH message |
* mqtt_msgPUBLISH() Create PUBLISH message |
* |
* |
* @buf = Message buffer |
|
* @csTopic = Publish topic |
* @csTopic = Publish topic |
* @msgID = MessageID >0, if QOS != MQTT_QOS_ONCE |
* @msgID = MessageID >0, if QOS != MQTT_QOS_ONCE |
* @Dup = Duplicate message |
* @Dup = Duplicate message |
Line 434 mqtt_msg_t *mqtt_msgPINGRESP();
|
Line 433 mqtt_msg_t *mqtt_msgPINGRESP();
|
* @Retain = Retain message |
* @Retain = Retain message |
* @pData = Publish data into topic |
* @pData = Publish data into topic |
* @datlen = Publish data length |
* @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, | mqtt_msg_t *mqtt_msgPUBLISH(const char *csTopic, unsigned short msgID, |
unsigned short msgID, unsigned char Dup, unsigned char QOS, | unsigned char Dup, unsigned char QOS, |
unsigned char Retain, const void *pData, int datlen); |
unsigned char Retain, const void *pData, int datlen); |
/* |
/* |
* mqtt_msgPUBACK() Create PUBACK message |
* mqtt_msgPUBACK() Create PUBACK message |
* |
* |
* @buf = Message buffer |
|
* @msgID = MessageID |
* @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 |
* mqtt_msgPUBREC() Create PUBREC message |
* |
* |
* @buf = Message buffer |
|
* @msgID = MessageID |
* @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 |
* mqtt_msgPUBREL() Create PUBREL message |
* |
* |
* @buf = Message buffer |
|
* @msgID = MessageID |
* @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 |
* mqtt_msgPUBCOMP() Create PUBCOMP message |
* |
* |
* @buf = Message buffer |
|
* @msgID = MessageID |
* @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 |
* 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 ***/ |