version 1.1.2.4, 2011/11/22 14:00:09
|
version 1.1.2.5, 2011/11/22 14:13:04
|
Line 179 mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, u_char re
|
Line 179 mqtt_msgCONNACK(mqtt_msg_t * __restrict buf, u_char re
|
|
|
return siz; |
return siz; |
} |
} |
|
|
|
static int |
|
_mqtt_msgSIMPLE_(mqtt_msg_t * __restrict buf, u_char cmd) |
|
{ |
|
int siz = 0; |
|
struct mqtthdr *hdr; |
|
|
|
if (!buf) |
|
return -1; |
|
|
|
if (mqtt_msgRealloc(buf, sizeof(struct mqtthdr)) == -1) |
|
return -1; |
|
else { |
|
hdr = (struct mqtthdr *) (buf->msg_base + siz); |
|
siz += sizeof(struct mqtthdr); |
|
} |
|
|
|
/* fixed header */ |
|
MQTTHDR_MSGINIT(hdr); |
|
hdr->mqtt_msg.type = cmd; |
|
*hdr->mqtt_len = 0; |
|
|
|
return siz; |
|
} |
|
|
|
/* |
|
* 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) |
|
{ |
|
return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_PINGREQ); |
|
} |
|
|
|
/* |
|
* 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) |
|
{ |
|
return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_PINGRESP); |
|
} |
|
|
|
/* |
|
* 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) |
|
{ |
|
return _mqtt_msgSIMPLE_(buf, MQTT_TYPE_DISCONNECT); |
|
} |