|
version 1.1.1.1.2.29, 2011/12/06 10:33:37
|
version 1.2, 2012/01/27 15:05:38
|
|
Line 108 typedef struct {
|
Line 108 typedef struct {
|
| |
|
| typedef unsigned char mqtthdr_protover_t; |
typedef unsigned char mqtthdr_protover_t; |
| |
|
| typedef struct { | typedef union { |
| unsigned char reserved:1, | struct { |
| clean_sess:1, | unsigned char reserved:1, |
| will_flg:1, | clean_sess:1, |
| will_qos:2, | will_flg:1, |
| will_retain:1, | will_qos:2, |
| password:1, | will_retain:1, |
| username:1; | password:1, |
| | username:1; |
| | }; |
| | unsigned char flags; |
| } __packed mqtthdr_connflgs_t; |
} __packed mqtthdr_connflgs_t; |
| |
|
| typedef struct { |
typedef struct { |
|
Line 231 inline mqtt_subscr_t *mqtt_subRealloc(mqtt_subscr_t *
|
Line 234 inline mqtt_subscr_t *mqtt_subRealloc(mqtt_subscr_t *
|
| * |
* |
| * @buf = Message buffer |
* @buf = Message buffer |
| * @csConnID = ConnectID |
* @csConnID = ConnectID |
| |
* @kasec = Keep alive timeout |
| * @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 |
| * @csWillTopic = Will Topic if !=NULL Will Flags set into message |
* @csWillTopic = Will Topic if !=NULL Will Flags set into message |
|
Line 241 inline mqtt_subscr_t *mqtt_subRealloc(mqtt_subscr_t *
|
Line 245 inline mqtt_subscr_t *mqtt_subRealloc(mqtt_subscr_t *
|
| * return: -1 error or >-1 message size for send |
* return: -1 error or >-1 message size for send |
| */ |
*/ |
| int mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const char *csConnID, |
int mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const char *csConnID, |
| const char *csUser, const char *csPass, | unsigned short kasec, const char *csUser, const char *csPass, |
| const char *csWillTopic, const char *csWillMessage, |
const char *csWillTopic, const char *csWillMessage, |
| unsigned char ClrSess, unsigned char WillQOS, unsigned char WillRetain); |
unsigned char ClrSess, unsigned char WillQOS, unsigned char WillRetain); |
| /* |
/* |
|
Line 382 int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi
|
Line 386 int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsi
|
| * @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 | * @psWillTopic = Will Topic if !=NULL Will Flags set into message and must be free() |
| * @topicLen = Will Topic length | * @psWillMessage = Will Message, may be NULL if !NULL must be free() after use! |
| * @psWillMessage = Will Message, may be NULL | |
| * @msgLen = Will Message length | |
| * return: .reserved == 1 is error or == 0 connection flags & msg ok |
* return: .reserved == 1 is error or == 0 connection flags & msg ok |
| */ |
*/ |
| mqtthdr_connflgs_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, int topicLen, char * __restrict psWillMessage, int msgLen); | char ** __restrict psWillTopic, char ** __restrict psWillMessage); |
| /* |
/* |
| * mqtt_readCONNACK() Read CONNACK message |
* mqtt_readCONNACK() Read CONNACK message |
| * |
* |
|
Line 472 u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf);
|
Line 474 u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf);
|
| * return: NULL error or !=NULL MQTT fixed header |
* return: NULL error or !=NULL MQTT fixed header |
| */ |
*/ |
| struct mqtthdr *mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, |
struct mqtthdr *mqtt_readSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, |
| |
mqtt_subscr_t **subscr); |
| |
/* |
| |
* mqtt_readSUBACK() Read SUBACK message |
| |
* |
| |
* @buf = Message buffer |
| |
* @msgID = MessageID |
| |
* @subqos = Subscribes QoS, must be free after use with free() |
| |
* return: -1 error or >-1 readed subscribes QoS elements |
| |
*/ |
| |
int mqtt_readSUBACK(mqtt_msg_t * __restrict buf, u_short *msgID, unsigned char **subqos); |
| |
/* |
| |
* mqtt_readUNSUBSCRIBE() Read UNSUBSCRIBE message |
| |
* |
| |
* @buf = Message buffer |
| |
* @msgID = MessageID |
| |
* @subscr = Subscriptions, must be free after use with mqtt_subFree() |
| |
* return: NULL error or !=NULL MQTT fixed header |
| |
*/ |
| |
struct mqtthdr *mqtt_readUNSUBSCRIBE(mqtt_msg_t * __restrict buf, unsigned short *msgID, |
| mqtt_subscr_t **subscr); |
mqtt_subscr_t **subscr); |
| /* |
/* |
| * mqtt_readUNSUBACK() Read UNSUBACK message |
* mqtt_readUNSUBACK() Read UNSUBACK message |