X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FPPI%2FModule.cc;h=40f743bc6be4c1050fdf8e495c689354a644b690;hb=refs%2Fheads%2Fmaster;hp=449bf2b81d57204220113906c465afe3c1f28188;hpb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;p=senf.git

diff --git a/senf/PPI/Module.cc b/senf/PPI/Module.cc
index 449bf2b..40f743b 100644
--- a/senf/PPI/Module.cc
+++ b/senf/PPI/Module.cc
@@ -2,23 +2,28 @@
 //
 // Copyright (C) 2007
 // Fraunhofer Institute for Open Communication Systems (FOKUS)
-// Competence Center NETwork research (NET), St. Augustin, GERMANY
-//     Stefan Bund <g0dil@berlios.de>
 //
-// This program is free software; you can redistribute it and/or modify
-// it under the terms of the GNU General Public License as published by
-// the Free Software Foundation; either version 2 of the License, or
-// (at your option) any later version.
+// The contents of this file are subject to the Fraunhofer FOKUS Public License
+// Version 1.0 (the "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at 
+// http://senf.berlios.de/license.html
 //
-// This program is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-// GNU General Public License for more details.
+// The Fraunhofer FOKUS Public License Version 1.0 is based on, 
+// but modifies the Mozilla Public License Version 1.1.
+// See the full license text for the amendments.
 //
-// You should have received a copy of the GNU General Public License
-// along with this program; if not, write to the
-// Free Software Foundation, Inc.,
-// 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+// Software distributed under the License is distributed on an "AS IS" basis, 
+// WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License 
+// for the specific language governing rights and limitations under the License.
+//
+// The Original Code is Fraunhofer FOKUS code.
+//
+// The Initial Developer of the Original Code is Fraunhofer-Gesellschaft e.V. 
+// (registered association), Hansastraße 27 c, 80686 Munich, Germany.
+// All Rights Reserved.
+//
+// Contributor(s):
+//   Stefan Bund <g0dil@berlios.de>
 
 /** \file
     \brief Module non-inline non-template implementation */
@@ -27,12 +32,96 @@
 #include "Module.ih"
 
 // Custom includes
+#include "Events.hh"
+#include "Connectors.hh"
 
 //#include "Module.mpp"
 #define prefix_
-///////////////////////////////cc.p////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
+
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
+// senf::ppi::module::Module
+
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
+// public members
+
+#ifdef DOXYGEN
+
+prefix_ senf::ppi::Route<connector::InputConnector, connector::OutputConnector> &
+senf::ppi::module::Module::route(connector::InputConnector & input,
+                                 connector::OutputConnector & output)
+{}
+prefix_ senf::ppi::Route<connector::InputConnector, EventDescriptor> &
+senf::ppi::module::Module::route(connector::InputConnector & input, EventDescriptor & output)
+{}
+
+prefix_ senf::ppi::RouteRoute<connector::EventDescriptor, connector::OutputConnector> &
+senf::ppi::module::Module::route(EventDescriptor & input, connector::OutputConnector & output);
+
+#else
+
+#define route_impl( Source, Target )                                                        \
+    prefix_ senf::ppi::Route<senf::ppi::Source, senf::ppi::Target> &                        \
+    senf::ppi::module::Module::route(Source & source, Target & target)                      \
+    {                                                                                       \
+        detail::RouteHelper<Source,Target>::route(*this, source, target, source, target);   \
+        return static_cast< Route<Source,Target> & >(                                       \
+                addRoute(std::auto_ptr< RouteBase >(                                        \
+                     new Route<Source,Target>(*this, source, target))));                    \
+    }
+
+route_impl( connector::GenericPassiveInput, connector::GenericActiveOutput);
+route_impl( connector::GenericActiveInput, connector::GenericPassiveOutput);
+route_impl( connector::GenericActiveInput, connector::GenericActiveOutput);
+route_impl( connector::GenericPassiveInput, connector::GenericPassiveOutput);
+route_impl( connector::GenericPassiveInput, EventDescriptor);
+route_impl( connector::GenericActiveInput, EventDescriptor);
+route_impl( EventDescriptor, connector::GenericPassiveOutput);
+route_impl( EventDescriptor, connector::GenericActiveOutput);
+
+#undef route_impl
+
+#endif
+
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
+// private members
+
+prefix_ void senf::ppi::module::Module::registerConnector(connector::Connector & connector)
+{
+    if (std::find(connectorRegistry_.begin(), connectorRegistry_.end(), &connector)
+        == connectorRegistry_.end()) {
+        connectorRegistry_.push_back(&connector);
+        connector.setModule(*this);
+    }
+}
+
+prefix_ void senf::ppi::module::Module::unregisterConnector(connector::Connector & connector)
+{
+    ConnectorRegistry::iterator i (std::find(connectorRegistry_.begin(), connectorRegistry_.end(),
+                                             &connector));
+    if (i != connectorRegistry_.end())
+        connectorRegistry_.erase(i);
+
+    routes_.erase_if(boost::bind(&RouteBase::hasConnector, _1, boost::cref(connector)));
+}
+
+prefix_ senf::ppi::RouteBase &
+senf::ppi::module::Module::addRoute(std::auto_ptr<RouteBase> route)
+{
+    routes_.push_back(route.release());
+    return routes_.back();
+}
+
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
+// protected members
+
+prefix_ void senf::ppi::module::Module::noroute(connector::Connector & connector)
+{
+    registerConnector(connector);
+    connector.setModule(*this);
+}
 
-///////////////////////////////cc.e////////////////////////////////////////
+//-/////////////////////////////////////////////////////////////////////////////////////////////////
 #undef prefix_
 //#include "Module.mpp"