X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FJoins.test.cc;h=671844862402581e145f6765a0d74475671ff2ea;hb=8fd21b2b2da6c78c27ca80699cb875ed537b77c1;hp=12cc83550c1f2302596a5072105bcfc8e4fbd036;hpb=566fb4271b2aff5aa07943707f770b2a84c2738b;p=senf.git diff --git a/senf/PPI/Joins.test.cc b/senf/PPI/Joins.test.cc index 12cc835..6718448 100644 --- a/senf/PPI/Joins.test.cc +++ b/senf/PPI/Joins.test.cc @@ -143,6 +143,45 @@ SENF_AUTO_UNIT_TEST(priorityJoin) BOOST_CHECK( ! sink ); } +namespace { + struct ActiveJackSource + { + senf::ppi::connector::ActiveOutputJack<> output; + + debug::ActiveSource source1; + debug::ActiveSource source2; + + ActiveJackSource() + : output (source1.output) {} + + void flip() { + output.reset( source2.output); + } + }; +} + +//SENF_AUTO_UNIT_TEST(jack_passiveJoin) +//{ +// ActiveJackSource jackSource; +// PassiveJoin join; +// debug::PassiveSink sink; +// +// ppi::connect(jackSource, join); +// ppi::connect(join, sink); +// ppi::init(); +// +// senf::Packet p1 (senf::DataPacket::create()); +// senf::Packet p2 (senf::DataPacket::create()); +// +// jackSource.source1.submit( p1); +// BOOST_CHECK_EQUAL( sink.pop_front(), p1); +// +// jackSource.flip(); +// +// jackSource.source2.submit( p2); +// BOOST_CHECK_EQUAL( sink.pop_front(), p2); +//} + //-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_