fs/ceph/osdmap.h

   1 #ifndef _FS_CEPH_OSDMAP_H
   2 #define _FS_CEPH_OSDMAP_H
   3
   4 #include <linux/rbtree.h>
   5 #include "types.h"
   6 #include "ceph_fs.h"
   7 #include "crush/crush.h"
   8
   9 /*
  10  * The osd map describes the current membership of the osd cluster and
  11  * specifies the mapping of objects to placement groups and placement
  12  * groups to (sets of) osds.  That is, it completely specifies the
  13  * (desired) distribution of all data objects in the system at some
  14  * point in time.
  15  *
  16  * Each map version is identified by an epoch, which increases monotonically.
  17  *
  18  * The map can be updated either via an incremental map (diff) describing
  19  * the change between two successive epochs, or as a fully encoded map.
  20  */
  21 struct ceph_pg_pool_info {
  22         struct rb_node node;
  23         int id;
  24         struct ceph_pg_pool v;
  25         int pg_num_mask, pgp_num_mask, lpg_num_mask, lpgp_num_mask;
  26 };
  27
  28 struct ceph_pg_mapping {
  29         struct rb_node node;
  30         struct ceph_pg pgid;
  31         int len;
  32         int osds[];
  33 };
  34
  35 struct ceph_osdmap {
  36         struct ceph_fsid fsid;
  37         u32 epoch;
  38         u32 mkfs_epoch;
  39         struct ceph_timespec created, modified;
  40
  41         u32 flags;         /* CEPH_OSDMAP_* */
  42
  43         u32 max_osd;       /* size of osd_state, _offload, _addr arrays */
  44         u8 *osd_state;     /* CEPH_OSD_* */
  45         u32 *osd_weight;   /* 0 = failed, 0x10000 = 100% normal */
  46         struct ceph_entity_addr *osd_addr;
  47
  48         struct rb_root pg_temp;
  49         struct rb_root pg_pools;
  50         u32 pool_max;
  51
  52         /* the CRUSH map specifies the mapping of placement groups to
  53          * the list of osds that store+replicate them. */
  54         struct crush_map *crush;
  55 };
  56
  57 /*
  58  * file layout helpers
  59  */
  60 #define ceph_file_layout_su(l) ((__s32)le32_to_cpu((l).fl_stripe_unit))
  61 #define ceph_file_layout_stripe_count(l) \
  62         ((__s32)le32_to_cpu((l).fl_stripe_count))
  63 #define ceph_file_layout_object_size(l) ((__s32)le32_to_cpu((l).fl_object_size))
  64 #define ceph_file_layout_cas_hash(l) ((__s32)le32_to_cpu((l).fl_cas_hash))
  65 #define ceph_file_layout_object_su(l) \
  66         ((__s32)le32_to_cpu((l).fl_object_stripe_unit))
  67 #define ceph_file_layout_pg_preferred(l) \
  68         ((__s32)le32_to_cpu((l).fl_pg_preferred))
  69 #define ceph_file_layout_pg_pool(l) \
  70         ((__s32)le32_to_cpu((l).fl_pg_pool))
  71
  72 static inline unsigned ceph_file_layout_stripe_width(struct ceph_file_layout *l)
  73 {
  74         return le32_to_cpu(l->fl_stripe_unit) *
  75                 le32_to_cpu(l->fl_stripe_count);
  76 }
  77
  78 /* "period" == bytes before i start on a new set of objects */
  79 static inline unsigned ceph_file_layout_period(struct ceph_file_layout *l)
  80 {
  81         return le32_to_cpu(l->fl_object_size) *
  82                 le32_to_cpu(l->fl_stripe_count);
  83 }
  84
  85
  86 static inline int ceph_osd_is_up(struct ceph_osdmap *map, int osd)
  87 {
  88         return (osd < map->max_osd) && (map->osd_state[osd] & CEPH_OSD_UP);
  89 }
  90
  91 static inline bool ceph_osdmap_flag(struct ceph_osdmap *map, int flag)
  92 {
  93         return map && (map->flags & flag);
  94 }
  95
  96 extern char *ceph_osdmap_state_str(char *str, int len, int state);
  97
  98 static inline struct ceph_entity_addr *ceph_osd_addr(struct ceph_osdmap *map,
  99                                                      int osd)
 100 {
 101         if (osd >= map->max_osd)
 102                 return NULL;
 103         return &map->osd_addr[osd];
 104 }
 105
 106 extern struct ceph_osdmap *osdmap_decode(void **p, void *end);
 107 extern struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end,
 108                                             struct ceph_osdmap *map,
 109                                             struct ceph_messenger *msgr);
 110 extern void ceph_osdmap_destroy(struct ceph_osdmap *map);
 111
 112 /* calculate mapping of a file extent to an object */
 113 extern void ceph_calc_file_object_mapping(struct ceph_file_layout *layout,
 114                                           u64 off, u64 *plen,
 115                                           u64 *bno, u64 *oxoff, u64 *oxlen);
 116
 117 /* calculate mapping of object to a placement group */
 118 extern int ceph_calc_object_layout(struct ceph_object_layout *ol,
 119                                    const char *oid,
 120                                    struct ceph_file_layout *fl,
 121                                    struct ceph_osdmap *osdmap);
 122 extern int ceph_calc_pg_primary(struct ceph_osdmap *osdmap,
 123                                 struct ceph_pg pgid);
 124
 125 #endif