diff options
Diffstat (limited to 'net/ceph/osd_client.c')
-rw-r--r-- | net/ceph/osd_client.c | 30 |
1 files changed, 15 insertions, 15 deletions
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); |