|
|
| version 1.1.1.1.2.24, 2011/12/05 14:11:47 | version 1.1.1.1.2.27, 2011/12/05 22:17:39 |
|---|---|
| Line 384 mqtthdr_connflgs_t mqtt_readCONNECT(mqtt_msg_t * __res | Line 384 mqtthdr_connflgs_t mqtt_readCONNECT(mqtt_msg_t * __res |
| 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, int topicLen, char * __restrict psWillMessage, int msgLen); |
| /* | |
| * mqtt_readCONNACK() Read CONNACK message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error or >-1 CONNECT message return code | |
| */ | |
| unsigned char mqtt_readCONNACK(mqtt_msg_t * __restrict buf); | |
| /* | |
| * mqtt_readDISCONNECT() Read DISCONNECT message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error, 0 ok, >0 undefined result | |
| */ | |
| int mqtt_readDISCONNECT(mqtt_msg_t * __restrict buf); | |
| /* | |
| * mqtt_readPINGREQ() Read PINGREQ message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error, 0 ok, >0 undefined result | |
| */ | |
| int mqtt_readPINGREQ(mqtt_msg_t * __restrict buf); | |
| /* | |
| * mqtt_readPINGRESP() Read PINGRESP message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error, 0 ok, >0 undefined result | |
| */ | |
| int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf); | |
| /* | |
| * mqtt_readPUBACK() Read PUBACK message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error or MessageID | |
| */ | |
| u_short mqtt_readPUBACK(mqtt_msg_t * __restrict buf); | |
| /* | |
| * mqtt_readPUBREC() Read PUBREC message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error or MessageID | |
| */ | |
| u_short mqtt_readPUBREC(mqtt_msg_t * __restrict buf); | |
| /* | |
| * mqtt_readPUBREL() Read PUBREL message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error or MessageID | |
| */ | |
| u_short mqtt_readPUBREL(mqtt_msg_t * __restrict buf); | |
| /* | |
| * mqtt_readPUBCOMP() Read PUBCOMP message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error or MessageID | |
| */ | |
| u_short mqtt_readPUBCOMP(mqtt_msg_t * __restrict buf); | |
| /* | |
| * mqtt_readUNSUBACK() Read UNSUBACK message | |
| * | |
| * @buf = Message buffer | |
| * return: -1 error or MessageID | |
| */ | |
| u_short mqtt_readUNSUBACK(mqtt_msg_t * __restrict buf); | |
| /*** ENGINE FUNCTIONS ***/ | /*** ENGINE FUNCTIONS ***/ |