--- mqtt/inc/mqttd.h 2011/12/08 14:52:47 1.1.2.1 +++ mqtt/inc/mqttd.h 2011/12/08 17:02:25 1.1.2.2 @@ -2,5 +2,28 @@ #define __MQTTD_H +struct tagSession { + pthread_t sess_tid; + mqtt_msg_t *sess_buf; + + io_sockaddr_t sess_addr; + struct timeval sess_ka; + + char sess_cid[MAX_CONNID]; + char sess_user[MAX_CRED]; + char sess_pass[MAX_CRED]; + + char clear; + struct { + char flag; + char qos; + char retain; + } sess_will; + + TAILQ_ENTRY(tagSession) sess_node; +}; + +typedef TAILQ_HEAD(, tagSession) sessions_t; + #endif