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 ***/ |
|
|