dataflow_cpp: increased number of task queues in unit test

dataflow_cpp/test/dataflow_cpp_test_simple.cc

@@ -142,8 +142,22 @@ SimpleTest::SimpleTest() {
   CreateUnit("dataflow_cpp simple test").Add(&SimpleTest::TestBasic, this);
   CreateUnit("dataflow_cpp simple test").Add(&SimpleTest::TestBasic, this);
 }
 }
 
 
+#define MTAPI_DOMAIN_ID 1
+#define MTAPI_NODE_ID 1
+
 void SimpleTest::TestBasic() {
 void SimpleTest::TestBasic() {
-  embb::tasks::Node::Initialize(1, 1);
+  // All available cores
+  embb::base::CoreSet core_set(true);
+  embb::tasks::Node::Initialize(
+    MTAPI_DOMAIN_ID,
+    MTAPI_NODE_ID,
+    core_set,
+    1024, // max tasks (default: 1024)
+    128,  // max groups (default: 128)
+    128,  // max queues (default: 16)
+    1024, // queue capacity (default: 1024)
+    4     // num priorities (default: 4)
+  );
 
 
   for (int ii = 0; ii < 10000; ii++) {
   for (int ii = 0; ii < 10000; ii++) {
     ArraySink<TEST_COUNT> asink;
     ArraySink<TEST_COUNT> asink;
@@ -163,6 +177,7 @@ void SimpleTest::TestBasic() {
       filter_array[kk] = -1;
       filter_array[kk] = -1;
       mult_array[kk] = -1;
       mult_array[kk] = -1;
     }
     }
+
     source_counter = 0;
     source_counter = 0;
     pred_counter = 0;
     pred_counter = 0;
     mult_counter = 0;
     mult_counter = 0;
@@ -198,3 +213,4 @@ void SimpleTest::TestBasic() {
 
 
   PT_EXPECT(embb_get_bytes_allocated() == 0);
   PT_EXPECT(embb_get_bytes_allocated() == 0);
 }
 }
+