|
version 1.3.4.11, 2022/09/14 21:44:21
|
version 1.3.4.14, 2022/09/16 04:14:03
|
|
Line 238 typedef struct {
|
Line 238 typedef struct {
|
| /* MQTT structures */ |
/* MQTT structures */ |
| |
|
| typedef struct { |
typedef struct { |
| unsigned char sub_ret; | unsigned char sub_qos; |
| mqtt_msg_t sub_topic; |
mqtt_msg_t sub_topic; |
| mqtt_msg_t sub_value; |
mqtt_msg_t sub_value; |
| } mqtt_subscr_t; |
} mqtt_subscr_t; |
|
Line 472 mqtt_msg_t *mqtt_msgPUBCOMP(unsigned short msgID);
|
Line 472 mqtt_msg_t *mqtt_msgPUBCOMP(unsigned short msgID);
|
| * |
* |
| * @Topics = MQTT subscription topics |
* @Topics = MQTT subscription topics |
| * @msgID = MessageID |
* @msgID = MessageID |
| * @Dup = Duplicate message |
|
| * @QOS = QoS |
|
| * return: NULL error or allocated SUBSCRIBE message |
* return: NULL error or allocated SUBSCRIBE message |
| */ |
*/ |
| mqtt_msg_t *mqtt_msgSUBSCRIBE(mqtt_subscr_t ** __restrict Topics, | mqtt_msg_t *mqtt_msgSUBSCRIBE(mqtt_subscr_t * __restrict Topics, unsigned short msgID); |
| unsigned short msgID, unsigned char Dup, unsigned char QOS); | |
| /* |
/* |
| * mqtt_msgSUBACK() Create SUBACK message |
* mqtt_msgSUBACK() Create SUBACK message |
| * |
* |
|
Line 485 mqtt_msg_t *mqtt_msgSUBSCRIBE(mqtt_subscr_t ** __restr
|
Line 482 mqtt_msg_t *mqtt_msgSUBSCRIBE(mqtt_subscr_t ** __restr
|
| * @msgID = MessageID |
* @msgID = MessageID |
| * return: NULL error or allocated SUBACK message |
* 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 |
* mqtt_msgUNSUBSCRIBE() Create UNSUBSCRIBE message |
| * |
* |
|
Line 495 mqtt_msg_t *mqtt_msgSUBACK(mqtt_subscr_t ** __restrict
|
Line 492 mqtt_msg_t *mqtt_msgSUBACK(mqtt_subscr_t ** __restrict
|
| * @QOS = QoS |
* @QOS = QoS |
| * return: NULL error or allocated UNSUBSCRIBE message |
* 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); |
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
| /* |
/* |
| * mqtt_msgUNSUBACK() Create UNSUBACK message |
* mqtt_msgUNSUBACK() Create UNSUBACK message |
|
Line 519 mqtt_msg_t *mqtt_msgUNSUBACK(unsigned short msgID);
|
Line 516 mqtt_msg_t *mqtt_msgUNSUBACK(unsigned short msgID);
|
| * @userLen = Username length |
* @userLen = Username length |
| * @psPass = Password for Username, only if csUser is set |
* @psPass = Password for Username, only if csUser is set |
| * @passLen = Password length |
* @passLen = Password length |
| * @psWillTopic = Will Topic if !=NULL Will Flags set into message and must be free() | * @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 free() after use! | * @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 |
* return: .reserved == 1 is error or == 0 connection flags & msg ok |
| */ |
*/ |
| mqtthdr_connack_t mqtt_readCONNECT(mqtt_msg_t * __restrict buf, unsigned short *KASec, |
mqtthdr_connack_t mqtt_readCONNECT(mqtt_msg_t * __restrict buf, unsigned short *KASec, |
|
Line 612 int mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, un
|
Line 609 int mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, un
|
| * |
* |
| * @buf = Message buffer |
* @buf = Message buffer |
| * @msgID = MessageID |
* @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 |
* return: -1 error or >-1 readed subscribes QoS elements |
| */ |
*/ |
| int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, unsigned short *msgID, unsigned char **subqos); |
int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, unsigned short *msgID, unsigned char **subqos); |