|
version 1.2.2.3, 2012/04/11 15:08:26
|
version 1.2.2.4, 2012/04/11 16:37:16
|
|
Line 8 struct tagStore {
|
Line 8 struct tagStore {
|
| |
|
| mqtt_subscr_t st_subscr; |
mqtt_subscr_t st_subscr; |
| |
|
| TAILQ_ENTRY(tagStore) st_node; | SLIST_ENTRY(tagStore) st_node; |
| }; |
}; |
| |
|
| struct tagSession { |
struct tagSession { |
|
Line 43 struct tagSession {
|
Line 43 struct tagSession {
|
| } sess_will; |
} sess_will; |
| |
|
| /* Data Storage by QoS class */ |
/* Data Storage by QoS class */ |
| TAILQ_HEAD(qosStore, tagStore) sess_sndqueue; | SLIST_HEAD(tStore, tagStore) sess_txque[3]; |
| |
| TAILQ_ENTRY(tagSession) sess_node; |
TAILQ_ENTRY(tagSession) sess_node; |
| }; |
}; |
| typedef TAILQ_HEAD(, tagSession) sessions_t; |
typedef TAILQ_HEAD(, tagSession) sessions_t; |
| |
#define SESS_ELEM_LOCK(x) pthread_mutex_lock(&(x)->sess_mtx) |
| |
#define SESS_ELEM_UNLOCK(x) pthread_mutex_unlock(&(x)->sess_mtx) |
| |
|
| |
|
| extern sessions_t Sessions; |
extern sessions_t Sessions; |
| 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; |
| |
#define SESS_LOCK pthread_mutex_lock(&mtx_sess) |
| |
#define SESS_UNLOCK pthread_mutex_unlock(&mtx_sess) |
| |
#define PUB_LOCK pthread_mutex_lock(&mtx_pub) |
| |
#define PUB_UNLOCK pthread_mutex_unlock(&mtx_pub) |
| |
|
| |
|
| #endif |
#endif |
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mqttd.h CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / inc