version 1.1.1.1.2.19, 2011/11/22 14:19:48
|
version 1.1.1.1.2.20, 2011/11/22 14:48:25
|
Line 114 typedef struct {
|
Line 114 typedef struct {
|
unsigned short msg_len; |
unsigned short msg_len; |
} mqtt_msg_t; |
} mqtt_msg_t; |
|
|
|
/* MQTT dispatcher callbacks */ |
|
|
|
typedef int (*mqtt_cb_t)(void *); |
|
|
|
|
// ------------------------------------------------------- |
// ------------------------------------------------------- |
// mqtt_GetErrno() Get error code of last operation |
// mqtt_GetErrno() Get error code of last operation |
inline int mqtt_GetErrno(); |
inline int mqtt_GetErrno(); |
Line 194 inline void mqtt_subFree(mqtt_subscr_t ** __restrict s
|
Line 198 inline void mqtt_subFree(mqtt_subscr_t ** __restrict s
|
*/ |
*/ |
inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num); |
inline mqtt_subscr_t *mqtt_subAlloc(unsigned short num); |
|
|
|
|
|
/*** SENDER FUNCTIONS ***/ |
|
|
/* |
/* |
* mqtt_msgCONNECT() Create CONNECT message |
* mqtt_msgCONNECT() Create CONNECT message |
* |
* |
Line 335 mqtt_msgUNSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_
|
Line 342 mqtt_msgUNSUBSCRIBE(mqtt_msg_t * __restrict buf, mqtt_
|
* return: -1 error or >-1 message size for send |
* return: -1 error or >-1 message size for send |
*/ |
*/ |
int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsigned short msgID); |
int mqtt_msgUNSUBACK(mqtt_msg_t * __restrict buf, unsigned short msgID); |
|
|
|
|
|
/*** RECEIVER FUNCTIONS ***/ |
|
|
|
/* |
|
* mqttInitCallbacks() Init callback array for dispatcher |
|
* |
|
* return: NULL error or !=NULL allocated callback array, after use free with mqttFiniCallbacks() |
|
*/ |
|
mqtt_cb_t *mqttInitCallbacks(void); |
|
/* |
|
* mqttFiniCallbacks() Free callback array |
|
* |
|
* @cb = Callback array |
|
* return: none |
|
*/ |
|
void mqttFiniCallbacks(mqtt_cb_t ** __restrict cb); |
|
|
|
|
#endif |
#endif |