mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-22 15:52:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

sstables stats: partition seeks

Browse Source 
Signed-off-by: Benny Halevy <bhalevy@scylladb.com>
This commit is contained in:
Benny Halevy
2018-08-12 16:35:58 +03:00
parent edb3c23125
commit 192c1949a3
3 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
sstables/partition.cc
View File

@@ -269,7 +269,9 @@ private:
return make_ready_future<>();
}
assert(_index_reader->element_kind() == indexable_element::partition);
return _context->skip_to(_index_reader->element_kind(), start);
return _context->skip_to(_index_reader->element_kind(), start).then([this] {
_sst->get_stats().on_partition_seek();
});
});
}
future<> read_from_index() {
@@ -381,6 +383,7 @@ private:
return make_ready_future<>();
}
return _context->skip_to(idx.element_kind(), index_position.start).then([this, &idx] {
_sst->get_stats().on_partition_seek();
set_range_tombstone_start_from_end_open_marker(_consumer, *_schema, idx);
});
});

2
sstables/sstables.cc
View File

@@ -4300,6 +4300,8 @@ future<> init_metrics() {
sm::description("Number of whole sstable flat mutation reads")),
sm::make_derive("partition_reads", [] { return sstables_stats::get_shard_stats().partition_reads; },
sm::description("Number of partitions read")),
sm::make_derive("partition_seeks", [] { return sstables_stats::get_shard_stats().partition_seeks; },
sm::description("Number of partitions seeked")),
});
});
}

5
sstables/stats.hh
View File

@@ -36,6 +36,7 @@ class sstables_stats {
uint64_t range_partition_reads = 0;
uint64_t sstable_partition_reads = 0;
uint64_t partition_reads = 0;
uint64_t partition_seeks = 0;
} _shard_stats;
stats& _stats = _shard_stats;
@@ -88,6 +89,10 @@ public:
inline void on_partition_read() {
++_stats.partition_reads;
}
inline void on_partition_seek() {
++_stats.partition_seeks;
}
};
}