version 1.3.4.9, 2022/09/14 14:32:48
|
version 1.3.4.10, 2022/09/14 17:37:13
|
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 |