Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
kvdb
rocksdb
提交
a5507be8
R
rocksdb
项目概览
kvdb
/
rocksdb
12 个月 前同步成功
通知
0
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
R
rocksdb
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
a5507be8
编写于
2月 14, 2023
作者:
A
Andrew Kryczka
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Revert "Remove Stats related to compressed block cache (#11135)"
This reverts commit
e808858a
.
上级
14fef92c
变更
5
隐藏空白更改
内联
并排
Showing
5 changed file
with
49 addition
and
2 deletion
+49
-2
db_stress_tool/db_stress_test_base.h
db_stress_tool/db_stress_test_base.h
+2
-2
include/rocksdb/statistics.h
include/rocksdb/statistics.h
+6
-0
java/rocksjni/portal.h
java/rocksjni/portal.h
+16
-0
java/src/main/java/org/rocksdb/TickerType.java
java/src/main/java/org/rocksdb/TickerType.java
+20
-0
monitoring/statistics.cc
monitoring/statistics.cc
+5
-0
未找到文件。
db_stress_tool/db_stress_test_base.h
浏览文件 @
a5507be8
...
...
@@ -290,7 +290,7 @@ extern void InitializeOptionsFromFlags(
// There are two cases.
// Case 1: OPTIONS file is not specified. Command line arguments have been used
// to initialize `options`. InitializeOptionsGeneral() will use
// `cache` and `filter_policy` to initialize
// `cache`
, `block_cache_compressed`
and `filter_policy` to initialize
// corresponding fields of `options`. InitializeOptionsGeneral() will
// also set up other fields of `options` so that stress test can run.
// Examples include `create_if_missing` and
...
...
@@ -301,7 +301,7 @@ extern void InitializeOptionsFromFlags(
// case, if command line arguments indicate that the user wants to set
// up such shared objects, e.g. block cache, compressed block cache,
// row cache, filter policy, then InitializeOptionsGeneral() will honor
// the user's choice, thus passing `cache`,
// the user's choice, thus passing `cache`,
`block_cache_compressed`,
// `filter_policy` as input arguments.
//
// InitializeOptionsGeneral() must not overwrite fields of `options` loaded
...
...
include/rocksdb/statistics.h
浏览文件 @
a5507be8
...
...
@@ -170,6 +170,12 @@ enum Tickers : uint32_t {
// Record the number of calls to GetUpdatesSince. Useful to keep track of
// transaction log iterator refreshes
GET_UPDATES_SINCE_CALLS
,
BLOCK_CACHE_COMPRESSED_MISS
,
// miss in the compressed block cache
BLOCK_CACHE_COMPRESSED_HIT
,
// hit in the compressed block cache
// Number of blocks added to compressed block cache
BLOCK_CACHE_COMPRESSED_ADD
,
// Number of failures when adding blocks to compressed block cache
BLOCK_CACHE_COMPRESSED_ADD_FAILURES
,
WAL_FILE_SYNCED
,
// Number of times WAL sync is done
WAL_FILE_BYTES
,
// Number of bytes written to WAL
...
...
java/rocksjni/portal.h
浏览文件 @
a5507be8
...
...
@@ -4904,6 +4904,14 @@ class TickerTypeJni {
return
0x40
;
case
ROCKSDB_NAMESPACE
::
Tickers
::
GET_UPDATES_SINCE_CALLS
:
return
0x41
;
case
ROCKSDB_NAMESPACE
::
Tickers
::
BLOCK_CACHE_COMPRESSED_MISS
:
return
0x42
;
case
ROCKSDB_NAMESPACE
::
Tickers
::
BLOCK_CACHE_COMPRESSED_HIT
:
return
0x43
;
case
ROCKSDB_NAMESPACE
::
Tickers
::
BLOCK_CACHE_COMPRESSED_ADD
:
return
0x44
;
case
ROCKSDB_NAMESPACE
::
Tickers
::
BLOCK_CACHE_COMPRESSED_ADD_FAILURES
:
return
0x45
;
case
ROCKSDB_NAMESPACE
::
Tickers
::
WAL_FILE_SYNCED
:
return
0x46
;
case
ROCKSDB_NAMESPACE
::
Tickers
::
WAL_FILE_BYTES
:
...
...
@@ -5253,6 +5261,14 @@ class TickerTypeJni {
return
ROCKSDB_NAMESPACE
::
Tickers
::
NUMBER_OF_RESEEKS_IN_ITERATION
;
case
0x41
:
return
ROCKSDB_NAMESPACE
::
Tickers
::
GET_UPDATES_SINCE_CALLS
;
case
0x42
:
return
ROCKSDB_NAMESPACE
::
Tickers
::
BLOCK_CACHE_COMPRESSED_MISS
;
case
0x43
:
return
ROCKSDB_NAMESPACE
::
Tickers
::
BLOCK_CACHE_COMPRESSED_HIT
;
case
0x44
:
return
ROCKSDB_NAMESPACE
::
Tickers
::
BLOCK_CACHE_COMPRESSED_ADD
;
case
0x45
:
return
ROCKSDB_NAMESPACE
::
Tickers
::
BLOCK_CACHE_COMPRESSED_ADD_FAILURES
;
case
0x46
:
return
ROCKSDB_NAMESPACE
::
Tickers
::
WAL_FILE_SYNCED
;
case
0x47
:
...
...
java/src/main/java/org/rocksdb/TickerType.java
浏览文件 @
a5507be8
...
...
@@ -312,6 +312,26 @@ public enum TickerType {
*/
GET_UPDATES_SINCE_CALLS
((
byte
)
0x41
),
/**
* Miss in the compressed block cache.
*/
BLOCK_CACHE_COMPRESSED_MISS
((
byte
)
0x42
),
/**
* Hit in the compressed block cache.
*/
BLOCK_CACHE_COMPRESSED_HIT
((
byte
)
0x43
),
/**
* Number of blocks added to compressed block cache.
*/
BLOCK_CACHE_COMPRESSED_ADD
((
byte
)
0x44
),
/**
* Number of failures when adding blocks to compressed block cache.
*/
BLOCK_CACHE_COMPRESSED_ADD_FAILURES
((
byte
)
0x45
),
/**
* Number of times WAL sync is done.
*/
...
...
monitoring/statistics.cc
浏览文件 @
a5507be8
...
...
@@ -85,6 +85,11 @@ const std::vector<std::pair<Tickers, std::string>> TickersNameMap = {
{
BLOOM_FILTER_PREFIX_USEFUL
,
"rocksdb.bloom.filter.prefix.useful"
},
{
NUMBER_OF_RESEEKS_IN_ITERATION
,
"rocksdb.number.reseeks.iteration"
},
{
GET_UPDATES_SINCE_CALLS
,
"rocksdb.getupdatessince.calls"
},
{
BLOCK_CACHE_COMPRESSED_MISS
,
"rocksdb.block.cachecompressed.miss"
},
{
BLOCK_CACHE_COMPRESSED_HIT
,
"rocksdb.block.cachecompressed.hit"
},
{
BLOCK_CACHE_COMPRESSED_ADD
,
"rocksdb.block.cachecompressed.add"
},
{
BLOCK_CACHE_COMPRESSED_ADD_FAILURES
,
"rocksdb.block.cachecompressed.add.failures"
},
{
WAL_FILE_SYNCED
,
"rocksdb.wal.synced"
},
{
WAL_FILE_BYTES
,
"rocksdb.wal.bytes"
},
{
WRITE_DONE_BY_SELF
,
"rocksdb.write.self"
},
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录