diff options
Diffstat (limited to 'include/linux/ceph/mdsmap.h')
| -rw-r--r-- | include/linux/ceph/mdsmap.h | 62 |
1 files changed, 62 insertions, 0 deletions
diff --git a/include/linux/ceph/mdsmap.h b/include/linux/ceph/mdsmap.h new file mode 100644 index 000000000000..4c5cb0880bba --- /dev/null +++ b/include/linux/ceph/mdsmap.h | |||
| @@ -0,0 +1,62 @@ | |||
| 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 { | ||
| 12 | u64 global_id; | ||
| 13 | struct ceph_entity_addr addr; | ||
| 14 | s32 state; | ||
| 15 | int num_export_targets; | ||
| 16 | bool laggy; | ||
| 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 | |||
| 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 | |||
| 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 | ||
