--- mqtt/inc/mqttd.h 2012/01/24 10:18:44 1.1.2.6 +++ mqtt/inc/mqttd.h 2012/01/27 16:19:04 1.2.2.1 @@ -8,12 +8,14 @@ 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; + /* server dispatcher */ + mqtt_srv_t *sess_srv; /* client network settings */ int sess_sock; @@ -40,7 +42,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; };