#include "Joins.hh"
#include "DebugModules.hh"
#include "Setup.hh"
-#include "../Packets/Packets.hh"
+#include <senf/Packets/Packets.hh>
-#include "../Utils/auto_unit_test.hh"
+#include <senf/Utils/auto_unit_test.hh>
#include <boost/test/test_tools.hpp>
#define prefix_
namespace module = ppi::module;
namespace debug = module::debug;
+namespace {
+
+ struct PassiveJoin : public module::PassiveJoin
+ {
+ using module::PassiveJoin::connectors;
+ };
+
+}
+
BOOST_AUTO_UNIT_TEST(passiveJoin)
{
debug::ActiveSource source1;
debug::ActiveSource source2;
- module::PassiveJoin join;
+ PassiveJoin join;
debug::PassiveSink sink;
ppi::connect(source1, join);
BOOST_CHECK_EQUAL( sink.size(), 2u );
sink.input.unthrottle();
BOOST_CHECK_EQUAL( sink.size(), 4u );
+
+ 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)