emo/thin-provisioning-tools
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[thin_metadata_pack] Prefetch blocks.

Browse Source 
Doubles performance
This commit is contained in:
Joe Thornber 2020-06-01 11:13:51 +01:00
parent 128ecc27f2
commit 9f2b747ffa
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
thin-provisioning/thin_metadata_pack.cc
View File

@ -42,6 +42,7 @@ namespace {
using namespace std; using namespace std;
constexpr uint64_t MAGIC = 0xa537a0aa6309ef77; constexpr uint64_t MAGIC = 0xa537a0aa6309ef77;
constexpr uint64_t PACK_VERSION = 1; constexpr uint64_t PACK_VERSION = 1;
constexpr uint64_t PREFETCH_COUNT = 1024;
uint32_t const SUPERBLOCK_CSUM_SEED = 160774; uint32_t const SUPERBLOCK_CSUM_SEED = 160774;
uint32_t const BITMAP_CSUM_XOR = 240779; uint32_t const BITMAP_CSUM_XOR = 240779;
@ -132,6 +133,10 @@ namespace {
write_u64(out, block_size); write_u64(out, block_size);
write_u64(out, nr_blocks); write_u64(out, nr_blocks);
// prefetch
for (block_address b = 0; b < PREFETCH_COUNT; b++)
bm->prefetch(b);
is_metadata_functor is_metadata; is_metadata_functor is_metadata;
for (block_address b = 0; b < nr_blocks; b++) { for (block_address b = 0; b < nr_blocks; b++) {
auto rr = bm->read_lock(b); auto rr = bm->read_lock(b);
@ -140,6 +145,10 @@ namespace {
write_u64(out, b); write_u64(out, b);
out.write(reinterpret_cast<const char *>(rr.data()), block_size); out.write(reinterpret_cast<const char *>(rr.data()), block_size);
} }
auto prefetch_b = b + PREFETCH_COUNT;
if (prefetch_b < nr_blocks)
bm->prefetch(prefetch_b);
} }
return 0; return 0;