update test
15
README.md
@ -1,13 +1,18 @@
|
|||||||
# mace 0.0.22 vs rocksdb 10.4.2
|
# mace 0.0.22 vs rocksdb 10.4.2
|
||||||
|
|
||||||
## insert performance (sequential)
|
## sequential insert
|
||||||

|

|
||||||
|
|
||||||

|

|
||||||
|
|
||||||
|
## random insert
|
||||||
|

|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
## random get performance (warm get)
|
## random get (warm get)
|
||||||
|
|
||||||

|

|
||||||
|
|
||||||
@ -21,7 +26,7 @@
|
|||||||
|
|
||||||

|

|
||||||
|
|
||||||
# sequential scan perfomance (warm scan)
|
# sequential scan (warm scan)
|
||||||
|
|
||||||

|

|
||||||
|
|
||||||
|
|||||||
@ -282,6 +282,13 @@ int main(int argc, char *argv[]) {
|
|||||||
return args.mode == "insert" ? 100 : 0;
|
return args.mode == "insert" ? 100 : 0;
|
||||||
}();
|
}();
|
||||||
uint64_t ops = total_op.load(std::memory_order_relaxed) / b.elapse_sec();
|
uint64_t ops = total_op.load(std::memory_order_relaxed) / b.elapse_sec();
|
||||||
|
if (args.mode == "insert") {
|
||||||
|
if (args.random) {
|
||||||
|
args.mode = "random_insert";
|
||||||
|
} else {
|
||||||
|
args.mode = "sequential_insert";
|
||||||
|
}
|
||||||
|
}
|
||||||
fmt::println("{},{},{},{},{},{},{}", args.mode, args.threads, args.key_size, args.value_size, ratio, (uint64_t) ops,
|
fmt::println("{},{},{},{},{},{},{}", args.mode, args.threads, args.key_size, args.value_size, ratio, (uint64_t) ops,
|
||||||
(uint64_t) b.elapse_ms());
|
(uint64_t) b.elapse_ms());
|
||||||
db->ReleaseSnapshot(snapshot);
|
db->ReleaseSnapshot(snapshot);
|
||||||
|
|||||||
@ -24,6 +24,15 @@ function samples() {
|
|||||||
do
|
do
|
||||||
for ((k = 0; k < ${#mode[@]}; k += 1))
|
for ((k = 0; k < ${#mode[@]}; k += 1))
|
||||||
do
|
do
|
||||||
|
if [ "${mode[k]}" == "insert" ]
|
||||||
|
then
|
||||||
|
./target/release/kv_bench --path $db_root --threads $i --iterations $cnt --mode ${mode[k]} --key-size ${kv_sz[j]} --value-size ${kv_sz[j+1]} --random
|
||||||
|
if test $? -ne 0
|
||||||
|
then
|
||||||
|
echo "${mode[k]} threads $i ksz ${kv_sz[j]} vsz ${kv_sz[j+1]} random fail"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
fi
|
||||||
./target/release/kv_bench --path $db_root --threads $i --iterations $cnt --mode ${mode[k]} --key-size ${kv_sz[j]} --value-size ${kv_sz[j+1]}
|
./target/release/kv_bench --path $db_root --threads $i --iterations $cnt --mode ${mode[k]} --key-size ${kv_sz[j]} --value-size ${kv_sz[j+1]}
|
||||||
if test $? -ne 0
|
if test $? -ne 0
|
||||||
then
|
then
|
||||||
|
|||||||
|
Before Width: | Height: | Size: 142 KiB After Width: | Height: | Size: 135 KiB |
|
Before Width: | Height: | Size: 123 KiB |
|
Before Width: | Height: | Size: 131 KiB After Width: | Height: | Size: 131 KiB |
|
Before Width: | Height: | Size: 141 KiB After Width: | Height: | Size: 144 KiB |
@ -23,13 +23,22 @@ function samples() {
|
|||||||
do
|
do
|
||||||
for ((k = 0; k < ${#mode[@]}; k += 1))
|
for ((k = 0; k < ${#mode[@]}; k += 1))
|
||||||
do
|
do
|
||||||
|
if [ "${mode[k]}" == "insert" ]
|
||||||
|
then
|
||||||
|
./build/release/rocksdb_bench --path $db_root --threads $i --iterations $cnt --mode ${mode[k]} --key-size ${kv_sz[j]} --value-size ${kv_sz[j+1]} --random 1
|
||||||
|
if test $? -ne 0
|
||||||
|
then
|
||||||
|
echo "${mode[k]} threads $i ksz ${kv_sz[j]} vsz ${kv_sz[j+1]} random fail"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
fi
|
||||||
./build/release/rocksdb_bench --path $db_root --threads $i --iterations $cnt --mode ${mode[k]} --key-size ${kv_sz[j]} --value-size ${kv_sz[j+1]}
|
./build/release/rocksdb_bench --path $db_root --threads $i --iterations $cnt --mode ${mode[k]} --key-size ${kv_sz[j]} --value-size ${kv_sz[j+1]}
|
||||||
if test $? -ne 0
|
if test $? -ne 0
|
||||||
then
|
then
|
||||||
echo "${mode[k]} threads $i ksz ${kv_sz[j]} vsz ${kv_sz[j+1]} fail"
|
echo "${mode[k]} threads $i ksz ${kv_sz[j]} vsz ${kv_sz[j+1]} fail"
|
||||||
exit 1
|
exit 1
|
||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
done
|
done
|
||||||
done
|
done
|
||||||
}
|
}
|
||||||
|
|||||||
|
Before Width: | Height: | Size: 148 KiB After Width: | Height: | Size: 137 KiB |
|
Before Width: | Height: | Size: 122 KiB |
|
Before Width: | Height: | Size: 142 KiB After Width: | Height: | Size: 132 KiB |
|
Before Width: | Height: | Size: 115 KiB After Width: | Height: | Size: 129 KiB |
@ -52,7 +52,7 @@ fn main() {
|
|||||||
Logger::init().add_file("/tmp/x.log", true);
|
Logger::init().add_file("/tmp/x.log", true);
|
||||||
log::set_max_level(log::LevelFilter::Info);
|
log::set_max_level(log::LevelFilter::Info);
|
||||||
}
|
}
|
||||||
let args = Args::parse();
|
let mut args = Args::parse();
|
||||||
|
|
||||||
let path = Path::new(&args.path);
|
let path = Path::new(&args.path);
|
||||||
|
|
||||||
@ -217,6 +217,13 @@ fn main() {
|
|||||||
} else {
|
} else {
|
||||||
0
|
0
|
||||||
};
|
};
|
||||||
|
if args.mode == "insert" {
|
||||||
|
if args.random {
|
||||||
|
args.mode = "random_insert".into();
|
||||||
|
} else {
|
||||||
|
args.mode = "sequential_insert".into();
|
||||||
|
}
|
||||||
|
}
|
||||||
eprintln!(
|
eprintln!(
|
||||||
"{},{},{},{},{},{},{}",
|
"{},{},{},{},{},{},{}",
|
||||||
args.mode,
|
args.mode,
|
||||||
|
|||||||