#ifndef __MQTTD_H
#define __MQTTD_H


struct tagStore {
	char				st_qos;
	u_short				st_msgid;

	mqtt_subscr_t			st_subscr;

	SLIST_ENTRY(tagStore)		st_node;
};

struct tagSession {
	/* client session thread id */
	pthread_t			sess_tid;

	/* client network settings */
	int				sess_sock;
	u_short				sess_ka;
	/* client send retry in miliseconds, if client not receive message */
	u_int				sess_retry;
	/* message work buffer */
	mqtt_msg_t			*sess_buf;

	/* authentication user info */
	char				sess_cid[MAX_CONNID];
	char				sess_user[MAX_CRED];
	char				sess_pass[MAX_CRED];
	char				sess_addr[64];

	/* connect flags */
	char				sess_clean;
	struct {
		char			flag;
		char			qos;
		char			retain;
		char			*topic;
		char			*msg;
	} sess_will;

	/* Data Storage by QoS class */
	SLIST_HEAD(qosStore, tagStore)	sess_store[MQTT_QOS_RESERVED];

	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;


#endif