--- mqtt/inc/mqttd.h 2011/12/08 17:02:25 1.1.2.2 +++ mqtt/inc/mqttd.h 2011/12/09 09:53:54 1.1.2.3 @@ -6,6 +6,7 @@ struct tagSession { pthread_t sess_tid; mqtt_msg_t *sess_buf; + int sess_sock; io_sockaddr_t sess_addr; struct timeval sess_ka; @@ -18,12 +19,17 @@ struct tagSession { char flag; char qos; char retain; + char *topic; + char *msg; } sess_will; TAILQ_ENTRY(tagSession) sess_node; }; typedef TAILQ_HEAD(, tagSession) sessions_t; + + +extern sessions_t Sessions; #endif