compile two versions of mabain

diff --git a/mabain/examples/Makefile b/mabain/examples/Makefile
index e279ae384e895dfe037ae42b385487b9fb0ce0de..564e42d27d55ffc30a6150cf896de23d26a2452a 100644 (file)
--- a/mabain/examples/Makefile
+++ b/mabain/examples/Makefile
@@ -6,7 +6,7 @@ CPP=../../clang++
 
 all: mb_insert_test mb_lookup_test mb_longest_prefix_test \
        mb_remove_test mb_iterator_test mb_multi_proc_test \
-       mb_rc_test mb_multi_thread_insert_test mb_memory_only_test
+       mb_rc_test mb_multi_thread_insert_test mb_multi_thread_insert_test_assert mb_memory_only_test
 
 CFLAGS  = -I. -I$(MABAIN_INSTALL_DIR)/include -Wall -Werror -g -O0 -c -std=c++11
 LDFLAGS = -lpthread -lcrypto -L$(MABAIN_INSTALL_DIR) -lmabain
@@ -35,6 +35,9 @@ mb_rc_test: mb_rc_test.cpp
 mb_multi_thread_insert_test: mb_multi_thread_insert_test.cpp
        $(CPP) $(CFLAGS) mb_multi_thread_insert_test.cpp
        $(CPP) mb_multi_thread_insert_test.o -o mb_multi_thread_insert_test $(LDFLAGS)
+mb_multi_thread_insert_test_assert: mb_multi_thread_insert_test.cpp
+       $(CPP) $(CFLAGS) -D ASSERT_TEST mb_multi_thread_insert_test.cpp
+       $(CPP) mb_multi_thread_insert_test.o -o mb_multi_thread_insert_test_assert $(LDFLAGS)
 mb_memory_only_test: mb_memory_only_test.cpp
        $(CPP) $(CFLAGS) mb_memory_only_test.cpp
        $(CPP) mb_memory_only_test.o -o mb_memory_only_test $(LDFLAGS)

diff --git a/mabain/examples/mb_multi_thread_insert_test.cpp b/mabain/examples/mb_multi_thread_insert_test.cpp
index 0d790b99dbffa5ec8edca0063a6ba011152cb61e..62a18536b014ea19bca10d6d504e15a7307588f0 100644 (file)
--- a/mabain/examples/mb_multi_thread_insert_test.cpp
+++ b/mabain/examples/mb_multi_thread_insert_test.cpp
@@ -26,6 +26,8 @@
 
 #include "test_key.h"
 
+//#define ASSERT_TEST
+
 using namespace mabain;
 
 static int max_key = 100000;
@@ -45,8 +47,11 @@ 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) {
-                       db_r->Add(kv, kv);
-//            assert(db_r->Add(kv, kv) == MBError::SUCCESS);
+#ifdef ASSERT_TEST
+            assert(db_r->Add(kv, kv) == MBError::SUCCESS);
+#else
+            db_r->Add(kv, kv);
+#endif
         } else {
             stop_processing = true;
             break;
@@ -80,9 +85,12 @@ static void Lookup()
 
     for(int i = 0; i < max_key; i++) {
         kv = mkey.get_key(i);
-               db_r->Find(kv, mbd);
-//        assert(db_r->Find(kv, mbd) == MBError::SUCCESS);
-//        assert(kv == std::string((const char *)mbd.buff, mbd.data_len));
+#ifdef ASSERT_TEST
+        assert(db_r->Find(kv, mbd) == MBError::SUCCESS);
+        assert(kv == std::string((const char *)mbd.buff, mbd.data_len));
+#else
+        db_r->Find(kv, mbd);
+#endif
     }
     db_r->Close();
     delete db_r;