ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

lib/ftl: automatically advance parent's IO position

Browse Source 
Advance parent's IO position when children positions are advanced.
There's no need to call ftl_io_advance twice for the same request
anymore.

Change-Id: I1f7f04a3a83575b11e7bf0b13c0c8f3bf98b5522
Signed-off-by: Konrad Sztyber <konrad.sztyber@intel.com>
Reviewed-on: https://review.gerrithub.io/c/spdk/spdk/+/455518
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: Wojciech Malikowski <wojciech.malikowski@intel.com>
Reviewed-by: Darek Stojaczyk <dariusz.stojaczyk@intel.com>
This commit is contained in:
Konrad Sztyber 2019-05-09 13:37:21 +02:00 committed by Darek Stojaczyk
parent 5470a0584f
commit b52a5a45d8
2 changed files with 18 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib/ftl/ftl_core.c
View File

@ -1013,7 +1013,6 @@ _ftl_write_nv_cache(void *ctx)
}
ftl_submit_nv_cache(child);
ftl_io_advance(io, num_lbks);
}
if (ftl_io_done(io)) {
@ -1265,10 +1264,6 @@ ftl_submit_write(struct ftl_wptr *wptr, struct ftl_io *io)
}
ftl_trace_submission(dev, io, wptr->ppa, lbk_cnt);
/* Update parent iovec */
ftl_io_advance(io, lbk_cnt);
ftl_wptr_advance(wptr, lbk_cnt);
}

34
lib/ftl/ftl_io.c
View File

@ -104,27 +104,29 @@ void
ftl_io_advance(struct ftl_io *io, size_t lbk_cnt)
{
struct iovec *iov = ftl_io_iovec(io);
size_t iov_lbks;
size_t iov_lbks, lbk_left = lbk_cnt;
io->pos += lbk_cnt;
if (io->iov_cnt == 0) {
return;
if (io->iov_cnt != 0) {
while (lbk_left > 0) {
assert(io->iov_pos < io->iov_cnt);
iov_lbks = iov[io->iov_pos].iov_len / PAGE_SIZE;
if (io->iov_off + lbk_left < iov_lbks) {
io->iov_off += lbk_left;
break;
}
assert(iov_lbks > io->iov_off);
lbk_left -= (iov_lbks - io->iov_off);
io->iov_off = 0;
io->iov_pos++;
}
}
while (lbk_cnt > 0) {
assert(io->iov_pos < io->iov_cnt);
iov_lbks = iov[io->iov_pos].iov_len / PAGE_SIZE;
if (io->iov_off + lbk_cnt < iov_lbks) {
io->iov_off += lbk_cnt;
break;
}
assert(iov_lbks > io->iov_off);
lbk_cnt -= (iov_lbks - io->iov_off);
io->iov_off = 0;
io->iov_pos++;
if (io->parent) {
ftl_io_advance(io->parent, lbk_cnt);
}
}