X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FRoute.hh;h=fb2930597f6d1f3d5a97950067d8c2c684aa5c22;hb=fd3a0e8ac95d1158e9ea661ddf9187b67c70169f;hp=f765152048628b9e57f28a0d285b784ebbd212e6;hpb=7465ea4f6d3d54622bd783106cf8b60d5f133343;p=senf.git diff --git a/PPI/Route.hh b/PPI/Route.hh index f765152..fb29305 100644 --- a/PPI/Route.hh +++ b/PPI/Route.hh @@ -1,6 +1,8 @@ -// Copyright (C) 2007 -// Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS) -// Kompetenzzentrum fuer Satelitenkommunikation (SatCom) +// $Id$ +// +// 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 @@ -21,8 +23,8 @@ /** \file \brief Route public header */ -#ifndef HH_Route_ -#define HH_Route_ 1 +#ifndef HH_SENF_PPI_Route_ +#define HH_SENF_PPI_Route_ 1 // Custom includes #include @@ -34,11 +36,27 @@ namespace senf { namespace ppi { + /** \brief Routing base class + + Routing information is defined within each module to define the control flow. RouteBase is + the generic base class for all routing entries. + */ class RouteBase { public: virtual ~RouteBase(); +#ifdef DOXYGEN + Source & source() const; ///< Routing source + /**< \note The real implementation is in the \c + BaseRouteImplementation template in \c Route.ih. This + class is internal and not documented. */ + Target & target() const; ///< Routing target + /**< \note The real implementation is in the \c + BaseRouteImplementation template in \c Route.ih. This + class is internal and not documented. */ +#endif + protected: RouteBase(module::Module & module); @@ -46,11 +64,17 @@ namespace ppi { module::Module * module_; }; + /** \brief Forwarding route base class + + All routes which may forward control information are based on + ForwardingRoute. ForwardingRoute provides methods to control and query the throttling + behavior. + */ class ForwardingRoute : public RouteBase { public: - bool autoThrottling(); + bool autoThrottling() const; ///< Query current autoThrottling state void autoThrottling(bool state); ///< Change automatic throttle notification forwarding /**< By default, throttle notifications are automatically forwarded from active to passive connectors. This may @@ -65,12 +89,17 @@ namespace ppi { comes in. Respective for unthrottle notifications. \param[in] state New throttle forwarding state */ + + bool throttled() const; ///< \c true, if the route is throttled + /**< This member checks only the automatic throttling + state. If autoThrottling() is \c false, this member + will always return \c false. */ protected: ForwardingRoute(module::Module & module); // Called to register this route with the connectors forwarding information base - void registerRoute(connector::ActiveConnector & connector); + template void registerRoute(T & ob); template void notifyThrottle(T & ob); template void notifyUnthrottle(T & ob); @@ -83,6 +112,7 @@ namespace ppi { // Implemented in the derived classes to forward throttling notifications virtual void v_notifyThrottle() = 0; virtual void v_notifyUnthrottle() = 0; + virtual bool v_throttled() const = 0; bool autoThrottling_; @@ -101,13 +131,23 @@ namespace ppi { Route instances are created by Module::route statements. The Route class provides an interface to manipulate the flow processing. + + Depending on the type of route, one of the following classes will be a baseclass: + +
ForwardingRoute
If the route is a \e forwarding route. This is a route + which forwards throttling notifications. This is the case, if one of the route endpoints is + a notify source (a connector::ActiveConnector) and the other is a + notify target (a connector::PassiveConnector or an EventDescriptor). + +
RouteBase
If the route is not a forwarding route, it is based directly on the + generic route base class
*/ template class Route : public detail::RouteImplementation { - typedef detail::RouteImplementation Base; private: + typedef detail::RouteImplementation Base; typedef detail::RouteImplementation Implementation; Route(module::Module & module, Source & source, Target & target);