--- mqtt/inc/mqttd.h 2011/12/09 13:43:55 1.1.2.4 +++ mqtt/inc/mqttd.h 2012/01/25 10:34:14 1.1.2.7 @@ -8,7 +8,7 @@ struct tagStore { mqtt_subscr_t st_subscr; - SLIST_ENTRY(tagStore) st_node; + TAILQ_ENTRY(tagStore) st_node; }; struct tagSession { @@ -40,17 +40,17 @@ struct tagSession { } sess_will; /* Data Storage by QoS class */ - SLIST_HEAD(qosStore, tagStore) sess_store[MQTT_QOS_RESERVED]; + TAILQ_HEAD(qosStore, tagStore) sess_sndqueue; TAILQ_ENTRY(tagSession) sess_node; }; - typedef TAILQ_HEAD(, tagSession) sessions_t; extern sessions_t Sessions; extern sched_root_task_t *root; extern sl_config cfg; +extern pthread_mutex_t mtx_sess, mtx_pub; #endif