Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 1 | #ifndef _FS_CEPH_OSDMAP_H |
| 2 | #define _FS_CEPH_OSDMAP_H |
| 3 | |
| 4 | #include <linux/rbtree.h> |
David Howells | a1ce392 | 2012-10-02 18:01:25 +0100 | [diff] [blame] | 5 | #include <linux/ceph/types.h> |
Alex Elder | ef4859d | 2013-04-01 18:58:26 -0500 | [diff] [blame] | 6 | #include <linux/ceph/decode.h> |
David Howells | a1ce392 | 2012-10-02 18:01:25 +0100 | [diff] [blame] | 7 | #include <linux/ceph/ceph_fs.h> |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 8 | #include <linux/crush/crush.h> |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 9 | |
| 10 | /* |
| 11 | * The osd map describes the current membership of the osd cluster and |
| 12 | * specifies the mapping of objects to placement groups and placement |
| 13 | * groups to (sets of) osds. That is, it completely specifies the |
| 14 | * (desired) distribution of all data objects in the system at some |
| 15 | * point in time. |
| 16 | * |
| 17 | * Each map version is identified by an epoch, which increases monotonically. |
| 18 | * |
| 19 | * The map can be updated either via an incremental map (diff) describing |
| 20 | * the change between two successive epochs, or as a fully encoded map. |
| 21 | */ |
Sage Weil | 5b191d9 | 2013-02-23 10:38:16 -0800 | [diff] [blame] | 22 | struct ceph_pg { |
| 23 | uint64_t pool; |
| 24 | uint32_t seed; |
| 25 | }; |
| 26 | |
Sage Weil | 83ca14f | 2013-02-26 10:39:09 -0800 | [diff] [blame] | 27 | #define CEPH_POOL_FLAG_HASHPSPOOL 1 |
| 28 | |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 29 | struct ceph_pg_pool_info { |
Sage Weil | 4fc51be | 2010-02-16 15:55:03 -0800 | [diff] [blame] | 30 | struct rb_node node; |
Sage Weil | 4f6a7e5 | 2013-02-23 10:41:09 -0800 | [diff] [blame] | 31 | s64 id; |
| 32 | u8 type; |
| 33 | u8 size; |
| 34 | u8 crush_ruleset; |
| 35 | u8 object_hash; |
| 36 | u32 pg_num, pgp_num; |
| 37 | int pg_num_mask, pgp_num_mask; |
Ilya Dryomov | 17a13e40 | 2014-01-27 17:40:19 +0200 | [diff] [blame^] | 38 | s64 read_tier; |
| 39 | s64 write_tier; /* wins for read+write ops */ |
Sage Weil | 4f6a7e5 | 2013-02-23 10:41:09 -0800 | [diff] [blame] | 40 | u64 flags; |
Sage Weil | 2844a76 | 2010-04-09 15:46:42 -0700 | [diff] [blame] | 41 | char *name; |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 42 | }; |
| 43 | |
Sage Weil | 4f6a7e5 | 2013-02-23 10:41:09 -0800 | [diff] [blame] | 44 | struct ceph_object_locator { |
Ilya Dryomov | 22116525 | 2014-01-27 17:40:18 +0200 | [diff] [blame] | 45 | s64 pool; |
Sage Weil | 4f6a7e5 | 2013-02-23 10:41:09 -0800 | [diff] [blame] | 46 | }; |
| 47 | |
Ilya Dryomov | 4295f22 | 2014-01-27 17:40:18 +0200 | [diff] [blame] | 48 | /* |
| 49 | * Maximum supported by kernel client object name length |
| 50 | * |
| 51 | * (probably outdated: must be >= RBD_MAX_MD_NAME_LEN -- currently 100) |
| 52 | */ |
| 53 | #define CEPH_MAX_OID_NAME_LEN 100 |
| 54 | |
| 55 | struct ceph_object_id { |
| 56 | char name[CEPH_MAX_OID_NAME_LEN]; |
| 57 | int name_len; |
| 58 | }; |
| 59 | |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 60 | struct ceph_pg_mapping { |
| 61 | struct rb_node node; |
Sage Weil | 5b191d9 | 2013-02-23 10:38:16 -0800 | [diff] [blame] | 62 | struct ceph_pg pgid; |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 63 | int len; |
| 64 | int osds[]; |
| 65 | }; |
| 66 | |
| 67 | struct ceph_osdmap { |
| 68 | struct ceph_fsid fsid; |
| 69 | u32 epoch; |
| 70 | u32 mkfs_epoch; |
| 71 | struct ceph_timespec created, modified; |
| 72 | |
| 73 | u32 flags; /* CEPH_OSDMAP_* */ |
| 74 | |
| 75 | u32 max_osd; /* size of osd_state, _offload, _addr arrays */ |
| 76 | u8 *osd_state; /* CEPH_OSD_* */ |
| 77 | u32 *osd_weight; /* 0 = failed, 0x10000 = 100% normal */ |
| 78 | struct ceph_entity_addr *osd_addr; |
| 79 | |
| 80 | struct rb_root pg_temp; |
Sage Weil | 4fc51be | 2010-02-16 15:55:03 -0800 | [diff] [blame] | 81 | struct rb_root pg_pools; |
| 82 | u32 pool_max; |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 83 | |
| 84 | /* the CRUSH map specifies the mapping of placement groups to |
| 85 | * the list of osds that store+replicate them. */ |
| 86 | struct crush_map *crush; |
| 87 | }; |
| 88 | |
Ilya Dryomov | 4295f22 | 2014-01-27 17:40:18 +0200 | [diff] [blame] | 89 | static inline void ceph_oid_set_name(struct ceph_object_id *oid, |
| 90 | const char *name) |
| 91 | { |
| 92 | int len; |
| 93 | |
| 94 | len = strlen(name); |
| 95 | if (len > sizeof(oid->name)) { |
| 96 | WARN(1, "ceph_oid_set_name '%s' len %d vs %zu, truncating\n", |
| 97 | name, len, sizeof(oid->name)); |
| 98 | len = sizeof(oid->name); |
| 99 | } |
| 100 | |
| 101 | memcpy(oid->name, name, len); |
| 102 | oid->name_len = len; |
| 103 | } |
| 104 | |
| 105 | static inline void ceph_oid_copy(struct ceph_object_id *dest, |
| 106 | struct ceph_object_id *src) |
| 107 | { |
| 108 | BUG_ON(src->name_len > sizeof(dest->name)); |
| 109 | memcpy(dest->name, src->name, src->name_len); |
| 110 | dest->name_len = src->name_len; |
| 111 | } |
| 112 | |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 113 | static inline int ceph_osd_is_up(struct ceph_osdmap *map, int osd) |
| 114 | { |
| 115 | return (osd < map->max_osd) && (map->osd_state[osd] & CEPH_OSD_UP); |
| 116 | } |
| 117 | |
| 118 | static inline bool ceph_osdmap_flag(struct ceph_osdmap *map, int flag) |
| 119 | { |
| 120 | return map && (map->flags & flag); |
| 121 | } |
| 122 | |
| 123 | extern char *ceph_osdmap_state_str(char *str, int len, int state); |
| 124 | |
| 125 | static inline struct ceph_entity_addr *ceph_osd_addr(struct ceph_osdmap *map, |
| 126 | int osd) |
| 127 | { |
| 128 | if (osd >= map->max_osd) |
| 129 | return NULL; |
| 130 | return &map->osd_addr[osd]; |
| 131 | } |
| 132 | |
Alex Elder | ef4859d | 2013-04-01 18:58:26 -0500 | [diff] [blame] | 133 | static inline int ceph_decode_pgid(void **p, void *end, struct ceph_pg *pgid) |
| 134 | { |
| 135 | __u8 version; |
| 136 | |
| 137 | if (!ceph_has_room(p, end, 1 + 8 + 4 + 4)) { |
| 138 | pr_warning("incomplete pg encoding"); |
| 139 | |
| 140 | return -EINVAL; |
| 141 | } |
| 142 | version = ceph_decode_8(p); |
| 143 | if (version > 1) { |
| 144 | pr_warning("do not understand pg encoding %d > 1", |
| 145 | (int)version); |
| 146 | return -EINVAL; |
| 147 | } |
| 148 | |
| 149 | pgid->pool = ceph_decode_64(p); |
| 150 | pgid->seed = ceph_decode_32(p); |
| 151 | *p += 4; /* skip deprecated preferred value */ |
| 152 | |
| 153 | return 0; |
| 154 | } |
| 155 | |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 156 | extern struct ceph_osdmap *osdmap_decode(void **p, void *end); |
| 157 | extern struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end, |
| 158 | struct ceph_osdmap *map, |
| 159 | struct ceph_messenger *msgr); |
| 160 | extern void ceph_osdmap_destroy(struct ceph_osdmap *map); |
| 161 | |
| 162 | /* calculate mapping of a file extent to an object */ |
Sage Weil | d63b77f | 2012-09-24 20:59:48 -0700 | [diff] [blame] | 163 | extern int ceph_calc_file_object_mapping(struct ceph_file_layout *layout, |
Alex Elder | e8afad6 | 2012-11-14 09:38:19 -0600 | [diff] [blame] | 164 | u64 off, u64 len, |
Sage Weil | d63b77f | 2012-09-24 20:59:48 -0700 | [diff] [blame] | 165 | u64 *bno, u64 *oxoff, u64 *oxlen); |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 166 | |
| 167 | /* calculate mapping of object to a placement group */ |
Ilya Dryomov | 7c13cb6 | 2014-01-27 17:40:19 +0200 | [diff] [blame] | 168 | extern int ceph_oloc_oid_to_pg(struct ceph_osdmap *osdmap, |
| 169 | struct ceph_object_locator *oloc, |
| 170 | struct ceph_object_id *oid, |
| 171 | struct ceph_pg *pg_out); |
| 172 | |
Sage Weil | 12979354 | 2013-01-08 09:15:10 -0800 | [diff] [blame] | 173 | extern int ceph_calc_pg_acting(struct ceph_osdmap *osdmap, |
Sage Weil | 5b191d9 | 2013-02-23 10:38:16 -0800 | [diff] [blame] | 174 | struct ceph_pg pgid, |
Sage Weil | d85b705 | 2010-05-10 10:24:48 -0700 | [diff] [blame] | 175 | int *acting); |
Sage Weil | 5104212 | 2009-11-04 11:39:12 -0800 | [diff] [blame] | 176 | extern int ceph_calc_pg_primary(struct ceph_osdmap *osdmap, |
Sage Weil | 5b191d9 | 2013-02-23 10:38:16 -0800 | [diff] [blame] | 177 | struct ceph_pg pgid); |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 178 | |
Ilya Dryomov | ce7f6a2 | 2014-01-27 17:40:19 +0200 | [diff] [blame] | 179 | extern struct ceph_pg_pool_info *ceph_pg_pool_by_id(struct ceph_osdmap *map, |
| 180 | u64 id); |
| 181 | |
Alex Elder | 72afc71 | 2012-10-30 19:40:33 -0500 | [diff] [blame] | 182 | extern const char *ceph_pg_pool_name_by_id(struct ceph_osdmap *map, u64 id); |
Yehuda Sadeh | 7669a2c | 2010-05-17 12:31:35 -0700 | [diff] [blame] | 183 | extern int ceph_pg_poolid_by_name(struct ceph_osdmap *map, const char *name); |
| 184 | |
Sage Weil | f24e998 | 2009-10-06 11:31:10 -0700 | [diff] [blame] | 185 | #endif |