Added rudimentary test case for SetWeightHint.

Author: schlangster

project/msvc/CppReactTest.vcxproj

@@ -174,6 +174,7 @@
     <ClCompile Include="..\..\tests\src\ObserverTestQ.cpp" />
     <ClCompile Include="..\..\tests\src\OperationsTest.cpp" />
     <ClCompile Include="..\..\tests\src\OperationsTestQ.cpp" />
+    <ClCompile Include="..\..\tests\src\ParallelizationTest.cpp" />
     <ClCompile Include="..\..\tests\src\SignalTest.cpp" />
     <ClCompile Include="..\..\tests\src\SignalTestQ.cpp" />
     <ClCompile Include="..\..\tests\src\TransactionTest.cpp" />
@@ -183,6 +184,7 @@
     <ClInclude Include="..\..\tests\src\MoveTest.h" />
     <ClInclude Include="..\..\tests\src\ObserverTest.h" />
     <ClInclude Include="..\..\tests\src\OperationsTest.h" />
+    <ClInclude Include="..\..\tests\src\ParallelizationTest.h" />
     <ClInclude Include="..\..\tests\src\SignalTest.h" />
     <ClInclude Include="..\..\tests\src\TransactionTest.h" />
     <ClInclude Include="..\..\tests\src\TestUtil.h" />

project/msvc/CppReactTest.vcxproj.filters

@@ -45,6 +45,9 @@
     <ClCompile Include="..\..\tests\src\TransactionTest.cpp">
       <Filter>Source Files</Filter>
     </ClCompile>
+    <ClCompile Include="..\..\tests\src\ParallelizationTest.cpp">
+      <Filter>Source Files</Filter>
+    </ClCompile>
   </ItemGroup>
   <ItemGroup>
     <ClInclude Include="..\..\tests\src\EventStreamTest.h">
@@ -68,5 +71,8 @@
     <ClInclude Include="..\..\tests\src\TestUtil.h">
       <Filter>Header Files</Filter>
     </ClInclude>
+    <ClInclude Include="..\..\tests\src\ParallelizationTest.h">
+      <Filter>Header Files</Filter>
+    </ClInclude>
   </ItemGroup>
 </Project>

tests/src/ParallelizationTest.cpp

@@ -0,0 +1,29 @@
+
+//          Copyright Sebastian Jeckel 2014.
+// Distributed under the Boost Software License, Version 1.0.
+//    (See accompanying file LICENSE_1_0.txt or copy at
+//          http://www.boost.org/LICENSE_1_0.txt)
+
+#include "ParallelizationTest.h"
+#include "TestUtil.h"
+
+#include "react/engine/PulsecountEngine.h"
+#include "react/engine/ToposortEngine.h"
+#include "react/engine/SubtreeEngine.h"
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+namespace {
+
+using namespace react;
+
+using P1 = DomainParams<sequential_concurrent,ToposortEngine>;
+using P2 = DomainParams<parallel_concurrent,ToposortEngine>;
+using P3 = DomainParams<parallel_concurrent,PulsecountEngine>;
+using P4 = DomainParams<parallel_concurrent,SubtreeEngine>;
+
+INSTANTIATE_TYPED_TEST_CASE_P(SeqToposortQ, ParallelizationTest, P1);
+INSTANTIATE_TYPED_TEST_CASE_P(ParToposortQ, ParallelizationTest, P2);
+INSTANTIATE_TYPED_TEST_CASE_P(PulsecountQ, ParallelizationTest, P3);
+INSTANTIATE_TYPED_TEST_CASE_P(SubtreeQ, ParallelizationTest, P4);
+
+} // ~namespace

tests/src/ParallelizationTest.h

@@ -0,0 +1,63 @@
+
+//          Copyright Sebastian Jeckel 2014.
+// Distributed under the Boost Software License, Version 1.0.
+//    (See accompanying file LICENSE_1_0.txt or copy at
+//          http://www.boost.org/LICENSE_1_0.txt)
+
+#pragma once
+
+#include "gtest/gtest.h"
+
+#include "react/Domain.h"
+#include "react/Signal.h"
+#include "react/Event.h"
+#include "react/Observer.h"
+#include "react/Algorithm.h"
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+namespace {
+
+using namespace react;
+using namespace std;
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+/// ParallelizationTest fixture
+///////////////////////////////////////////////////////////////////////////////////////////////////
+template <typename TParams>
+class ParallelizationTest : public testing::Test
+{
+public:
+    template <EPropagationMode mode>
+    class MyEngine : public TParams::template EngineT<mode> {};
+
+    REACTIVE_DOMAIN(MyDomain, TParams::mode, MyEngine)
+};
+
+TYPED_TEST_CASE_P(ParallelizationTest);
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+/// Iterate1 test
+///////////////////////////////////////////////////////////////////////////////////////////////////
+TYPED_TEST_P(ParallelizationTest, WeightHint1)
+{
+    using D = typename WeightHint1::MyDomain;
+
+    auto sig = MakeVar<D>(0);
+    auto evn = MakeEventSource<D,int>();
+    auto cont = MakeContinuation<D>(sig, [] (int v) {});
+    auto obs = Observe(evn, [] (int v) {});
+
+    sig.SetWeightHint(WeightHint::heavy);
+    evn.SetWeightHint(WeightHint::automatic);
+    cont.SetWeightHint(WeightHint::light);
+    obs.SetWeightHint(WeightHint::automatic);
+}
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+REGISTER_TYPED_TEST_CASE_P
+(
+    ParallelizationTest,
+    WeightHint1
+);
+
+} // ~namespace