// Custom includes
#include <senf/Utils/TypeInfo.hh>
#include <senf/Utils/senfassert.hh>
+#include "Module.hh"
#define prefix_ inline
///////////////////////////////cci.p///////////////////////////////////////
return peer_;
}
+prefix_ void senf::ppi::connector::Connector::unregisterConnector()
+{
+ if (module_)
+ module_->unregisterConnector(*this);
+}
+
////////////////////////////////////////
// private members
routes_.push_back(&route);
}
-// public members
+prefix_ void senf::ppi::connector::PassiveConnector::unregisterRoute(ForwardingRoute & route)
+{
+ Routes::iterator i (std::find(routes_.begin(), routes_.end(), &route));
+ if (i != routes_.end())
+ routes_.erase(i);
+}
+
+// public members
prefix_ bool senf::ppi::connector::PassiveConnector::nativeThrottled()
const
const
{
// Cannot peek() head of empty queue
- SENF_ASSERT( ! queue_.empty() &&
+ SENF_ASSERT( ! queue_.empty() &&
"senf::ppi::connector::InputConnector: cannot call peek() on empty queue" );
return queue_.back();
}