version 1.1.1.1.2.27, 2011/12/05 22:17:39
|
version 1.1.1.1.2.28, 2011/12/06 09:04:55
|
Line 279 int mqtt_msgPINGRESP(mqtt_msg_t * __restrict buf);
|
Line 279 int mqtt_msgPINGRESP(mqtt_msg_t * __restrict buf);
|
* @datlen = Publish data length |
* @datlen = Publish data length |
* return: -1 error or >-1 message size for send |
* return: -1 error or >-1 message size for send |
*/ |
*/ |
int mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const char *csTopic, unsigned short msgID, | int mqtt_msgPUBLISH(mqtt_msg_t * __restrict buf, const char *csTopic, |
unsigned char Dup, unsigned char QOS, unsigned char Retain, | unsigned short msgID, unsigned char Dup, unsigned char QOS, |
const void *pData, unsigned short datlen); | unsigned char Retain, const void *pData, int datlen); |
/* |
/* |
* mqtt_msgPUBACK() Create PUBACK message |
* mqtt_msgPUBACK() Create PUBACK message |
* |
* |
Line 413 int mqtt_readPINGREQ(mqtt_msg_t * __restrict buf);
|
Line 413 int mqtt_readPINGREQ(mqtt_msg_t * __restrict buf);
|
*/ |
*/ |
int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf); |
int mqtt_readPINGRESP(mqtt_msg_t * __restrict buf); |
|
|
|
/* |
|
* mqtt_readPUBLISH() Read PUBLISH message |
|
* |
|
* @buf = Message buffer |
|
* @psTopic = Topic |
|
* @topicLen = Topic length |
|
* @msgID = MessageID |
|
* @pData = Data buffer |
|
* @datLen = Data buffer length, if *datLen == 0 allocate memory for pData |
|
* return: NULL error or !=NULL MQTT fixed header |
|
*/ |
|
struct mqtthdr *mqtt_readPUBLISH(mqtt_msg_t * __restrict buf, char * __restrict psTopic, |
|
int topicLen, unsigned short *msgID, void * __restrict pData, int *datLen); |
/* |
/* |
* mqtt_readPUBACK() Read PUBACK message |
* mqtt_readPUBACK() Read PUBACK message |
* |
* |