--- mqtt/inc/mqttd.h	2012/01/24 10:18:44	1.1.2.6
+++ mqtt/inc/mqttd.h	2012/01/30 13:39:22	1.2.2.2
@@ -8,12 +8,15 @@ struct tagStore {
 
 	mqtt_subscr_t			st_subscr;
 
-	SLIST_ENTRY(tagStore)		st_node;
+	TAILQ_ENTRY(tagStore)		st_node;
 };
 
 struct tagSession {
 	/* client session thread id */
 	pthread_t			sess_tid;
+	pthread_mutex_t			sess_mtx;
+	/* server dispatcher */
+	mqtt_srv_t			*sess_srv;
 
 	/* client network settings */
 	int				sess_sock;
@@ -40,7 +43,7 @@ struct tagSession {
 	} sess_will;
 
 	/* Data Storage by QoS class */
-	SLIST_HEAD(qosStore, tagStore)	sess_sndqueue;
+	TAILQ_HEAD(qosStore, tagStore)	sess_sndqueue;
 
 	TAILQ_ENTRY(tagSession)		sess_node;
 };