#702: TestTermChaining: ensure that the callback is executed on the s…

…ame node as the root for the reduce
DARMA-tasking · Aug 25, 2020 · 9cc2971 · 9cc2971
1 parent fb31ca1
commit 9cc2971
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tests/unit/termination/test_term_chaining.cc b/tests/unit/termination/test_term_chaining.cc
@@ -165,7 +165,7 @@ struct TestTermChaining : TestParallelHarness {
     EpochType epoch2 = theTerm()->makeEpochCollective();
     vt::theMsg()->pushEpoch(epoch2);
     auto msg2 = makeMessage<ChainReduceMsg>(theContext()->getNode());
-    auto cb = vt::theCB()->makeFunc<ChainReduceMsg>( &test_handler_reduce );
+    auto cb = vt::theCB()->makeSend<ChainReduceMsg, test_handler_reduce>( 0 );
     chain.add(epoch2, theCollective()->global()->reduce< vt::collective::None >(0, msg2.get(), cb));
     vt::theMsg()->popEpoch(epoch2);
     vt::theTerm()->finishedEpoch(epoch2);
@@ -188,7 +188,7 @@ struct TestTermChaining : TestParallelHarness {
     EpochType epoch2 = theTerm()->makeEpochRooted();
     vt::theMsg()->pushEpoch(epoch2);
     auto msg2 = makeMessage<ChainReduceMsg>(theContext()->getNode());
-    auto cb = vt::theCB()->makeFunc<ChainReduceMsg>( &test_handler_reduce );
+    auto cb = vt::theCB()->makeSend<ChainReduceMsg, test_handler_reduce>( 0 );
     chain.add(epoch2, theCollective()->global()->reduce< vt::collective::None >(0, msg2.get(), cb));
     vt::theMsg()->popEpoch(epoch2);
     vt::theTerm()->finishedEpoch(epoch2);