projects
/
c11concurrency-benchmarks.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
edits
[c11concurrency-benchmarks.git]
/
mabain
/
examples
/
mb_multi_thread_insert_test.cpp
diff --git
a/mabain/examples/mb_multi_thread_insert_test.cpp
b/mabain/examples/mb_multi_thread_insert_test.cpp
index 9a8b510fcaf31a43cd8f5c5e9f0e44109d7ff656..7e73ec0a4e6c1b25d32dea71986ec5005ce83ab5 100644
(file)
--- a/
mabain/examples/mb_multi_thread_insert_test.cpp
+++ b/
mabain/examples/mb_multi_thread_insert_test.cpp
@@
-31,7
+31,7
@@
using namespace mabain;
static int max_key = 1000000;
static std::atomic<int> write_index;
static bool stop_processing = false;
static int max_key = 1000000;
static std::atomic<int> write_index;
static bool stop_processing = false;
-static std::string mbdir = "
/var/tmp/mabain
_test/";
+static std::string mbdir = "
./multi
_test/";
static void* insert_thread(void *arg)
{
static void* insert_thread(void *arg)
{
@@
-57,7
+57,7
@@
static void* insert_thread(void *arg)
return NULL;
}
return NULL;
}
-
static
void SetTestStatus(bool success)
+void SetTestStatus(bool success)
{
std::string cmd;
if(success) {
{
std::string cmd;
if(success) {
@@
-104,7
+104,7
@@
int main(int argc, char *argv[])
std::cout << "Setting number of keys to be " << max_key << "\n";
}
std::cout << "Setting number of keys to be " << max_key << "\n";
}
- SetTestStatus(false);
+
//
SetTestStatus(false);
mabain::DB::SetLogFile(mbdir + "/mabain.log");
write_index.store(0, std::memory_order_release);
mabain::DB::SetLogFile(mbdir + "/mabain.log");
write_index.store(0, std::memory_order_release);
@@
-121,10
+121,6
@@
int main(int argc, char *argv[])
}
}
}
}
- while(!stop_processing) {
- usleep(5);
- }
-
for(int i = 0; i < nthread; i++) {
pthread_join(pid[i], NULL);
}
for(int i = 0; i < nthread; i++) {
pthread_join(pid[i], NULL);
}
@@
-135,6
+131,6
@@
int main(int argc, char *argv[])
Lookup();
mabain::DB::CloseLogFile();
Lookup();
mabain::DB::CloseLogFile();
- SetTestStatus(true);
+
//
SetTestStatus(true);
return 0;
}
return 0;
}