|
version 1.3.4.8, 2022/09/13 22:20:59
|
version 1.3.4.9, 2022/09/14 14:32:48
|
|
Line 382 mqtt_subscr_t *mqtt_subCopy(mqtt_subscr_t * __restrict
|
Line 382 mqtt_subscr_t *mqtt_subCopy(mqtt_subscr_t * __restrict
|
| * mqtt_msgCONNECT() Create CONNECT message |
* mqtt_msgCONNECT() Create CONNECT message |
| * |
* |
| * @csConnID = ConnectID |
* @csConnID = ConnectID |
| * @Version = MQTT version | * @Version = MQTT version, if =0 default version is 3.1.1 |
| * @KASec = Keep alive timeout, if =0 default timeout for MQTT |
* @KASec = Keep alive timeout, if =0 default timeout for MQTT |
| * @csUser = Username if !=NULL |
* @csUser = Username if !=NULL |
| * @csPass = Password for Username, only if csUser is set |
* @csPass = Password for Username, only if csUser is set |
|
Line 391 mqtt_subscr_t *mqtt_subCopy(mqtt_subscr_t * __restrict
|
Line 391 mqtt_subscr_t *mqtt_subCopy(mqtt_subscr_t * __restrict
|
| * @ClrSess = Clear Session subscriptions after disconnect |
* @ClrSess = Clear Session subscriptions after disconnect |
| * @WillQOS = Will QOS if csWillTopic is set |
* @WillQOS = Will QOS if csWillTopic is set |
| * @WillRetain = Will Retain Will Message if csWillTopic is set |
* @WillRetain = Will Retain Will Message if csWillTopic is set |
| * return: NULL error or allocated connect message | * return: NULL error or allocated CONNECT message |
| */ |
*/ |
| mqtt_msg_t *mqtt_msgCONNECT(const char *csConnID, unsigned char Version, |
mqtt_msg_t *mqtt_msgCONNECT(const char *csConnID, unsigned char Version, |
| unsigned short KASec, const char *csUser, const char *csPass, |
unsigned short KASec, const char *csUser, const char *csPass, |
|
Line 400 mqtt_msg_t *mqtt_msgCONNECT(const char *csConnID, unsi
|
Line 400 mqtt_msg_t *mqtt_msgCONNECT(const char *csConnID, unsi
|
| /* |
/* |
| * mqtt_msgCONNACK() Create CONNACK message |
* mqtt_msgCONNACK() Create CONNACK message |
| * |
* |
| * @buf = Message buffer |
|
| * @retcode = Return code |
* @retcode = Return code |
| * return: -1 error or >-1 message size for send | * return: NULL error or allocated CONNACK message |
| */ |
*/ |
| int mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, unsigned char retcode); | mqtt_msg_t *mqtt_msgCONNACK(unsigned char retcode); |
| /* |
/* |
| * mqtt_msgDISCONNECT() Create DISCONNECT message |
* mqtt_msgDISCONNECT() Create DISCONNECT message |
| * |
* |
| * @buf = Message buffer | * return: NULL error or allocated message |
| * return: -1 error or >-1 message size for send | |
| */ |
*/ |
| int mqtt_msgDISCONNECT(mqtt_msg_t * __restrict buf); | mqtt_msg_t *mqtt_msgDISCONNECT(); |
| /* |
/* |
| * mqtt_msgPINGREQ() Create PINGREQ message |
* mqtt_msgPINGREQ() Create PINGREQ message |
| * |
* |
| * @buf = Message buffer | * return: NULL error or allocated message |
| * return: -1 error or >-1 message size for send | |
| */ |
*/ |
| int mqtt_msgPINGREQ(mqtt_msg_t * __restrict buf); | mqtt_msg_t *mqtt_msgPINGREQ(); |
| /* |
/* |
| * mqtt_msgPINGRESP() Create PINGRESP message |
* mqtt_msgPINGRESP() Create PINGRESP message |
| * |
* |
| * @buf = Message buffer | * return: NULL error or allocated message |
| * return: -1 error or >-1 message size for send | |
| */ |
*/ |
| int mqtt_msgPINGRESP(mqtt_msg_t * __restrict buf); | mqtt_msg_t *mqtt_msgPINGRESP(); |
| |
|
| /* |
/* |
| * mqtt_msgPUBLISH() Create PUBLISH message |
* mqtt_msgPUBLISH() Create PUBLISH message |
|
Line 528 int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi
|
Line 524 int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi
|
| * mqtt_readCONNECT() Read elements from CONNECT message |
* mqtt_readCONNECT() Read elements from CONNECT message |
| * |
* |
| * @buf = Message buffer |
* @buf = Message buffer |
| * @kasec = Keep Alive in seconds for current connection | * @KASec = Keep Alive in seconds for current connection |
| * @psConnID = ConnectID |
* @psConnID = ConnectID |
| * @connLen = ConnectID length |
* @connLen = ConnectID length |
| * @psUser = Username if !=NULL |
* @psUser = Username if !=NULL |
|
Line 539 int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi
|
Line 535 int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi
|
| * @psWillMessage = Will Message, may be NULL if !NULL must be free() after use! |
* @psWillMessage = Will Message, may be NULL if !NULL must be 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, |
| char * __restrict psConnID, int connLen, |
char * __restrict psConnID, int connLen, |
| char * __restrict psUser, int userLen, char * __restrict psPass, int passLen, |
char * __restrict psUser, int userLen, char * __restrict psPass, int passLen, |
| char ** __restrict psWillTopic, char ** __restrict psWillMessage); |
char ** __restrict psWillTopic, char ** __restrict psWillMessage); |