// $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>
UserContainerModule()
{
- noroute(input);
+ noroute(input);
input.onRequest(&UserContainerModule::request);
}
void connectorDestroy(ConnectorType const * c)
{
Connectors::iterator i (
- std::find_if(connectors_.begin(), connectors_.end(),
+ std::find_if(connectors_.begin(), connectors_.end(),
boost::bind(&Connectors::value_type::get,_1) == c));
if (i != connectors_.end())
connectors_.erase(i);
}
Connectors connectors_;
-
+
friend class module::MultiConnectorMixin<UserContainerModule, connector::ActiveOutput<>, void, void>;
};
-
+
struct IntAnnotation {
int value;
bool operator<(IntAnnotation const & other) const { return value < other.value; }
module::PassiveJoin join2;
module::AnnotationRouter<IntAnnotation> router;
UserContainerModule module;
-
+
ppi::connect(source, join1);
ppi::connect(join1, router);
ppi::connect(router, 1, join2);
ppi::connect(join2, module);
ppi::connect(module, sink);
-
+
senf::Packet p (senf::DataPacket::create());
p.annotation<IntAnnotation>().value = 1;