version 1.1.1.1.2.16, 2011/11/22 13:03:25
|
version 1.1.1.1.2.17, 2011/11/22 14:00:09
|
Line 10
|
Line 10
|
/* FIXED HEADER */ |
/* FIXED HEADER */ |
|
|
struct mqtthdr { |
struct mqtthdr { |
struct { | union { |
unsigned char retain:1, | struct { |
qos:2, | unsigned char retain:1, |
dup:1, | qos:2, |
type:4; | dup:1, |
| type:4; |
| }; |
| unsigned char val; |
} mqtt_msg; |
} mqtt_msg; |
unsigned char mqtt_len[1]; /* may be grow to 4 bytes */ |
unsigned char mqtt_len[1]; /* may be grow to 4 bytes */ |
} __packed; |
} __packed; |
|
#define MQTTHDR_MSGINIT(x) (assert((x)), (x)->mqtt_msg.val ^= (x)->mqtt_msg.val) |
|
|
#define MQTT_TYPE_UNKNOWN 0 /* reserved */ |
#define MQTT_TYPE_UNKNOWN 0 /* reserved */ |
#define MQTT_TYPE_CONNECT 1 /* client request to connect to server */ |
#define MQTT_TYPE_CONNECT 1 /* client request to connect to server */ |
Line 311 mqtt_msgSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_su
|
Line 315 mqtt_msgSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_su
|
*/ |
*/ |
int mqtt_msgSUBACK(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, |
int mqtt_msgSUBACK(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, |
unsigned short msgID); |
unsigned short msgID); |
|
/* |
|
* mqtt_msgUNSUBSCRIBE() Create UNSUBSCRIBE message |
|
* |
|
* @buf = Message buffer |
|
* @Topics = MQTT subscription topics |
|
* @msgID = MessageID |
|
* @Dup = Duplicate message |
|
* @QOS = QoS |
|
* return: -1 error or >-1 message size for send |
|
*/ |
|
int |
|
mqtt_msgUNSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_subscr_t * __restrict Topics, |
|
unsigned short msgID, unsigned char Dup, unsigned char QOS); |
|
/* |
|
* mqtt_msgUNSUBACK() Create UNSUBACK message |
|
* |
|
* @buf = Message buffer |
|
* @msgID = MessageID |
|
* return: -1 error or >-1 message size for send |
|
*/ |
|
int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsigned short msgID); |
|
|
|
|
#endif |
#endif |