diff --git a/tests/unit/termination/test_term_chaining.cc b/tests/unit/termination/test_term_chaining.cc index 7319be8c98..12808e6a3b 100644 --- a/tests/unit/termination/test_term_chaining.cc +++ b/tests/unit/termination/test_term_chaining.cc @@ -136,7 +136,7 @@ struct TestTermChaining : TestParallelHarness { } static void start_chain() { - EpochType epoch1 = theTerm()->makeEpochRooted(); + EpochType epoch1 = theTerm()->makeEpochRooted("rooted epoch 1"); vt::theMsg()->pushEpoch(epoch1); auto msg = makeMessage(); chain.add( @@ -145,7 +145,7 @@ struct TestTermChaining : TestParallelHarness { vt::theMsg()->popEpoch(epoch1); vt::theTerm()->finishedEpoch(epoch1); - EpochType epoch2 = theTerm()->makeEpochRooted(); + EpochType epoch2 = theTerm()->makeEpochRooted("rooted epoch 2"); vt::theMsg()->pushEpoch(epoch2); auto msg2 = makeMessage(); chain.add( @@ -213,7 +213,7 @@ TEST_F(TestTermChaining, test_termination_chaining_1) { auto const& this_node = theContext()->getNode(); - epoch = theTerm()->makeEpochCollective(); + epoch = theTerm()->makeEpochCollective("top chain"); handler_count = 0; @@ -224,16 +224,18 @@ TEST_F(TestTermChaining, test_termination_chaining_1) { start_chain(); theTerm()->finishedEpoch(epoch); theMsg()->popEpoch(epoch); - fmt::print("before run 1\n"); + vt_print(gen, "before run 1\n"); vt::runSchedulerThrough(epoch); - fmt::print("after run 1\n"); + vt_print(gen, "after run 1\n"); EXPECT_EQ(handler_count, 4); } else { theMsg()->pushEpoch(epoch); theTerm()->finishedEpoch(epoch); theMsg()->popEpoch(epoch); + vt_print(gen, "before run 1 (other)\n"); vt::runSchedulerThrough(epoch); + vt_print(gen, "after run 1 (other)\n"); EXPECT_EQ(handler_count, 13); } }