}
-BOOST_AUTO_UNIT_TEST(passiveJoin)
+SENF_AUTO_UNIT_TEST(passiveJoin)
{
debug::ActiveSource source1;
debug::ActiveSource source2;
sink.input.throttle();
BOOST_CHECK( ! source1 );
BOOST_CHECK( ! source2 );
-
+
source1.submit(p);
source2.submit(p);
BOOST_CHECK_EQUAL( sink.size(), 2u );
BOOST_CHECK_EQUAL( join.connectors().size(), 2u);
source1.output.disconnect();
BOOST_CHECK_EQUAL( join.connectors().size(), 1u);
+ ppi::connect(source1, join);
+ ppi::init();
+ BOOST_CHECK_EQUAL( join.connectors().size(), 2u);
}
-BOOST_AUTO_UNIT_TEST(priorityJoin)
+SENF_AUTO_UNIT_TEST(priorityJoin)
{
debug::PassiveSource source1;
debug::PassiveSource source2;
senf::Packet p1 (senf::DataPacket::create());
senf::Packet p2 (senf::DataPacket::create());
-
+
source1.submit(p1);
BOOST_CHECK( sink );
source2.submit(p2);
ppi::connect(source3, join, 0);
ppi::connect(source4, join, -2);
// Ordering now: source3, source1, source4, source2
-
+
senf::Packet p3 (senf::DataPacket::create());
senf::Packet p4 (senf::DataPacket::create());
-
+
source4.submit(p4);
source3.submit(p3);
source2.submit(p2);