[net-next-2.6.git] / fs / ceph / mdsmap.h

#ifndef _FS_CEPH_MDSMAP_H
#define _FS_CEPH_MDSMAP_H

#include "types.h"

/*
 * mds map - describe servers in the mds cluster.
 *
 * we limit fields to those the client actually xcares about
 */
struct ceph_mds_info {
	u64 global_id;
	struct ceph_entity_addr addr;
	s32 state;
	int num_export_targets;
	bool laggy;
	u32 *export_targets;
};

struct ceph_mdsmap {
	u32 m_epoch, m_client_epoch, m_last_failure;
	u32 m_root;
	u32 m_session_timeout;          /* seconds */
	u32 m_session_autoclose;        /* seconds */
	u64 m_max_file_size;
	u32 m_max_mds;                  /* size of m_addr, m_state arrays */
	struct ceph_mds_info *m_info;

	/* which object pools file data can be stored in */
	int m_num_data_pg_pools;
	u32 *m_data_pg_pools;
	u32 m_cas_pg_pool;
};

static inline struct ceph_entity_addr *
ceph_mdsmap_get_addr(struct ceph_mdsmap *m, int w)
{
	if (w >= m->m_max_mds)
		return NULL;
	return &m->m_info[w].addr;
}

static inline int ceph_mdsmap_get_state(struct ceph_mdsmap *m, int w)
{
	BUG_ON(w < 0);
	if (w >= m->m_max_mds)
		return CEPH_MDS_STATE_DNE;
	return m->m_info[w].state;
}

static inline bool ceph_mdsmap_is_laggy(struct ceph_mdsmap *m, int w)
{
	if (w >= 0 && w < m->m_max_mds)
		return m->m_info[w].laggy;
	return false;
}

extern int ceph_mdsmap_get_random_mds(struct ceph_mdsmap *m);
extern struct ceph_mdsmap *ceph_mdsmap_decode(void **p, void *end);
extern void ceph_mdsmap_destroy(struct ceph_mdsmap *m);

#endif
Commit	Line	Data
2f2dc053 SW	1	#ifndef _FS_CEPH_MDSMAP_H
	2	#define _FS_CEPH_MDSMAP_H
	3
	4	#include "types.h"
	5
	6	/*
	7	* mds map - describe servers in the mds cluster.
	8	*
	9	* we limit fields to those the client actually xcares about
	10	*/
	11	struct ceph_mds_info {
94045e11	12	u64 global_id;
2f2dc053 SW	13	struct ceph_entity_addr addr;
	14	s32 state;
	15	int num_export_targets;
0deb01c9	16	bool laggy;
2f2dc053 SW	17	u32 *export_targets;
	18	};
	19
	20	struct ceph_mdsmap {
	21	u32 m_epoch, m_client_epoch, m_last_failure;
	22	u32 m_root;
	23	u32 m_session_timeout; /* seconds */
	24	u32 m_session_autoclose; /* seconds */
	25	u64 m_max_file_size;
	26	u32 m_max_mds; /* size of m_addr, m_state arrays */
	27	struct ceph_mds_info *m_info;
	28
	29	/* which object pools file data can be stored in */
	30	int m_num_data_pg_pools;
	31	u32 *m_data_pg_pools;
	32	u32 m_cas_pg_pool;
	33	};
	34
	35	static inline struct ceph_entity_addr *
	36	ceph_mdsmap_get_addr(struct ceph_mdsmap *m, int w)
	37	{
	38	if (w >= m->m_max_mds)
	39	return NULL;
	40	return &m->m_info[w].addr;
	41	}
	42
	43	static inline int ceph_mdsmap_get_state(struct ceph_mdsmap *m, int w)
	44	{
	45	BUG_ON(w < 0);
	46	if (w >= m->m_max_mds)
	47	return CEPH_MDS_STATE_DNE;
	48	return m->m_info[w].state;
	49	}
	50
0deb01c9 SW	51	static inline bool ceph_mdsmap_is_laggy(struct ceph_mdsmap *m, int w)
	52	{
	53	if (w >= 0 && w < m->m_max_mds)
	54	return m->m_info[w].laggy;
	55	return false;
	56	}
	57
2f2dc053 SW	58	extern int ceph_mdsmap_get_random_mds(struct ceph_mdsmap *m);
	59	extern struct ceph_mdsmap ceph_mdsmap_decode(void p, void end);
	60	extern void ceph_mdsmap_destroy(struct ceph_mdsmap *m);
	61
	62	#endif