Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
indiff7643
Terarkdb
提交
90ed555d
T
Terarkdb
项目概览
indiff7643
/
Terarkdb
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
Terarkdb
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
90ed555d
编写于
4月 08, 2020
作者:
C
chenchanglong
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
WIP:somehow compilable
上级
a219df61
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
66 addition
and
64 deletion
+66
-64
build.sh
build.sh
+48
-48
include/rocksdb/table_properties.h
include/rocksdb/table_properties.h
+7
-5
table/block_based_table_reader.cc
table/block_based_table_reader.cc
+10
-10
table/table_properties.cc
table/table_properties.cc
+1
-1
未找到文件。
build.sh
浏览文件 @
90ed555d
...
...
@@ -56,35 +56,35 @@ fi
export
BUNDLE_ALL_TERARK_STATIC
=
${
BUNDLE_ALL_TERARK_STATIC
:-
1
}
# # build targets
#
make LINK_TERARK=static \
#
EXTRA_CXXFLAGS="-DROCKSDB_VALGRIND_RUN=$VALGRIND" \
#
BMI2=$WITH_BMI2 \
#
DISABLE_WARNING_AS_ERROR=1 \
#
USE_JEMALLOC={$USE_JEMALLOC:=0} \
#
TERARKDB_ENABLE_METRICS=$TERARKDB_ENABLE_METRICS \
#
TERARKDB_ENABLE_CONSOLE=$TERARKDB_ENABLE_CONSOLE \
#
PORTABLE=$PORTABLE \
#
DEBUG_LEVEL=0 shared_lib -j $cpuNum
#
make LINK_TERARK=static \
#
EXTRA_CXXFLAGS="-DROCKSDB_VALGRIND_RUN=$VALGRIND" \
#
BMI2=$WITH_BMI2 \
#
DISABLE_WARNING_AS_ERROR=1 \
#
USE_JEMALLOC={$USE_JEMALLOC:=0} \
#
TERARKDB_ENABLE_METRICS=$TERARKDB_ENABLE_METRICS \
#
TERARKDB_ENABLE_CONSOLE=$TERARKDB_ENABLE_CONSOLE \
#
PORTABLE=$PORTABLE \
#
DEBUG_LEVEL=1 shared_lib -j $cpuNum
#
make LINK_TERARK=static \
#
EXTRA_CXXFLAGS="-DROCKSDB_VALGRIND_RUN=$VALGRIND" \
#
BMI2=$WITH_BMI2 \
#
DISABLE_WARNING_AS_ERROR=1 \
#
USE_JEMALLOC={$USE_JEMALLOC:=0} \
#
TERARKDB_ENABLE_METRICS=$TERARKDB_ENABLE_METRICS \
#
TERARKDB_ENABLE_CONSOLE=$TERARKDB_ENABLE_CONSOLE \
#
PORTABLE=$PORTABLE \
#
DEBUG_LEVEL=2 shared_lib -j $cpuNum
make
LINK_TERARK
=
static
\
EXTRA_CXXFLAGS
=
"-DROCKSDB_VALGRIND_RUN=
$VALGRIND
"
\
BMI2
=
$WITH_BMI2
\
DISABLE_WARNING_AS_ERROR
=
1
\
USE_JEMALLOC
={
$USE_JEMALLOC
:
=
0
}
\
TERARKDB_ENABLE_METRICS
=
$TERARKDB_ENABLE_METRICS
\
TERARKDB_ENABLE_CONSOLE
=
$TERARKDB_ENABLE_CONSOLE
\
PORTABLE
=
$PORTABLE
\
DEBUG_LEVEL
=
0 shared_lib
-j
$cpuNum
make
LINK_TERARK
=
static
\
EXTRA_CXXFLAGS
=
"-DROCKSDB_VALGRIND_RUN=
$VALGRIND
"
\
BMI2
=
$WITH_BMI2
\
DISABLE_WARNING_AS_ERROR
=
1
\
USE_JEMALLOC
={
$USE_JEMALLOC
:
=
0
}
\
TERARKDB_ENABLE_METRICS
=
$TERARKDB_ENABLE_METRICS
\
TERARKDB_ENABLE_CONSOLE
=
$TERARKDB_ENABLE_CONSOLE
\
PORTABLE
=
$PORTABLE
\
DEBUG_LEVEL
=
1 shared_lib
-j
$cpuNum
make
LINK_TERARK
=
static
\
EXTRA_CXXFLAGS
=
"-DROCKSDB_VALGRIND_RUN=
$VALGRIND
"
\
BMI2
=
$WITH_BMI2
\
DISABLE_WARNING_AS_ERROR
=
1
\
USE_JEMALLOC
={
$USE_JEMALLOC
:
=
0
}
\
TERARKDB_ENABLE_METRICS
=
$TERARKDB_ENABLE_METRICS
\
TERARKDB_ENABLE_CONSOLE
=
$TERARKDB_ENABLE_CONSOLE
\
PORTABLE
=
$PORTABLE
\
DEBUG_LEVEL
=
2 shared_lib
-j
$cpuNum
# static library
make
LINK_TERARK
=
static
\
...
...
@@ -97,25 +97,25 @@ make LINK_TERARK=static \
PORTABLE
=
$PORTABLE
\
DEBUG_LEVEL
=
0 static_lib
-j
$cpuNum
#
make LINK_TERARK=static \
#
EXTRA_CXXFLAGS="-DROCKSDB_VALGRIND_RUN=$VALGRIND" \
#
BMI2=$WITH_BMI2 \
#
DISABLE_WARNING_AS_ERROR=1 \
#
USE_JEMALLOC={$USE_JEMALLOC:=0} \
#
TERARKDB_ENABLE_METRICS=$TERARKDB_ENABLE_METRICS \
#
TERARKDB_ENABLE_CONSOLE=$TERARKDB_ENABLE_CONSOLE \
#
PORTABLE=$PORTABLE \
#
DEBUG_LEVEL=1 static_lib -j $cpuNum
#
make LINK_TERARK=static \
#
EXTRA_CXXFLAGS="-DROCKSDB_VALGRIND_RUN=$VALGRIND" \
#
BMI2=$WITH_BMI2 \
#
DISABLE_WARNING_AS_ERROR=1 \
#
USE_JEMALLOC={$USE_JEMALLOC:=0} \
#
TERARKDB_ENABLE_METRICS=$TERARKDB_ENABLE_METRICS \
#
TERARKDB_ENABLE_CONSOLE=$TERARKDB_ENABLE_CONSOLE \
#
PORTABLE=$PORTABLE \
#
DEBUG_LEVEL=2 static_lib -j $cpuNum
make
LINK_TERARK
=
static
\
EXTRA_CXXFLAGS
=
"-DROCKSDB_VALGRIND_RUN=
$VALGRIND
"
\
BMI2
=
$WITH_BMI2
\
DISABLE_WARNING_AS_ERROR
=
1
\
USE_JEMALLOC
={
$USE_JEMALLOC
:
=
0
}
\
TERARKDB_ENABLE_METRICS
=
$TERARKDB_ENABLE_METRICS
\
TERARKDB_ENABLE_CONSOLE
=
$TERARKDB_ENABLE_CONSOLE
\
PORTABLE
=
$PORTABLE
\
DEBUG_LEVEL
=
1 static_lib
-j
$cpuNum
make
LINK_TERARK
=
static
\
EXTRA_CXXFLAGS
=
"-DROCKSDB_VALGRIND_RUN=
$VALGRIND
"
\
BMI2
=
$WITH_BMI2
\
DISABLE_WARNING_AS_ERROR
=
1
\
USE_JEMALLOC
={
$USE_JEMALLOC
:
=
0
}
\
TERARKDB_ENABLE_METRICS
=
$TERARKDB_ENABLE_METRICS
\
TERARKDB_ENABLE_CONSOLE
=
$TERARKDB_ENABLE_CONSOLE
\
PORTABLE
=
$PORTABLE
\
DEBUG_LEVEL
=
2 static_lib
-j
$cpuNum
pkgdir
=
output
rm
-rf
$pkgdir
...
...
include/rocksdb/table_properties.h
浏览文件 @
90ed555d
...
...
@@ -238,6 +238,13 @@ struct TablePropertiesBase {
// Inheritance chain
std
::
vector
<
uint64_t
>
inheritance_chain
;
// convert this object to a human readable form
// @prop_delim: delimiter for each property.
std
::
string
ToString
(
const
std
::
string
&
prop_delim
=
"; "
,
const
std
::
string
&
kv_delim
=
"="
)
const
;
};
...
...
@@ -246,11 +253,6 @@ struct TableProperties : public TablePropertiesBase {
UserCollectedProperties
user_collected_properties
;
UserCollectedProperties
readable_properties
;
// convert this object to a human readable form
// @prop_delim: delimiter for each property.
std
::
string
ToString
(
const
std
::
string
&
prop_delim
=
"; "
,
const
std
::
string
&
kv_delim
=
"="
)
const
;
// Aggregate the numerical member variables of the specified
// TableProperties.
void
Add
(
const
TableProperties
&
tp
);
...
...
table/block_based_table_reader.cc
浏览文件 @
90ed555d
...
...
@@ -193,18 +193,18 @@ Cache::Handle* GetEntryFromCache(Cache* block_cache, const Slice& key,
// For hash based index, return true if prefix_extractor and
// prefix_extractor_block mismatch, false otherwise. This flag will be used
// as total_order_seek via NewIndexIterator
bool
PrefixExtractorChanged
(
const
TablePropertiesBase
*
table_properties
,
bool
PrefixExtractorChanged
(
const
TablePropertiesBase
*
table_properties
_base
,
const
SliceTransform
*
prefix_extractor
)
{
// BlockBasedTableOptions::kHashSearch requires prefix_extractor to be set.
// Turn off hash index in prefix_extractor is not set; if prefix_extractor
// is set but prefix_extractor_block is not set, also disable hash index
if
(
prefix_extractor
==
nullptr
||
table_properties
==
nullptr
||
table_properties_base
.
prefix_extractor_name
.
empty
())
{
if
(
prefix_extractor
==
nullptr
||
table_properties
_base
==
nullptr
||
table_properties_base
->
prefix_extractor_name
.
empty
())
{
return
true
;
}
// prefix_extractor and prefix_extractor_block are both non-empty
if
(
table_properties_base
.
prefix_extractor_name
.
compare
(
if
(
table_properties_base
->
prefix_extractor_name
.
compare
(
prefix_extractor
->
Name
())
!=
0
)
{
return
true
;
}
else
{
...
...
@@ -1174,7 +1174,7 @@ std::shared_ptr<const TableProperties> BlockBasedTable::GetTableProperties()
if
(
rep_
->
table_properties
)
{
return
rep_
->
table_properties
;
}
else
{
TableReader
::
ReadTableProperties
(
rep_
->
file
.
get
()
);
//TableReader::ReadTableProperties(rep_->file.get(), rep_->file
);
}
}
...
...
@@ -2932,7 +2932,7 @@ Status BlockBasedTable::DumpTable(WritableFile* out_file,
}
// Output TableProperties
const
rocksdb
::
TablePropertiesBase
*
table_properties
=
const
rocksdb
::
TablePropertiesBase
*
table_properties
_base
=
&
rep_
->
table_properties_base
;
if
(
rep_
->
found_table_properties
)
{
...
...
@@ -2940,18 +2940,18 @@ Status BlockBasedTable::DumpTable(WritableFile* out_file,
"Table Properties:
\n
"
"--------------------------------------
\n
"
" "
);
out_file
->
Append
(
table_properties_base
.
ToString
(
"
\n
"
,
": "
).
c_str
());
out_file
->
Append
(
table_properties_base
->
ToString
(
"
\n
"
,
": "
).
c_str
());
out_file
->
Append
(
"
\n
"
);
// Output Filter blocks
if
(
!
rep_
->
filter
&&
!
table_properties_base
.
filter_policy_name
.
empty
())
{
if
(
!
rep_
->
filter
&&
!
table_properties_base
->
filter_policy_name
.
empty
())
{
// Support only BloomFilter as off now
rocksdb
::
BlockBasedTableOptions
table_options
;
table_options
.
filter_policy
.
reset
(
rocksdb
::
NewBloomFilterPolicy
(
1
));
if
(
table_properties
->
filter_policy_name
.
compare
(
if
(
table_properties
_base
->
filter_policy_name
.
compare
(
table_options
.
filter_policy
->
Name
())
==
0
)
{
std
::
string
filter_block_key
=
kFilterBlockPrefix
;
filter_block_key
.
append
(
table_properties
->
filter_policy_name
);
filter_block_key
.
append
(
table_properties
_base
->
filter_policy_name
);
BlockHandle
handle
;
if
(
FindMetaBlock
(
meta_iter
.
get
(),
filter_block_key
,
&
handle
).
ok
())
{
BlockContents
block
;
...
...
table/table_properties.cc
浏览文件 @
90ed555d
...
...
@@ -68,7 +68,7 @@ namespace {
}
}
std
::
string
TableProperties
::
ToString
(
std
::
string
TableProperties
Base
::
ToString
(
const
std
::
string
&
prop_delim
,
const
std
::
string
&
kv_delim
)
const
{
std
::
string
result
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录