From e56e6d9ba4b3beef53d4bd20b3c8f967061aabdc Mon Sep 17 00:00:00 2001
From: Marcus Winter <marcus.winter.ext@siemens.com>
Date: Thu, 3 Nov 2016 10:07:16 +0100
Subject: [PATCH] dataflow_cpp: testing with and without main thread reuse

---
 dataflow_cpp/test/dataflow_cpp_test_simple.cc | 10 +++++++---
 dataflow_cpp/test/dataflow_cpp_test_simple.h  |  2 ++
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/dataflow_cpp/test/dataflow_cpp_test_simple.cc b/dataflow_cpp/test/dataflow_cpp_test_simple.cc
index e25186a..f4eea87 100644
--- a/dataflow_cpp/test/dataflow_cpp_test_simple.cc
+++ b/dataflow_cpp/test/dataflow_cpp_test_simple.cc
@@ -150,12 +150,12 @@ SimpleTest::SimpleTest() {
 #define MTAPI_DOMAIN_ID 1
 #define MTAPI_NODE_ID 1
 
-void SimpleTest::TestBasic() {
+void SimpleTest::TrySimple(bool reuse_main_thread) {
   // All available cores
   embb::base::CoreSet core_set(true);
   embb::mtapi::NodeAttributes node_attr;
   node_attr
-    .SetReuseMainThread(MTAPI_TRUE)
+    .SetReuseMainThread(reuse_main_thread ? MTAPI_TRUE : MTAPI_FALSE)
     .SetCoreAffinity(core_set)
     .SetMaxQueues(2);
   embb::mtapi::Node::Initialize(
@@ -163,7 +163,7 @@ void SimpleTest::TestBasic() {
     MTAPI_NODE_ID,
     node_attr);
 
-  for (int ii = 0; ii < 10000; ii++) {
+  for (int ii = 0; ii < 1000; ii++) {
     ArraySink<TEST_COUNT> asink;
     MyNetwork network(NUM_SLICES);
     MyConstantSource constant(network, 4);
@@ -226,3 +226,7 @@ void SimpleTest::TestBasic() {
   PT_EXPECT(embb_get_bytes_allocated() == 0);
 }
 
+void SimpleTest::TestBasic() {
+  TrySimple(false);
+  TrySimple(true);
+}
diff --git a/dataflow_cpp/test/dataflow_cpp_test_simple.h b/dataflow_cpp/test/dataflow_cpp_test_simple.h
index d4fc9c1..dce1b99 100644
--- a/dataflow_cpp/test/dataflow_cpp_test_simple.h
+++ b/dataflow_cpp/test/dataflow_cpp_test_simple.h
@@ -35,6 +35,8 @@ class SimpleTest : public partest::TestCase {
 
  private:
   void TestBasic();
+
+  void TrySimple(bool reuse_main_thread);
 };
 
 #endif // DATAFLOW_CPP_TEST_DATAFLOW_CPP_TEST_SIMPLE_H_
--
libgit2 0.26.0