disable error checking
authorweiyu <weiyuluo1232@gmail.com>
Wed, 9 Dec 2020 20:28:48 +0000 (12:28 -0800)
committerweiyu <weiyuluo1232@gmail.com>
Wed, 9 Dec 2020 20:28:48 +0000 (12:28 -0800)
mabain/examples/mb_multi_thread_insert_test.cpp

index 7e73ec0a4e6c1b25d32dea71986ec5005ce83ab5..0d790b99dbffa5ec8edca0063a6ba011152cb61e 100644 (file)
@@ -28,7 +28,7 @@
 
 using namespace mabain;
 
 
 using namespace mabain;
 
-static int max_key = 1000000;
+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;