projects
/
c11concurrency-benchmarks.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
9226a18
)
disable error checking
author
weiyu
<weiyuluo1232@gmail.com>
Wed, 9 Dec 2020 20:28:48 +0000
(12:28 -0800)
committer
weiyu
<weiyuluo1232@gmail.com>
Wed, 9 Dec 2020 20:28:48 +0000
(12:28 -0800)
mabain/examples/mb_multi_thread_insert_test.cpp
patch
|
blob
|
history
diff --git
a/mabain/examples/mb_multi_thread_insert_test.cpp
b/mabain/examples/mb_multi_thread_insert_test.cpp
index 7e73ec0a4e6c1b25d32dea71986ec5005ce83ab5..0d790b99dbffa5ec8edca0063a6ba011152cb61e 100644
(file)
--- a/
mabain/examples/mb_multi_thread_insert_test.cpp
+++ b/
mabain/examples/mb_multi_thread_insert_test.cpp
@@
-28,7
+28,7
@@
using namespace mabain;
using namespace mabain;
-static int max_key = 100000
0
;
+static int max_key = 100000;
static std::atomic<int> write_index;
static bool stop_processing = false;
static std::string mbdir = "./multi_test/";
static std::atomic<int> write_index;
static bool stop_processing = false;
static std::string mbdir = "./multi_test/";
@@
-45,7
+45,8
@@
static void* insert_thread(void *arg)
curr_key = write_index.fetch_add(1, std::memory_order_release);
kv = mkey.get_key(curr_key);
if(curr_key < max_key) {
curr_key = write_index.fetch_add(1, std::memory_order_release);
kv = mkey.get_key(curr_key);
if(curr_key < max_key) {
- assert(db_r->Add(kv, kv) == MBError::SUCCESS);
+ db_r->Add(kv, kv);
+// assert(db_r->Add(kv, kv) == MBError::SUCCESS);
} else {
stop_processing = true;
break;
} else {
stop_processing = true;
break;
@@
-79,8
+80,9
@@
static void Lookup()
for(int i = 0; i < max_key; i++) {
kv = mkey.get_key(i);
for(int i = 0; i < max_key; i++) {
kv = mkey.get_key(i);
- assert(db_r->Find(kv, mbd) == MBError::SUCCESS);
- assert(kv == std::string((const char *)mbd.buff, mbd.data_len));
+ db_r->Find(kv, mbd);
+// assert(db_r->Find(kv, mbd) == MBError::SUCCESS);
+// assert(kv == std::string((const char *)mbd.buff, mbd.data_len));
}
db_r->Close();
delete db_r;
}
db_r->Close();
delete db_r;