version 1.2, 2012/06/20 15:02:24
|
version 1.3, 2012/06/28 11:06:17
|
Line 68 mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha
|
Line 68 mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha
|
u_char ClrSess, u_char WillQOS, u_char WillRetain) |
u_char ClrSess, u_char WillQOS, u_char WillRetain) |
{ |
{ |
int len, siz = 0; |
int len, siz = 0; |
u_int n; | u_int n, *l; |
struct mqtthdr *hdr; |
struct mqtthdr *hdr; |
mqtthdr_var_t *var, *cid, *topic, *wmsg, *user, *pass; |
mqtthdr_var_t *var, *cid, *topic, *wmsg, *user, *pass; |
mqtthdr_protover_t *proto; |
mqtthdr_protover_t *proto; |
Line 123 mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha
|
Line 123 mqtt_msgCONNECT(mqtt_msg_t * __restrict buf, const cha
|
/* fixed header */ |
/* fixed header */ |
MQTTHDR_MSGINIT(hdr); |
MQTTHDR_MSGINIT(hdr); |
hdr->mqtt_msg.type = MQTT_TYPE_CONNECT; |
hdr->mqtt_msg.type = MQTT_TYPE_CONNECT; |
*(u_int*) hdr->mqtt_len = n; | l = (u_int*) hdr->mqtt_len; |
| *l = n; |
data += siz; |
data += siz; |
|
|
/* variable header */ |
/* variable header */ |