// $Id$
//
-// Copyright (C) 2009
+// Copyright (C) 2009
// Fraunhofer Institute for Open Communication Systems (FOKUS)
// Competence Center NETwork research (NET), St. Augustin, GERMANY
// Stefan Bund <g0dil@berlios.de>
//#include "MultiConnectorMixin.test.ih"
// Custom includes
-#include "PPI.hh"
+#include "MultiConnectorMixin.hh"
+#include "DebugModules.hh"
+#include "Joins.hh"
+#include "AnnotationRouter.hh"
#include <senf/Utils/auto_unit_test.hh>
#include <boost/test/test_tools.hpp>
#define prefix_
///////////////////////////////cc.p////////////////////////////////////////
-
namespace ppi = senf::ppi;
namespace connector = ppi::connector;
namespace module = ppi::module;
namespace debug = module::debug;
namespace {
- // We only test the user-collection case, all other cases are already handled by
- // existing modules
+
+ // Primitive join
+ class SequenceContainerModule
+ : public module::Module,
+ public module::MultiConnectorMixin<SequenceContainerModule, connector::PassiveInput<> >
+ {
+ SENF_PPI_MODULE(SequenceContainerModule);
+ typedef module::MultiConnectorMixin<SequenceContainerModule, connector::PassiveInput<> > base;
+
+ public:
+ connector::ActiveOutput<> output;
+
+ using base::connectors;
+
+ SequenceContainerModule() : count (0u)
+ {
+ noroute(output);
+ }
+
+ unsigned count;
+
+ private:
+ void connectorSetup(connector::PassiveInput<> & c)
+ {
+ route(c, output);
+ c.onRequest(boost::bind(&SequenceContainerModule::request, this, boost::ref(c)));
+ ++ count;
+ }
+
+ void connectorDestroy(connector::PassiveInput<> const & c)
+ {
+ -- count;
+ }
+
+ void request(connector::PassiveInput<> & c)
+ {
+ output(c());
+ }
+
+ friend class module::MultiConnectorMixin<SequenceContainerModule, connector::PassiveInput<> >;
+ };
// Primitive duplicator
- class MyModule
+ class UserContainerModule
: public module::Module,
- public module::MultiConnectorMixin<MyModule, connector::ActiveOutput<>, void, void>
+ public module::MultiConnectorMixin<UserContainerModule, connector::ActiveOutput<>, void, void>
{
- SENF_PPI_MODULE(MyModule);
+ SENF_PPI_MODULE(UserContainerModule);
+ typedef std::vector< boost::shared_ptr<UserContainerModule::ConnectorType> > Connectors;
public:
connector::PassiveInput<> input;
- MyModule()
+ UserContainerModule()
{
- noroute(input);
- input.onRequest(&MyModule::request);
+ noroute(input);
+ input.onRequest(&UserContainerModule::request);
}
+ Connectors const & connectors() const
+ { return connectors_; }
+
private:
void connectorSetup(std::auto_ptr<ConnectorType> c)
{
connectors_.push_back(boost::shared_ptr<ConnectorType>(c));
}
+ void connectorDestroy(ConnectorType const * c)
+ {
+ Connectors::iterator i (
+ std::find_if(connectors_.begin(), connectors_.end(),
+ boost::bind(&Connectors::value_type::get,_1) == c));
+ if (i != connectors_.end())
+ connectors_.erase(i);
+ }
+
void request()
{
senf::Packet p (input());
(**i)(p);
}
- typedef std::vector< boost::shared_ptr<MyModule::ConnectorType> > Connectors;
Connectors connectors_;
-
- friend class module::MultiConnectorMixin<MyModule, connector::ActiveOutput<>, void, void>;
+
+ friend class module::MultiConnectorMixin<UserContainerModule, connector::ActiveOutput<>, void, void>;
};
-
+
struct IntAnnotation {
int value;
bool operator<(IntAnnotation const & other) const { return value < other.value; }
{ os << value.value; return os; }
}
-BOOST_AUTO_UNIT_TEST(multiConnectorTraits)
+SENF_AUTO_UNIT_TEST(multiConnectorMixin_sequenceContainer)
{
- BOOST_STATIC_ASSERT( senf::ppi::module::detail::is_multiconnector_source<MyModule>::value );
- BOOST_STATIC_ASSERT( ! senf::ppi::module::detail::is_multiconnector_target<MyModule>::value );
-}
+ debug::ActiveSource source1;
+ debug::ActiveSource source2;
+ SequenceContainerModule module;
+ debug::PassiveSink sink;
+
+ ppi::connect(source1, module);
+ ppi::connect(source2, module);
+ ppi::connect(module, sink);
+ ppi::init();
+ senf::Packet p (senf::DataPacket::create());
+
+ source1.submit(p);
+ BOOST_CHECK_EQUAL( sink.size(), 1u );
+ BOOST_CHECK( sink.pop_front() == p );
+ source2.submit(p);
+ BOOST_CHECK_EQUAL( sink.size(), 1u );
+ BOOST_CHECK( sink.pop_front() == p );
-BOOST_AUTO_UNIT_TEST(multiConnectorMixin_userContainer)
+ BOOST_CHECK_EQUAL( module.connectors().size(), 2u );
+ BOOST_CHECK_EQUAL( module.count, 2u );
+ source1.output.disconnect();
+ BOOST_CHECK_EQUAL( module.connectors().size(), 1u );
+ BOOST_CHECK_EQUAL( module.count, 1u );
+}
+
+SENF_AUTO_UNIT_TEST(multiConnectorMixin_userContainer)
{
debug::ActiveSource source;
- MyModule module;
+ UserContainerModule module;
debug::PassiveSink sink1;
debug::PassiveSink sink2;
BOOST_CHECK_EQUAL( sink2.size(), 1u );
BOOST_CHECK( sink1.pop_front() == p );
BOOST_CHECK( sink2.pop_front() == p );
+
+ BOOST_CHECK_EQUAL( module.connectors().size(), 2u );
+ sink1.input.disconnect();
+ BOOST_CHECK_EQUAL( module.connectors().size(), 1u );
}
-BOOST_AUTO_UNIT_TEST(multiConnectorMixin_multipleModules)
+SENF_AUTO_UNIT_TEST(multiConnectorMixin_multipleModules)
{
debug::ActiveSource source;
debug::PassiveSink sink;
module::PassiveJoin join1;
module::PassiveJoin join2;
module::AnnotationRouter<IntAnnotation> router;
- MyModule module;
-
+ UserContainerModule module;
+
ppi::connect(source, join1);
ppi::connect(join1, router);
- ppi::connect(router, join2, 1);
+ ppi::connect(router, 1, join2);
ppi::connect(join2, module);
ppi::connect(module, sink);
-
+
senf::Packet p (senf::DataPacket::create());
p.annotation<IntAnnotation>().value = 1;