X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FConnectors.cc;h=ce44e0d23784c73237c77ee2ba399303fb61d9a6;hb=d5a72d0b3f6fee56dba6de1c54cafb448ebe3457;hp=d8e74dcaf77819bd478937b731c0897370aafaaa;hpb=81ffa1c459b96dd44472bcef37e1e373934ee138;p=senf.git diff --git a/PPI/Connectors.cc b/PPI/Connectors.cc index d8e74dc..ce44e0d 100644 --- a/PPI/Connectors.cc +++ b/PPI/Connectors.cc @@ -1,8 +1,8 @@ // $Id$ // -// Copyright (C) 2007 -// Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS) -// Kompetenzzentrum fuer Satelitenkommunikation (SatCom) +// Copyright (C) 2007 +// Fraunhofer Institute for Open Communication Systems (FOKUS) +// Competence Center NETwork research (NET), St. Augustin, GERMANY // Stefan Bund // // This program is free software; you can redistribute it and/or modify @@ -24,32 +24,265 @@ \brief Connectors non-inline non-template implementation */ #include "Connectors.hh" -//#include "Connectors.ih" +#include "Connectors.ih" // Custom includes +#include "Route.hh" +#include "Module.hh" +#include "ModuleManager.hh" +#include "../Utils/Console/Console.hh" //#include "Connectors.mpp" #define prefix_ ///////////////////////////////cc.p//////////////////////////////////////// /////////////////////////////////////////////////////////////////////////// -// protected members - -prefix_ senf::ppi::connector::Connector::~Connector() -{} +// senf::ppi::connector::Connector prefix_ void senf::ppi::connector::Connector::connect(Connector & target) { + // The connector is not registered -> route() or noroute() statement missing + SENF_ASSERT( module_ && + "senf::ppi::connector::Connector::connect(): (source) " + "Missing route() or noroute()" ); + // The connector is already connected + SENF_ASSERT( ! peer_ && + "senf::ppi::connector::Connector::connect(): (source) " + "duplicate connection" ); + // The target connector is not registered -> route() or noroute() statement missing + SENF_ASSERT( target.module_ && + "senf::ppi::connector::Connector::connect(): (target) " + "Missing route() or noroute()" ); + // The target connector is already connected + SENF_ASSERT( ! target.peer_ && + "senf::ppi::connector::Connector::connect(): (target) " + "duplicate connection" ); + if (! (packetTypeID() == typeid(void) || + target.packetTypeID() == typeid(void) || + packetTypeID() == target.packetTypeID()) ) + throw IncompatibleConnectorsException() + << ": " << prettyName(packetTypeID()) + << " [in module " << prettyName(typeid(*module_)) << "] " + << ", " << prettyName(target.packetTypeID()) + << " [in module " << prettyName(typeid(*target.module_)) << "]"; + peer_ = & target; target.peer_ = this; + + if (! initializationScheduled()) + enqueueInitializable(); + if (! peer().initializationScheduled()) + peer().enqueueInitializable(); +} + +senf::ppi::connector::Connector::TraceState senf::ppi::connector::Connector::traceState_ ( + senf::ppi::connector::Connector::NO_TRACING); + +prefix_ void senf::ppi::connector::Connector::trace(Packet const & p, char const * label) +{ + if (traceState_ == NO_TRACING) + return; + SENF_LOG_BLOCK(({ + std::string type (prettyName(p.typeId().id())); + log << "PPI packet trace: " << label << " 0x" << std::hex << p.id() << " " + << type.substr(21, type.size()-22) << " on " << & module() << " " + << prettyName(typeid(module())) << " connector 0x" << this << "\n"; + if (traceState_ == TRACE_CONTENTS) + p.dump(log); + })); +} + +prefix_ void senf::ppi::connector::Connector::throttleTrace(char const * label, + char const * type) +{ + if (traceState_ == NO_TRACING) + return; + SENF_LOG_BLOCK(({ + log << "PPI throttling trace: " << label << " " << type << " on " << & module() + << " " << prettyName(typeid(module())) << " connector 0x" << this << "\n"; + })); +} + +namespace senf { namespace ppi { namespace connector { + + SENF_CONSOLE_REGISTER_ENUM_MEMBER( + Connector, TraceState, (NO_TRACING)(TRACE_IDS)(TRACE_CONTENTS) ); + +}}} + +namespace { + + struct ConsoleRegister + { + ConsoleRegister(); + }; + + ConsoleRegister::ConsoleRegister() + { + senf::ppi::ModuleManager::instance().consoleDir() + .add("tracing", SENF_FNP(senf::ppi::connector::Connector::TraceState, + senf::ppi::connector::Connector::tracing, ())) + .doc("Log every packet sent or received by any module.\n" + "There are three different tracing levels:\n" + "\n" + " NO_TRACING don't output any tracing information\n" + " TRACE_IDS trace packet id's but do not show packet contents\n" + " TRACE_CONTENTS trace complete packet contents\n" + "\n" + "A log message is generated whenever the packet traverses a connector. The\n" + "TRACE_IDS log message has the following format:\n" + "\n" + " PPI packet trace: \n" + " on connector \n" + " PPI throttling trace: \n" + " on connector \n" + "\n" + "The fields are:\n" + "\n" + " direction 'IN' for packets/throttle notifications entering the module,\n" + " 'OUT' for packets/throttle notifications leaving it\n" + " packet-id Numeric unique packet id. This value is unique for packets\n" + " alive at the same time, packets at different times may (and\n" + " will) share id's\n" + " packet-type The type of the packet header\n" + " module-id Unique module id\n" + " module-type Type of the module the packet is sent to/from\n" + " connector-id Unique connector id\n" + " throttle-msg Type of throttling event\n"); + + senf::ppi::ModuleManager::instance().consoleDir() + .add("tracing", SENF_FNP(void, senf::ppi::connector::Connector::tracing, + (senf::ppi::connector::Connector::TraceState))) + .arg("state", "new tracing state"); + } + + ConsoleRegister consoleRegister; + +} + +prefix_ void senf::ppi::connector::Connector::disconnect() +{ + // Cannot disconnected a non-connected connector + SENF_ASSERT( peer_ && + "senf::ppi::connector::Connector::disconnect(): Not connected" ); + Connector & peer (*peer_); + peer_ = 0; + peer.peer_ = 0; + + if (! initializationScheduled()) + enqueueInitializable(); + if (! peer.initializationScheduled()) + peer.enqueueInitializable(); +} + +prefix_ std::type_info const & senf::ppi::connector::Connector::packetTypeID() +{ + return typeid(void); +} + +/////////////////////////////////////////////////////////////////////////// +// senf::ppi::connector::PassiveConnector + +//////////////////////////////////////// +// private members + +prefix_ void senf::ppi::connector::PassiveConnector::v_init() +{ + Routes::const_iterator i (routes_.begin()); + Routes::const_iterator const i_end (routes_.end()); + for (; i != i_end; ++i) + if ((*i)->throttled()) + break; + if (i == i_end) + remoteThrottled_ = false; + if (throttled()) + emitThrottle(); + else + emitUnthrottle(); +} + +prefix_ void senf::ppi::connector::PassiveConnector::v_unthrottleEvent() +{} + +prefix_ void senf::ppi::connector::PassiveConnector::notifyUnthrottle() +{ + if (std::find_if(routes_.begin(), routes_.end(), + boost::bind(&ForwardingRoute::throttled, _1)) == routes_.end()) { + remoteThrottled_ = false; + if (!nativeThrottled_) + emitUnthrottle(); + } else + throttleTrace("OUT", "not forwarding unthrottle event"); +} + +/////////////////////////////////////////////////////////////////////////// +// senf::ppi::connector::ActiveConnector + +//////////////////////////////////////// +// private members + +prefix_ void senf::ppi::connector::ActiveConnector::v_init() +{ + if (! connected()) + notifyThrottle(); +} + +prefix_ void senf::ppi::connector::ActiveConnector::notifyThrottle() +{ + throttleTrace("IN ", "throttle"); + if (! throttled_) { + throttled_ = true; + if (throttleCallback_) + throttleCallback_(); + NotifyRoutes::const_iterator i (notifyRoutes_.begin()); + NotifyRoutes::const_iterator const i_end (notifyRoutes_.end()); + for (; i != i_end; ++i) + (*i)->notifyThrottle(); + } +} + +prefix_ void senf::ppi::connector::ActiveConnector::notifyUnthrottle() +{ + throttleTrace("IN ", "unthrottle"); + if (throttled_) { + throttled_ = false; + if (unthrottleCallback_) + unthrottleCallback_(); + NotifyRoutes::const_iterator i (notifyRoutes_.begin()); + NotifyRoutes::const_iterator const i_end (notifyRoutes_.end()); + for (; i != i_end; ++i) + (*i)->notifyUnthrottle(); + } +} + +prefix_ void senf::ppi::connector::ActiveConnector::registerRoute(ForwardingRoute & route) +{ + notifyRoutes_.push_back(&route); } /////////////////////////////////////////////////////////////////////////// // senf::ppi::connector::InputConnector +prefix_ senf::Packet senf::ppi::connector::InputConnector::operator()() +{ + if (empty()) + v_requestEvent(); + Packet p; + if (! empty()) { + p = peek(); + queue_.pop_back(); + v_dequeueEvent(); + } + trace(p, "IN "); + return p; +} + //////////////////////////////////////// // private members +prefix_ void senf::ppi::connector::InputConnector::v_requestEvent() +{} + prefix_ void senf::ppi::connector::InputConnector::v_enqueueEvent() {} @@ -57,22 +290,43 @@ prefix_ void senf::ppi::connector::InputConnector::v_dequeueEvent() {} /////////////////////////////////////////////////////////////////////////// -// senf::ppi::connector::PassiveInput +// senf::ppi::connector::GenericActiveInput + +//////////////////////////////////////// +// private members + +prefix_ void senf::ppi::connector::GenericActiveInput::v_requestEvent() +{ + request(); +} + +/////////////////////////////////////////////////////////////////////////// +// senf::ppi::connector::GenericPassiveInput //////////////////////////////////////// // private members -prefix_ void senf::ppi::connector::PassiveInput::v_enqueueEvent() +prefix_ void senf::ppi::connector::GenericPassiveInput::v_enqueueEvent() { - ///\fixme Emit notifications when qstate_ changes - qstate_ = qdisc_->update(*this, QueueingDiscipline::ENQUEUE); emit(); + qdisc_->update(*this, QueueingDiscipline::ENQUEUE); +} + +prefix_ void senf::ppi::connector::GenericPassiveInput::v_dequeueEvent() +{ + qdisc_->update(*this, QueueingDiscipline::DEQUEUE); } -prefix_ void senf::ppi::connector::PassiveInput::v_dequeueEvent() +prefix_ void senf::ppi::connector::GenericPassiveInput::v_unthrottleEvent() { - ///\fixme Emit notifications when qstate_ changes - qstate_ = qdisc_->update(*this, QueueingDiscipline::DEQUEUE); + size_type n (queueSize()); + while (n) { + emit(); + size_type nn (queueSize()); + if (n == nn) + break; + n = nn; + } } ///////////////////////////////cc.e////////////////////////////////////////