Skip to content

Commit 8146b01

Browse files
committed
crimson/os/seastore: replace record_group_data_bytes with data_bytes
Signed-off-by: Myoungwon Oh <[email protected]>
1 parent 8d2cdfd commit 8146b01

File tree

4 files changed

+8
-8
lines changed

4 files changed

+8
-8
lines changed

src/crimson/os/seastore/extent_placement_manager.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1027,7 +1027,7 @@ RandomBlockOolWriter::do_write(
10271027
auto& trans_stats = get_by_src(w_stats.stats_by_src, t.get_src());
10281028
++(trans_stats.num_records);
10291029
trans_stats.data_bytes += ex->get_length();
1030-
w_stats.record_group_data_bytes += ex->get_length();
1030+
w_stats.data_bytes += ex->get_length();
10311031
}
10321032
return trans_intr::make_interruptible(
10331033
rbm->write(paddr + offset,

src/crimson/os/seastore/journal/record_submitter.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -411,7 +411,7 @@ RecordSubmitter::open(bool is_mkfs)
411411
),
412412
sm::make_counter(
413413
"record_group_data_bytes",
414-
stats.record_group_data_bytes,
414+
stats.data_bytes,
415415
sm::description("bytes of data when write record groups"),
416416
label_instances
417417
),
@@ -489,7 +489,7 @@ void RecordSubmitter::account_submission(
489489
stats.record_group_padding_bytes +=
490490
(rg.size.get_mdlength() - rg.size.get_raw_mdlength());
491491
stats.record_group_metadata_bytes += rg.size.get_raw_mdlength();
492-
stats.record_group_data_bytes += rg.size.dlength;
492+
stats.data_bytes += rg.size.dlength;
493493
stats.record_batch_stats.increment(rg.get_size());
494494

495495
for (const record_t& r : rg.records) {

src/crimson/os/seastore/seastore_types.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -911,7 +911,7 @@ std::ostream& operator<<(std::ostream& out, const writer_stats_printer_t& p)
911911
<< ",sizeB="
912912
<< fmt::format(dfmt, p.stats.get_total_bytes()/d_num_io)
913913
<< "("
914-
<< fmt::format(dfmt, p.stats.record_group_data_bytes/d_num_io)
914+
<< fmt::format(dfmt, p.stats.data_bytes/d_num_io)
915915
<< ","
916916
<< fmt::format(dfmt, p.stats.record_group_metadata_bytes/d_num_io)
917917
<< ","

src/crimson/os/seastore/seastore_types.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2330,7 +2330,7 @@ struct writer_stats_t {
23302330
grouped_io_stats io_depth_stats;
23312331
uint64_t record_group_padding_bytes = 0;
23322332
uint64_t record_group_metadata_bytes = 0;
2333-
uint64_t record_group_data_bytes = 0;
2333+
uint64_t data_bytes = 0;
23342334
counter_by_src_t<trans_writer_stats_t> stats_by_src;
23352335

23362336
bool is_empty() const {
@@ -2340,15 +2340,15 @@ struct writer_stats_t {
23402340
uint64_t get_total_bytes() const {
23412341
return record_group_padding_bytes +
23422342
record_group_metadata_bytes +
2343-
record_group_data_bytes;
2343+
data_bytes;
23442344
}
23452345

23462346
void add(const writer_stats_t &o) {
23472347
record_batch_stats.add(o.record_batch_stats);
23482348
io_depth_stats.add(o.io_depth_stats);
23492349
record_group_padding_bytes += o.record_group_padding_bytes;
23502350
record_group_metadata_bytes += o.record_group_metadata_bytes;
2351-
record_group_data_bytes += o.record_group_data_bytes;
2351+
data_bytes += o.data_bytes;
23522352
add_srcs(stats_by_src, o.stats_by_src);
23532353
}
23542354

@@ -2357,7 +2357,7 @@ struct writer_stats_t {
23572357
io_depth_stats.minus(o.io_depth_stats);
23582358
record_group_padding_bytes -= o.record_group_padding_bytes;
23592359
record_group_metadata_bytes -= o.record_group_metadata_bytes;
2360-
record_group_data_bytes -= o.record_group_data_bytes;
2360+
data_bytes -= o.data_bytes;
23612361
minus_srcs(stats_by_src, o.stats_by_src);
23622362
}
23632363
};

0 commit comments

Comments
 (0)