version 1.3.4.11, 2022/09/14 21:44:21
|
version 1.3.4.12, 2022/09/15 13:50:14
|
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 519 mqtt_msg_t *mqtt_msgUNSUBACK(unsigned short msgID);
|
Line 519 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 612 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); |