aboutsummaryrefslogtreecommitdiffstats
path: root/net/ceph
diff options
context:
space:
mode:
authorIlya Dryomov <ilya.dryomov@inktank.com>2014-01-27 10:40:20 -0500
committerIlya Dryomov <ilya.dryomov@inktank.com>2014-01-27 16:57:49 -0500
commit3c972c95c68f455d80ff185aa440857be046bbe0 (patch)
tree9389951dec0bcc03c2da0f0f3fb966e16438b430 /net/ceph
parent17a13e4028e6ad7ded079cf32370c47bd0e0fc07 (diff)
libceph: rename ceph_osd_request::r_{oloc,oid} to r_base_{oloc,oid}
Rename ceph_osd_request::r_{oloc,oid} to r_base_{oloc,oid} before introducing r_target_{oloc,oid} needed for redirects. Signed-off-by: Ilya Dryomov <ilya.dryomov@inktank.com> Reviewed-by: Sage Weil <sage@inktank.com>
Diffstat (limited to 'net/ceph')
-rw-r--r--net/ceph/debugfs.c4
-rw-r--r--net/ceph/osd_client.c30
2 files changed, 17 insertions, 17 deletions
diff --git a/net/ceph/debugfs.c b/net/ceph/debugfs.c
index 1f8562706393..258a382e75ed 100644
--- a/net/ceph/debugfs.c
+++ b/net/ceph/debugfs.c
@@ -132,8 +132,8 @@ static int osdc_show(struct seq_file *s, void *pp)
132 req->r_osd ? req->r_osd->o_osd : -1, 132 req->r_osd ? req->r_osd->o_osd : -1,
133 req->r_pgid.pool, req->r_pgid.seed); 133 req->r_pgid.pool, req->r_pgid.seed);
134 134
135 seq_printf(s, "%.*s", req->r_oid.name_len, 135 seq_printf(s, "%.*s", req->r_base_oid.name_len,
136 req->r_oid.name); 136 req->r_base_oid.name);
137 137
138 if (req->r_reassert_version.epoch) 138 if (req->r_reassert_version.epoch)
139 seq_printf(s, "\t%u'%llu", 139 seq_printf(s, "\t%u'%llu",
diff --git a/net/ceph/osd_client.c b/net/ceph/osd_client.c
index 0eb009eaf4ff..3997a87c4f51 100644
--- a/net/ceph/osd_client.c
+++ b/net/ceph/osd_client.c
@@ -368,7 +368,7 @@ struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,
368 INIT_LIST_HEAD(&req->r_req_lru_item); 368 INIT_LIST_HEAD(&req->r_req_lru_item);
369 INIT_LIST_HEAD(&req->r_osd_item); 369 INIT_LIST_HEAD(&req->r_osd_item);
370 370
371 req->r_oloc.pool = -1; 371 req->r_base_oloc.pool = -1;
372 372
373 /* create reply message */ 373 /* create reply message */
374 if (use_mempool) 374 if (use_mempool)
@@ -763,11 +763,11 @@ struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *osdc,
763 if (num_ops > 1) 763 if (num_ops > 1)
764 osd_req_op_init(req, 1, CEPH_OSD_OP_STARTSYNC); 764 osd_req_op_init(req, 1, CEPH_OSD_OP_STARTSYNC);
765 765
766 req->r_oloc.pool = ceph_file_layout_pg_pool(*layout); 766 req->r_base_oloc.pool = ceph_file_layout_pg_pool(*layout);
767 767
768 snprintf(req->r_oid.name, sizeof(req->r_oid.name), 768 snprintf(req->r_base_oid.name, sizeof(req->r_base_oid.name),
769 "%llx.%08llx", vino.ino, objnum); 769 "%llx.%08llx", vino.ino, objnum);
770 req->r_oid.name_len = strlen(req->r_oid.name); 770 req->r_base_oid.name_len = strlen(req->r_base_oid.name);
771 771
772 return req; 772 return req;
773} 773}
@@ -1259,20 +1259,20 @@ static int __calc_request_pg(struct ceph_osdmap *osdmap,
1259 if ((req->r_flags & CEPH_OSD_FLAG_IGNORE_OVERLAY) == 0) { 1259 if ((req->r_flags & CEPH_OSD_FLAG_IGNORE_OVERLAY) == 0) {
1260 struct ceph_pg_pool_info *pi; 1260 struct ceph_pg_pool_info *pi;
1261 1261
1262 pi = ceph_pg_pool_by_id(osdmap, req->r_oloc.pool); 1262 pi = ceph_pg_pool_by_id(osdmap, req->r_base_oloc.pool);
1263 if (pi) { 1263 if (pi) {
1264 if ((req->r_flags & CEPH_OSD_FLAG_READ) && 1264 if ((req->r_flags & CEPH_OSD_FLAG_READ) &&
1265 pi->read_tier >= 0) 1265 pi->read_tier >= 0)
1266 req->r_oloc.pool = pi->read_tier; 1266 req->r_base_oloc.pool = pi->read_tier;
1267 if ((req->r_flags & CEPH_OSD_FLAG_WRITE) && 1267 if ((req->r_flags & CEPH_OSD_FLAG_WRITE) &&
1268 pi->write_tier >= 0) 1268 pi->write_tier >= 0)
1269 req->r_oloc.pool = pi->write_tier; 1269 req->r_base_oloc.pool = pi->write_tier;
1270 } 1270 }
1271 /* !pi is caught in ceph_oloc_oid_to_pg() */ 1271 /* !pi is caught in ceph_oloc_oid_to_pg() */
1272 } 1272 }
1273 1273
1274 return ceph_oloc_oid_to_pg(osdmap, &req->r_oloc, 1274 return ceph_oloc_oid_to_pg(osdmap, &req->r_base_oloc,
1275 &req->r_oid, pg_out); 1275 &req->r_base_oid, pg_out);
1276} 1276}
1277 1277
1278/* 1278/*
@@ -1382,7 +1382,7 @@ static void __send_request(struct ceph_osd_client *osdc,
1382 /* fill in message content that changes each time we send it */ 1382 /* fill in message content that changes each time we send it */
1383 put_unaligned_le32(osdc->osdmap->epoch, req->r_request_osdmap_epoch); 1383 put_unaligned_le32(osdc->osdmap->epoch, req->r_request_osdmap_epoch);
1384 put_unaligned_le32(req->r_flags, req->r_request_flags); 1384 put_unaligned_le32(req->r_flags, req->r_request_flags);
1385 put_unaligned_le64(req->r_oloc.pool, req->r_request_pool); 1385 put_unaligned_le64(req->r_base_oloc.pool, req->r_request_pool);
1386 p = req->r_request_pgid; 1386 p = req->r_request_pgid;
1387 ceph_encode_64(&p, req->r_pgid.pool); 1387 ceph_encode_64(&p, req->r_pgid.pool);
1388 ceph_encode_32(&p, req->r_pgid.seed); 1388 ceph_encode_32(&p, req->r_pgid.seed);
@@ -2144,11 +2144,11 @@ void ceph_osdc_build_request(struct ceph_osd_request *req, u64 off,
2144 ceph_encode_32(&p, -1); /* preferred */ 2144 ceph_encode_32(&p, -1); /* preferred */
2145 2145
2146 /* oid */ 2146 /* oid */
2147 ceph_encode_32(&p, req->r_oid.name_len); 2147 ceph_encode_32(&p, req->r_base_oid.name_len);
2148 memcpy(p, req->r_oid.name, req->r_oid.name_len); 2148 memcpy(p, req->r_base_oid.name, req->r_base_oid.name_len);
2149 dout("oid '%.*s' len %d\n", req->r_oid.name_len, 2149 dout("oid '%.*s' len %d\n", req->r_base_oid.name_len,
2150 req->r_oid.name, req->r_oid.name_len); 2150 req->r_base_oid.name, req->r_base_oid.name_len);
2151 p += req->r_oid.name_len; 2151 p += req->r_base_oid.name_len;
2152 2152
2153 /* ops--can imply data */ 2153 /* ops--can imply data */
2154 ceph_encode_16(&p, (u16)req->r_num_ops); 2154 ceph_encode_16(&p, (u16)req->r_num_ops);