summaryrefslogtreecommitdiffstats
path: root/src/os/bluestore/BlueStore.cc
diff options
context:
space:
mode:
authorSage Weil <sage@redhat.com>2017-10-03 04:27:58 +0200
committerSage Weil <sage@redhat.com>2018-08-16 00:18:43 +0200
commitfa120cec38b11378a7e6dbe37397f9a203f2f75c (patch)
tree17a5b68ec77d4a86cce5dd9d405ba07de26d84fa /src/os/bluestore/BlueStore.cc
parentosd: re-add get_num_pgs() (diff)
downloadceph-fa120cec38b11378a7e6dbe37397f9a203f2f75c.tar.xz
ceph-fa120cec38b11378a7e6dbe37397f9a203f2f75c.zip
osd/osd_types: separate accounting for data, omap, and metadata
Signed-off-by: Sage Weil <sage@redhat.com>
Diffstat (limited to 'src/os/bluestore/BlueStore.cc')
-rw-r--r--src/os/bluestore/BlueStore.cc30
1 files changed, 15 insertions, 15 deletions
diff --git a/src/os/bluestore/BlueStore.cc b/src/os/bluestore/BlueStore.cc
index 0bae5cd5835..fe3f0911ff2 100644
--- a/src/os/bluestore/BlueStore.cc
+++ b/src/os/bluestore/BlueStore.cc
@@ -4350,10 +4350,10 @@ int BlueStore::_reload_logger()
int r = statfs(&store_statfs);
if (r >= 0) {
logger->set(l_bluestore_allocated, store_statfs.allocated);
- logger->set(l_bluestore_stored, store_statfs.stored);
- logger->set(l_bluestore_compressed, store_statfs.compressed);
- logger->set(l_bluestore_compressed_allocated, store_statfs.compressed_allocated);
- logger->set(l_bluestore_compressed_original, store_statfs.compressed_original);
+ logger->set(l_bluestore_stored, store_statfs.data_stored);
+ logger->set(l_bluestore_compressed, store_statfs.data_compressed);
+ logger->set(l_bluestore_compressed_allocated, store_statfs.data_compressed_allocated);
+ logger->set(l_bluestore_compressed_original, store_statfs.data_compressed_original);
}
return r;
}
@@ -5957,7 +5957,7 @@ int BlueStore::_fsck_check_extents(
continue;
expected_statfs.allocated += e.length;
if (compressed) {
- expected_statfs.compressed_allocated += e.length;
+ expected_statfs.data_compressed_allocated += e.length;
}
bool already = false;
apply(
@@ -6329,7 +6329,7 @@ int BlueStore::_fsck(bool deep, bool repair)
++errors;
}
pos = l.logical_offset + l.length;
- expected_statfs.stored += l.length;
+ expected_statfs.data_stored += l.length;
assert(l.blob);
const bluestore_blob_t& blob = l.blob->get_blob();
@@ -6413,8 +6413,8 @@ int BlueStore::_fsck(bool deep, bool repair)
++errors;
}
if (blob.is_compressed()) {
- expected_statfs.compressed += blob.get_compressed_payload_length();
- expected_statfs.compressed_original +=
+ expected_statfs.data_compressed += blob.get_compressed_payload_length();
+ expected_statfs.data_compressed_original +=
i.first->get_referenced_bytes();
}
if (blob.is_shared()) {
@@ -6650,7 +6650,7 @@ int BlueStore::_fsck(bool deep, bool repair)
}
expected_statfs.allocated += e->length;
if (compressed) {
- expected_statfs.compressed_allocated += e->length;
+ expected_statfs.data_compressed_allocated += e->length;
}
bufferlist bl;
IOContext ioc(cct, NULL, true); // allow EIO
@@ -6688,7 +6688,7 @@ int BlueStore::_fsck(bool deep, bool repair)
// NB: it's crucial to use compressed flag from sb_info_t
// as we originally used that value while accumulating
// expected_statfs
- expected_statfs.compressed_allocated -= r.second.length;
+ expected_statfs.data_compressed_allocated -= r.second.length;
}
}
sbi.updated = sbi.passed = true;
@@ -6702,7 +6702,7 @@ int BlueStore::_fsck(bool deep, bool repair)
for (auto& p : pext_to_release) {
expected_statfs.allocated -= p.length;
if (compressed) {
- expected_statfs.compressed_allocated -= p.length;
+ expected_statfs.data_compressed_allocated -= p.length;
}
to_release.union_insert(p.offset, p.length);
}
@@ -7131,10 +7131,10 @@ int BlueStore::statfs(struct store_statfs_t *buf)
{
std::lock_guard<std::mutex> l(vstatfs_lock);
buf->allocated = vstatfs.allocated();
- buf->stored = vstatfs.stored();
- buf->compressed = vstatfs.compressed();
- buf->compressed_original = vstatfs.compressed_original();
- buf->compressed_allocated = vstatfs.compressed_allocated();
+ buf->data_stored = vstatfs.stored();
+ buf->data_compressed = vstatfs.compressed();
+ buf->data_compressed_original = vstatfs.compressed_original();
+ buf->data_compressed_allocated = vstatfs.compressed_allocated();
}
dout(20) << __func__ << " " << *buf << dendl;