version 1.2.2.6, 2012/04/24 13:54:50
|
version 1.2.2.9, 2012/05/05 13:39:27
|
Line 2
|
Line 2
|
#define __MQTTD_H |
#define __MQTTD_H |
|
|
|
|
|
#define API_SERVER_SIDE |
|
#include <mqttapi.h> |
|
|
|
|
struct tagStore { |
struct tagStore { |
char st_qos; |
|
u_short st_msgid; |
u_short st_msgid; |
|
|
mqtt_subscr_t st_subscr; |
mqtt_subscr_t st_subscr; |
Line 42 struct tagSession {
|
Line 45 struct tagSession {
|
char *msg; |
char *msg; |
} sess_will; |
} sess_will; |
|
|
/* session scheduler */ |
|
sched_root_task_t *sess_root; |
|
|
|
/* session subscriptions */ |
/* session subscriptions */ |
SLIST_HEAD(tStore, tagStore) sess_subscr; |
SLIST_HEAD(tStore, tagStore) sess_subscr; |
|
|
Line 72 extern pubs_t Pubs;
|
Line 72 extern pubs_t Pubs;
|
extern sched_root_task_t *root; |
extern sched_root_task_t *root; |
extern cfg_root_t cfg; |
extern cfg_root_t cfg; |
extern pthread_mutex_t mtx_sess, mtx_pub; |
extern pthread_mutex_t mtx_sess, mtx_pub; |
|
|
|
|
|
/* function prototypes */ |
|
void finiSession(struct tagSession *sess); |
|
void *startSession(sched_task_t *task); |
|
|
|
|
#endif |
#endif |