version 1.1.1.1.2.17, 2011/11/22 14:00:09
|
version 1.1.1.1.2.19, 2011/11/22 14:19:48
|
Line 2
|
Line 2
|
#define __AITMQTT_H |
#define __AITMQTT_H |
|
|
|
|
#define MQTT_DATA_MAX 268435455 |
|
#define MQTT_CONN_STR "MQIsdp" |
|
#define MQTT_PROTO_VER 3 |
|
#define MQTT_KEEPALIVE 10 |
|
|
|
/* FIXED HEADER */ |
/* FIXED HEADER */ |
|
|
struct mqtthdr { |
struct mqtthdr { |
Line 17 struct mqtthdr {
|
Line 12 struct mqtthdr {
|
dup:1, |
dup:1, |
type:4; |
type:4; |
}; |
}; |
unsigned char val; | 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 MQTTHDR_MSGINIT(x) (assert((x)), (x)->mqtt_msg.val ^= (x)->mqtt_msg.val) |
|
|
#define MQTT_TYPE_UNKNOWN 0 /* reserved */ |
|
#define MQTT_TYPE_CONNECT 1 /* client request to connect to server */ |
|
#define MQTT_TYPE_CONNACK 2 /* connect acknowledgment */ |
|
#define MQTT_TYPE_PUBLISH 3 /* publish message */ |
|
#define MQTT_TYPE_PUBACK 4 /* publish acknowledgment */ |
|
#define MQTT_TYPE_PUBREC 5 /* publish received (assured delivery part 1) */ |
|
#define MQTT_TYPE_PUBREL 6 /* publish release (assured delivery part 2) */ |
|
#define MQTT_TYPE_PUBCOMP 7 /* publish complete (assured delivery part 3) */ |
|
#define MQTT_TYPE_SUBSCRIBE 8 /* client subscribe request */ |
|
#define MQTT_TYPE_SUBACK 9 /* subscribe acknowledgment */ |
|
#define MQTT_TYPE_UNSUBSCRIBE 10 /* client unsubscribe request */ |
|
#define MQTT_TYPE_UNSUBACK 11 /* unsubscribe acknowledgment */ |
|
#define MQTT_TYPE_PINGREQ 12 /* PING request */ |
|
#define MQTT_TYPE_PINGRESP 13 /* PING response */ |
|
#define MQTT_TYPE_DISCONNECT 14 /* client is disconnecting */ |
|
#define MQTT_TYPE_RESERVED 15 /* reserved */ |
|
|
|
#define MQTT_FLAG_DUP 1 /* This flag is set when the client or server attempts to re-deliver |
#define MQTT_FLAG_DUP 1 /* This flag is set when the client or server attempts to re-deliver |
a PUBLISH, PUBREL, SUBSCRIBE or UNSUBSCRIBE message. |
a PUBLISH, PUBREL, SUBSCRIBE or UNSUBSCRIBE message. |
This applies to messages where the value of QoS is greater than |
This applies to messages where the value of QoS is greater than |
Line 242 int mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const
|
Line 220 int mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const
|
* return: -1 error or >-1 message size for send |
* return: -1 error or >-1 message size for send |
*/ |
*/ |
int mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, unsigned char retcode); |
int mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, unsigned char retcode); |
|
/* |
|
* mqtt_msgDISCONNECT() Create DISCONNECT message |
|
* |
|
* @buf = Message buffer |
|
* return: -1 error or >-1 message size for send |
|
*/ |
|
int mqtt_msgDISCONNECT(mqtt_msg_t * __restrict buf); |
|
/* |
|
* mqtt_msgPINGREQ() Create PINGREQ message |
|
* |
|
* @buf = Message buffer |
|
* return: -1 error or >-1 message size for send |
|
*/ |
|
int mqtt_msgPINGREQ(mqtt_msg_t * __restrict buf); |
|
/* |
|
* mqtt_msgPINGRESP() Create PINGRESP message |
|
* |
|
* @buf = Message buffer |
|
* return: -1 error or >-1 message size for send |
|
*/ |
|
int mqtt_msgPINGRESP(mqtt_msg_t * __restrict buf); |
|
|
/* |
/* |
* mqtt_msgPUBLISH() Create PUBLISH message |
* mqtt_msgPUBLISH() Create PUBLISH message |