RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-04 02:02:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/os/seastore/segment_manager: respect len parameter of BlockSegmentManager::read()

Browse Source 
Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
This commit is contained in:
Yingxin Cheng 2021-07-22 15:28:40 +08:00
parent 1a5bcbb335
commit 97bcfda549
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/crimson/os/seastore/segment_manager/block.cc
View File

@ -84,23 +84,25 @@ static write_ertr::future<> do_writev(
static read_ertr::future<> do_read(
seastar::file &device,
uint64_t offset,
size_t len,
bufferptr &bptr)
{
assert(len <= bptr.length());
logger().debug(
"block: do_read offset {} len {}",
offset,
bptr.length());
len);
return device.dma_read(
offset,
bptr.c_str(),
bptr.length()
len
).handle_exception([](auto e) -> read_ertr::future<size_t> {
logger().error(
"do_read: dma_read got error {}",
e);
return crimson::ct_error::input_output_error::make();
}).then([length=bptr.length()](auto result) -> read_ertr::future<> {
if (result != length) {
}).then([len](auto result) -> read_ertr::future<> {
if (result != len) {
return crimson::ct_error::input_output_error::make();
}
return read_ertr::now();
@ -123,6 +125,7 @@ SegmentStateTracker::read_in(
return do_read(
device,
offset,
bptr.length(),
bptr);
}
@ -285,6 +288,7 @@ read_superblock(seastar::file &device, seastar::stat_data sd)
return do_read(
device,
0,
bp.length(),
bp
).safe_then([=, &bp] {
bufferlist bl;
@ -500,6 +504,7 @@ SegmentManager::read_ertr::future<> BlockSegmentManager::read(
return do_read(
device,
get_offset(addr),
len,
out);
}