Commit 12979354 authored by Sage Weil's avatar Sage Weil

libceph: rename ceph_pg -> ceph_pg_v1

Rename the old version this type to distinguish it from the new version.
Signed-off-by: default avatarSage Weil <sage@inktank.com>
Reviewed-by: default avatarAlex Elder <elder@inktank.com>
parent c47f9371
...@@ -186,7 +186,7 @@ static long ceph_ioctl_get_dataloc(struct file *file, void __user *arg) ...@@ -186,7 +186,7 @@ static long ceph_ioctl_get_dataloc(struct file *file, void __user *arg)
u64 len = 1, olen; u64 len = 1, olen;
u64 tmp; u64 tmp;
struct ceph_object_layout ol; struct ceph_object_layout ol;
struct ceph_pg pgid; struct ceph_pg_v1 pgid;
int r; int r;
/* copy and validate */ /* copy and validate */
......
...@@ -56,7 +56,7 @@ struct ceph_osd_request { ...@@ -56,7 +56,7 @@ struct ceph_osd_request {
struct list_head r_linger_item; struct list_head r_linger_item;
struct list_head r_linger_osd; struct list_head r_linger_osd;
struct ceph_osd *r_osd; struct ceph_osd *r_osd;
struct ceph_pg r_pgid; struct ceph_pg_v1 r_pgid;
int r_pg_osds[CEPH_PG_MAX_SIZE]; int r_pg_osds[CEPH_PG_MAX_SIZE];
int r_num_pg_osds; int r_num_pg_osds;
......
...@@ -28,7 +28,7 @@ struct ceph_pg_pool_info { ...@@ -28,7 +28,7 @@ struct ceph_pg_pool_info {
struct ceph_pg_mapping { struct ceph_pg_mapping {
struct rb_node node; struct rb_node node;
struct ceph_pg pgid; struct ceph_pg_v1 pgid;
int len; int len;
int osds[]; int osds[];
}; };
...@@ -118,10 +118,11 @@ extern int ceph_calc_object_layout(struct ceph_object_layout *ol, ...@@ -118,10 +118,11 @@ extern int ceph_calc_object_layout(struct ceph_object_layout *ol,
const char *oid, const char *oid,
struct ceph_file_layout *fl, struct ceph_file_layout *fl,
struct ceph_osdmap *osdmap); struct ceph_osdmap *osdmap);
extern int ceph_calc_pg_acting(struct ceph_osdmap *osdmap, struct ceph_pg pgid, extern int ceph_calc_pg_acting(struct ceph_osdmap *osdmap,
struct ceph_pg_v1 pgid,
int *acting); int *acting);
extern int ceph_calc_pg_primary(struct ceph_osdmap *osdmap, extern int ceph_calc_pg_primary(struct ceph_osdmap *osdmap,
struct ceph_pg pgid); struct ceph_pg_v1 pgid);
extern const char *ceph_pg_pool_name_by_id(struct ceph_osdmap *map, u64 id); extern const char *ceph_pg_pool_name_by_id(struct ceph_osdmap *map, u64 id);
extern int ceph_pg_poolid_by_name(struct ceph_osdmap *map, const char *name); extern int ceph_pg_poolid_by_name(struct ceph_osdmap *map, const char *name);
......
...@@ -64,7 +64,7 @@ struct ceph_timespec { ...@@ -64,7 +64,7 @@ struct ceph_timespec {
* placement group. * placement group.
* we encode this into one __le64. * we encode this into one __le64.
*/ */
struct ceph_pg { struct ceph_pg_v1 {
__le16 preferred; /* preferred primary osd */ __le16 preferred; /* preferred primary osd */
__le16 ps; /* placement seed */ __le16 ps; /* placement seed */
__le32 pool; /* object pool */ __le32 pool; /* object pool */
...@@ -128,7 +128,7 @@ static inline int ceph_stable_mod(int x, int b, int bmask) ...@@ -128,7 +128,7 @@ static inline int ceph_stable_mod(int x, int b, int bmask)
* object layout - how a given object should be stored. * object layout - how a given object should be stored.
*/ */
struct ceph_object_layout { struct ceph_object_layout {
struct ceph_pg ol_pgid; /* raw pg, with _full_ ps precision. */ struct ceph_pg_v1 ol_pgid; /* raw pg, with _full_ ps precision. */
__le32 ol_stripe_unit; /* for per-object parity, if any */ __le32 ol_stripe_unit; /* for per-object parity, if any */
} __attribute__ ((packed)); } __attribute__ ((packed));
......
...@@ -914,7 +914,7 @@ static int __map_request(struct ceph_osd_client *osdc, ...@@ -914,7 +914,7 @@ static int __map_request(struct ceph_osd_client *osdc,
struct ceph_osd_request *req, int force_resend) struct ceph_osd_request *req, int force_resend)
{ {
struct ceph_osd_request_head *reqhead = req->r_request->front.iov_base; struct ceph_osd_request_head *reqhead = req->r_request->front.iov_base;
struct ceph_pg pgid; struct ceph_pg_v1 pgid;
int acting[CEPH_PG_MAX_SIZE]; int acting[CEPH_PG_MAX_SIZE];
int o = -1, num = 0; int o = -1, num = 0;
int err; int err;
......
...@@ -350,7 +350,7 @@ static struct crush_map *crush_decode(void *pbyval, void *end) ...@@ -350,7 +350,7 @@ static struct crush_map *crush_decode(void *pbyval, void *end)
* rbtree of pg_mapping for handling pg_temp (explicit mapping of pgid * rbtree of pg_mapping for handling pg_temp (explicit mapping of pgid
* to a set of osds) * to a set of osds)
*/ */
static int pgid_cmp(struct ceph_pg l, struct ceph_pg r) static int pgid_cmp(struct ceph_pg_v1 l, struct ceph_pg_v1 r)
{ {
u64 a = *(u64 *)&l; u64 a = *(u64 *)&l;
u64 b = *(u64 *)&r; u64 b = *(u64 *)&r;
...@@ -389,7 +389,7 @@ static int __insert_pg_mapping(struct ceph_pg_mapping *new, ...@@ -389,7 +389,7 @@ static int __insert_pg_mapping(struct ceph_pg_mapping *new,
} }
static struct ceph_pg_mapping *__lookup_pg_mapping(struct rb_root *root, static struct ceph_pg_mapping *__lookup_pg_mapping(struct rb_root *root,
struct ceph_pg pgid) struct ceph_pg_v1 pgid)
{ {
struct rb_node *n = root->rb_node; struct rb_node *n = root->rb_node;
struct ceph_pg_mapping *pg; struct ceph_pg_mapping *pg;
...@@ -411,7 +411,7 @@ static struct ceph_pg_mapping *__lookup_pg_mapping(struct rb_root *root, ...@@ -411,7 +411,7 @@ static struct ceph_pg_mapping *__lookup_pg_mapping(struct rb_root *root,
return NULL; return NULL;
} }
static int __remove_pg_mapping(struct rb_root *root, struct ceph_pg pgid) static int __remove_pg_mapping(struct rb_root *root, struct ceph_pg_v1 pgid)
{ {
struct ceph_pg_mapping *pg = __lookup_pg_mapping(root, pgid); struct ceph_pg_mapping *pg = __lookup_pg_mapping(root, pgid);
...@@ -721,7 +721,7 @@ struct ceph_osdmap *osdmap_decode(void **p, void *end) ...@@ -721,7 +721,7 @@ struct ceph_osdmap *osdmap_decode(void **p, void *end)
ceph_decode_32_safe(p, end, len, bad); ceph_decode_32_safe(p, end, len, bad);
for (i = 0; i < len; i++) { for (i = 0; i < len; i++) {
int n, j; int n, j;
struct ceph_pg pgid; struct ceph_pg_v1 pgid;
struct ceph_pg_mapping *pg; struct ceph_pg_mapping *pg;
ceph_decode_need(p, end, sizeof(u32) + sizeof(u64), bad); ceph_decode_need(p, end, sizeof(u32) + sizeof(u64), bad);
...@@ -944,7 +944,7 @@ struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end, ...@@ -944,7 +944,7 @@ struct ceph_osdmap *osdmap_apply_incremental(void **p, void *end,
while (len--) { while (len--) {
struct ceph_pg_mapping *pg; struct ceph_pg_mapping *pg;
int j; int j;
struct ceph_pg pgid; struct ceph_pg_v1 pgid;
u32 pglen; u32 pglen;
ceph_decode_need(p, end, sizeof(u64) + sizeof(u32), bad); ceph_decode_need(p, end, sizeof(u64) + sizeof(u32), bad);
ceph_decode_copy(p, &pgid, sizeof(pgid)); ceph_decode_copy(p, &pgid, sizeof(pgid));
...@@ -1079,7 +1079,7 @@ int ceph_calc_object_layout(struct ceph_object_layout *ol, ...@@ -1079,7 +1079,7 @@ int ceph_calc_object_layout(struct ceph_object_layout *ol,
struct ceph_osdmap *osdmap) struct ceph_osdmap *osdmap)
{ {
unsigned int num, num_mask; unsigned int num, num_mask;
struct ceph_pg pgid; struct ceph_pg_v1 pgid;
int poolid = le32_to_cpu(fl->fl_pg_pool); int poolid = le32_to_cpu(fl->fl_pg_pool);
struct ceph_pg_pool_info *pool; struct ceph_pg_pool_info *pool;
unsigned int ps; unsigned int ps;
...@@ -1108,7 +1108,7 @@ EXPORT_SYMBOL(ceph_calc_object_layout); ...@@ -1108,7 +1108,7 @@ EXPORT_SYMBOL(ceph_calc_object_layout);
* Calculate raw osd vector for the given pgid. Return pointer to osd * Calculate raw osd vector for the given pgid. Return pointer to osd
* array, or NULL on failure. * array, or NULL on failure.
*/ */
static int *calc_pg_raw(struct ceph_osdmap *osdmap, struct ceph_pg pgid, static int *calc_pg_raw(struct ceph_osdmap *osdmap, struct ceph_pg_v1 pgid,
int *osds, int *num) int *osds, int *num)
{ {
struct ceph_pg_mapping *pg; struct ceph_pg_mapping *pg;
...@@ -1163,7 +1163,7 @@ static int *calc_pg_raw(struct ceph_osdmap *osdmap, struct ceph_pg pgid, ...@@ -1163,7 +1163,7 @@ static int *calc_pg_raw(struct ceph_osdmap *osdmap, struct ceph_pg pgid,
/* /*
* Return acting set for given pgid. * Return acting set for given pgid.
*/ */
int ceph_calc_pg_acting(struct ceph_osdmap *osdmap, struct ceph_pg pgid, int ceph_calc_pg_acting(struct ceph_osdmap *osdmap, struct ceph_pg_v1 pgid,
int *acting) int *acting)
{ {
int rawosds[CEPH_PG_MAX_SIZE], *osds; int rawosds[CEPH_PG_MAX_SIZE], *osds;
...@@ -1184,7 +1184,7 @@ int ceph_calc_pg_acting(struct ceph_osdmap *osdmap, struct ceph_pg pgid, ...@@ -1184,7 +1184,7 @@ int ceph_calc_pg_acting(struct ceph_osdmap *osdmap, struct ceph_pg pgid,
/* /*
* Return primary osd for given pgid, or -1 if none. * Return primary osd for given pgid, or -1 if none.
*/ */
int ceph_calc_pg_primary(struct ceph_osdmap *osdmap, struct ceph_pg pgid) int ceph_calc_pg_primary(struct ceph_osdmap *osdmap, struct ceph_pg_v1 pgid)
{ {
int rawosds[CEPH_PG_MAX_SIZE], *osds; int rawosds[CEPH_PG_MAX_SIZE], *osds;
int i, num = CEPH_PG_MAX_SIZE; int i, num = CEPH_PG_MAX_SIZE;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment