const
{
// The connector is not connected
- SENF_ASSERT(peer_);
+ SENF_ASSERT(peer_ && "senf::ppi::connect() call missing");
return *peer_;
}
{
// The connector is not registered in the module -> probably a route() or noroute() statement is
// missing.
- SENF_ASSERT(module_);
+ SENF_ASSERT(module_ && "Connector not registered: Missing route() or noroute()");
return *module_;
}
+prefix_ void senf::ppi::connector::Connector::tracing(TraceState state)
+{
+ traceState_ = state;
+}
+
+prefix_ senf::ppi::connector::Connector::TraceState senf::ppi::connector::Connector::tracing()
+{
+ return traceState_;
+}
+
////////////////////////////////////////
// protected members
prefix_ void senf::ppi::connector::PassiveConnector::emit()
{
- // No event callback has been registered (onEvent() call missing)
- SENF_ASSERT(callback_);
+ // No event callback has been registered (onRequest() call missing)
+ SENF_ASSERT(callback_ && "senf::ppi::connector::PassiveConnector: missing onRequest()");
if (!throttled())
callback_();
}
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();
}
////////////////////////////////////////
// private members
-prefix_ void senf::ppi::connector::InputConnector::enqueue(Packet p)
+prefix_ void senf::ppi::connector::InputConnector::enqueue(Packet const & p)
{
queue_.push_front(p);
v_enqueueEvent();
return dynamic_cast<InputConnector&>(Connector::peer());
}
-prefix_ void senf::ppi::connector::OutputConnector::operator()(Packet p)
+prefix_ void senf::ppi::connector::OutputConnector::operator()(Packet const & p)
{
+ trace(p, "OUTGOING");
if (connected())
peer().enqueue(p);
}
-prefix_ void senf::ppi::connector::OutputConnector::write(Packet p)
+prefix_ void senf::ppi::connector::OutputConnector::write(Packet const & p)
{
operator()(p);
}