PPI/Connectors.cci

   1 // $Id$
   2 //
   3 // Copyright (C) 2007
   4 // Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS)
   5 // Kompetenzzentrum fuer Satelitenkommunikation (SatCom)
   6 //     Stefan Bund <g0dil@berlios.de>
   7 //
   8 // This program is free software; you can redistribute it and/or modify
   9 // it under the terms of the GNU General Public License as published by
  10 // the Free Software Foundation; either version 2 of the License, or
  11 // (at your option) any later version.
  12 //
  13 // This program is distributed in the hope that it will be useful,
  14 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  15 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16 // GNU General Public License for more details.
  17 //
  18 // You should have received a copy of the GNU General Public License
  19 // along with this program; if not, write to the
  20 // Free Software Foundation, Inc.,
  21 // 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
  22
  23 /** \file
  24     \brief Connectors inline non-template implementation */
  25
  26 // Custom includes
  27
  28 #define prefix_ inline
  29 ///////////////////////////////cci.p///////////////////////////////////////
  30
  31 ///////////////////////////////////////////////////////////////////////////
  32 // senf::ppi::connector::Connector
  33
  34 prefix_ senf::ppi::connector::Connector & senf::ppi::connector::Connector::peer()
  35 {
  36     BOOST_ASSERT(peer_);
  37     return *peer_;
  38 }
  39
  40 prefix_ senf::ppi::module::Module & senf::ppi::connector::Connector::module()
  41 {
  42     BOOST_ASSERT(module_);
  43     return *module_;
  44 }
  45
  46 ////////////////////////////////////////
  47 // protected members
  48
  49 prefix_ senf::ppi::connector::Connector::Connector()
  50     : peer_(), module_()
  51 {}
  52
  53 ////////////////////////////////////////
  54 // private members
  55
  56 prefix_ void senf::ppi::connector::Connector::setModule(module::Module & module)
  57 {
  58     module_ = &module;
  59 }
  60
  61 ///////////////////////////////////////////////////////////////////////////
  62 // senf::ppi::connector::ActiveConnector
  63
  64 ////////////////////////////////////////
  65 // protected members
  66
  67 prefix_ senf::ppi::connector::ActiveConnector::ActiveConnector()
  68 {}
  69
  70 ///////////////////////////////////////////////////////////////////////////
  71 // senf::ppi::connector::PassiveConnector
  72
  73 prefix_ senf::ppi::connector::ActiveConnector & senf::ppi::connector::PassiveConnector::peer()
  74 {
  75     return dynamic_cast<ActiveConnector&>(Connector::peer());
  76 }
  77
  78 ////////////////////////////////////////
  79 // protected members
  80
  81 prefix_ senf::ppi::connector::PassiveConnector::PassiveConnector()
  82     : callback_()
  83 {}
  84
  85 prefix_ void senf::ppi::connector::PassiveConnector::emit()
  86 {
  87     BOOST_ASSERT(callback_);
  88     callback_();
  89 }
  90
  91 ///////////////////////////////////////////////////////////////////////////
  92 // senf::ppi::connector::InputConnector
  93
  94 prefix_ senf::Packet senf::ppi::connector::InputConnector::operator()()
  95 {
  96     Packet p (queue_.back());
  97     queue_.pop_back();
  98     v_dequeueEvent();
  99     return p;
 100 }
 101
 102 prefix_ bool senf::ppi::connector::InputConnector::boolean_test()
 103 {
 104     ///\fixme Add additional active/passive throttle/unthrottle conditions (make virtual ?)
 105     return ! empty();
 106 }
 107
 108 prefix_ senf::ppi::connector::OutputConnector & senf::ppi::connector::InputConnector::peer()
 109 {
 110     return dynamic_cast<OutputConnector &>(Connector::peer());
 111 }
 112
 113 prefix_ senf::ppi::connector::InputConnector::queue_iterator
 114 senf::ppi::connector::InputConnector::begin()
 115 {
 116     return queue_.begin();
 117 }
 118
 119 prefix_ senf::ppi::connector::InputConnector::queue_iterator
 120 senf::ppi::connector::InputConnector::end()
 121 {
 122     return queue_.end();
 123 }
 124
 125 prefix_ senf::Packet senf::ppi::connector::InputConnector::peek()
 126 {
 127     return queue_.back();
 128 }
 129
 130 prefix_ senf::ppi::connector::InputConnector::size_type
 131 senf::ppi::connector::InputConnector::queueSize()
 132 {
 133     return queue_.size();
 134 }
 135
 136 prefix_ bool senf::ppi::connector::InputConnector::empty()
 137 {
 138     return queue_.empty();
 139 }
 140
 141 ////////////////////////////////////////
 142 // protected members
 143
 144 prefix_ senf::ppi::connector::InputConnector::InputConnector()
 145 {}
 146
 147 ////////////////////////////////////////
 148 // private members
 149
 150 prefix_ void senf::ppi::connector::InputConnector::enqueue(Packet p)
 151 {
 152     queue_.push_front(p);
 153     v_enqueueEvent();
 154 }
 155
 156 ///////////////////////////////////////////////////////////////////////////
 157 // senf::ppi::connector::OutputConnector
 158
 159 prefix_ void senf::ppi::connector::OutputConnector::operator()(Packet p)
 160 {
 161     peer().enqueue(p);
 162 }
 163
 164 prefix_ senf::ppi::connector::InputConnector & senf::ppi::connector::OutputConnector::peer()
 165 {
 166     return dynamic_cast<InputConnector&>(Connector::peer());
 167 }
 168
 169 ////////////////////////////////////////
 170 // protected members
 171
 172 prefix_ senf::ppi::connector::OutputConnector::OutputConnector()
 173 {}
 174
 175 ///////////////////////////////////////////////////////////////////////////
 176 // senf::ppi::connector::PassiveInput
 177
 178 prefix_ senf::ppi::connector::PassiveInput::PassiveInput()
 179     : qdisc_(), qstate_(QueueingDiscipline::UNTHROTTLED)
 180 {}
 181
 182 prefix_ senf::ppi::connector::ActiveOutput & senf::ppi::connector::PassiveInput::peer()
 183 {
 184     return dynamic_cast<ActiveOutput&>(Connector::peer());
 185 }
 186
 187 ///////////////////////////////////////////////////////////////////////////
 188 // senf::ppi::connector::ActiveOutput
 189
 190 prefix_ senf::ppi::connector::ActiveInput & senf::ppi::connector::ActiveOutput::peer()
 191 {
 192     return dynamic_cast<ActiveInput&>(Connector::peer());
 193 }
 194
 195 prefix_ void senf::ppi::connector::ActiveOutput::connect(PassiveInput & target)
 196 {
 197     Connector::connect(target);
 198 }
 199
 200 ///////////////////////////////cci.e///////////////////////////////////////
 201 #undef prefix_
 202
 203 \f
 204 // Local Variables:
 205 // mode: c++
 206 // fill-column: 100
 207 // comment-column: 40
 208 // c-file-style: "senf"
 209 // indent-tabs-mode: nil
 210 // ispell-local-dictionary: "american"
 211 // compile-command: "scons -u test"
 212 // End: