PPI/DebugModules.cci

   1 // $Id$
   2 //
   3 // Copyright (C) 2007
   4 // Fraunhofer Institute for Open Communication Systems (FOKUS)
   5 // Competence Center NETwork research (NET), St. Augustin, GERMANY
   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 DebugModules inline non-template implementation */
  25
  26 // Custom includes
  27 #include "Setup.hh"
  28
  29 #define prefix_ inline
  30 ///////////////////////////////cci.p///////////////////////////////////////
  31
  32 ///////////////////////////////////////////////////////////////////////////
  33 // senf::ppi::module::debug::ActiveSource
  34
  35 prefix_ senf::ppi::module::debug::ActiveSource::ActiveSource()
  36 {
  37     noroute(output);
  38 }
  39
  40 prefix_ void senf::ppi::module::debug::ActiveSource::submit(Packet packet)
  41 {
  42     output(packet);
  43 }
  44
  45 prefix_ bool senf::ppi::module::debug::ActiveSource::boolean_test()
  46     const
  47 {
  48     return output;
  49 }
  50
  51 ///////////////////////////////////////////////////////////////////////////
  52 // senf::ppi::module::debug::PassiveSource
  53
  54 prefix_ senf::ppi::module::debug::PassiveSource::PassiveSource()
  55 {
  56     noroute(output);
  57     output.onRequest(&PassiveSource::request);
  58 }
  59
  60 prefix_ void senf::ppi::module::debug::PassiveSource::throttle()
  61 {
  62     output.throttle();
  63 }
  64
  65 prefix_ void senf::ppi::module::debug::PassiveSource::unthrottle()
  66 {
  67     output.unthrottle();
  68 }
  69
  70 prefix_ void senf::ppi::module::debug::PassiveSource::submit(Packet packet)
  71 {
  72     packets_.push_back(packet);
  73     output.unthrottle();
  74 }
  75
  76 prefix_ bool senf::ppi::module::debug::PassiveSource::empty()
  77 {
  78     return packets_.empty();
  79 }
  80
  81 prefix_ senf::ppi::module::debug::PassiveSource::size_type
  82 senf::ppi::module::debug::PassiveSource::size()
  83 {
  84     return packets_.size();
  85 }
  86
  87 ////////////////////////////////////////
  88 // private members
  89
  90 prefix_ void senf::ppi::module::debug::PassiveSource::request()
  91 {
  92     BOOST_ASSERT( ! packets_.empty() );
  93     output(packets_.front());
  94     packets_.pop_front();
  95     if (packets_.empty())
  96         output.throttle();
  97 }
  98
  99 prefix_ void senf::ppi::module::debug::PassiveSource::init()
 100 {
 101     if (empty())
 102         output.throttle();
 103 }
 104
 105 ///////////////////////////////////////////////////////////////////////////
 106 // senf::ppi::module::debug::ActiveSink
 107
 108 prefix_ senf::ppi::module::debug::ActiveSink::ActiveSink()
 109 {
 110     noroute(input);
 111 }
 112
 113 prefix_ senf::Packet senf::ppi::module::debug::ActiveSink::request()
 114 {
 115     return input();
 116 }
 117
 118 prefix_ bool senf::ppi::module::debug::ActiveSink::boolean_test()
 119     const
 120 {
 121     return input;
 122 }
 123
 124 ///////////////////////////////////////////////////////////////////////////
 125 // senf::ppi::module::debug::PassiveSink
 126
 127 prefix_ senf::ppi::module::debug::PassiveSink::PassiveSink()
 128 {
 129     noroute(input);
 130     input.onRequest(&PassiveSink::request);
 131 }
 132
 133 prefix_ void senf::ppi::module::debug::PassiveSink::throttle()
 134 {
 135     input.throttle();
 136 }
 137
 138 prefix_ void senf::ppi::module::debug::PassiveSink::unthrottle()
 139 {
 140     input.unthrottle();
 141 }
 142
 143 prefix_ bool senf::ppi::module::debug::PassiveSink::empty()
 144 {
 145     return packets_.empty();
 146 }
 147
 148 prefix_ senf::ppi::module::debug::PassiveSink::size_type
 149 senf::ppi::module::debug::PassiveSink::size()
 150 {
 151     return packets_.size();
 152 }
 153
 154 prefix_ senf::ppi::module::debug::PassiveSink::iterator
 155 senf::ppi::module::debug::PassiveSink::begin()
 156 {
 157     return packets_.begin();
 158 }
 159
 160 prefix_ senf::ppi::module::debug::PassiveSink::iterator
 161 senf::ppi::module::debug::PassiveSink::end()
 162 {
 163     return packets_.end();
 164 }
 165
 166 prefix_ senf::Packet senf::ppi::module::debug::PassiveSink::front()
 167 {
 168     if (empty())
 169         return Packet();
 170     else
 171         return packets_.front();
 172 }
 173
 174 prefix_ senf::Packet senf::ppi::module::debug::PassiveSink::pop_front()
 175 {
 176     Packet p (front());
 177     if (p)
 178         packets_.pop_front();
 179     return p;
 180 }
 181
 182 prefix_ void senf::ppi::module::debug::PassiveSink::clear()
 183 {
 184     packets_.erase(packets_.begin(), packets_.end());
 185 }
 186
 187 ////////////////////////////////////////
 188 // private members
 189
 190 prefix_ void senf::ppi::module::debug::PassiveSink::request()
 191 {
 192     packets_.push_back(input());
 193 }
 194
 195 ///////////////////////////////////////////////////////////////////////////
 196 // senf::ppi::module::debug::ActiveFeederSource
 197
 198 prefix_ senf::ppi::module::debug::ActiveFeederSource::ActiveFeederSource()
 199     : output(feeder.output)
 200 {
 201     ppi::connect(source,feeder);
 202 }
 203
 204 prefix_ void senf::ppi::module::debug::ActiveFeederSource::submit(Packet packet)
 205 {
 206     source.submit(packet);
 207 }
 208
 209 prefix_ bool senf::ppi::module::debug::ActiveFeederSource::empty()
 210 {
 211     return source.empty();
 212 }
 213
 214 prefix_ senf::ppi::module::debug::ActiveFeederSource::size_type
 215 senf::ppi::module::debug::ActiveFeederSource::size()
 216 {
 217     return source.size();
 218 }
 219
 220 ///////////////////////////////////////////////////////////////////////////
 221 // senf::ppi::module::debug::ActiveFeederSink
 222
 223 prefix_ senf::ppi::module::debug::ActiveFeederSink::ActiveFeederSink()
 224     : input(feeder.input)
 225 {
 226     ppi::connect(feeder, sink);
 227 }
 228
 229 prefix_ bool senf::ppi::module::debug::ActiveFeederSink::empty()
 230 {
 231     return sink.empty();
 232 }
 233
 234 prefix_ senf::ppi::module::debug::ActiveFeederSink::size_type
 235 senf::ppi::module::debug::ActiveFeederSink::size()
 236 {
 237     return sink.size();
 238 }
 239
 240 prefix_ senf::ppi::module::debug::ActiveFeederSink::iterator
 241 senf::ppi::module::debug::ActiveFeederSink::begin()
 242 {
 243     return sink.begin();
 244 }
 245
 246 prefix_ senf::ppi::module::debug::ActiveFeederSink::iterator
 247 senf::ppi::module::debug::ActiveFeederSink::end()
 248 {
 249     return sink.end();
 250 }
 251
 252 prefix_ senf::Packet senf::ppi::module::debug::ActiveFeederSink::front()
 253 {
 254     return sink.front();
 255 }
 256
 257 prefix_ senf::Packet senf::ppi::module::debug::ActiveFeederSink::pop_front()
 258 {
 259     return sink.pop_front();
 260 }
 261
 262 prefix_ void senf::ppi::module::debug::ActiveFeederSink::clear()
 263 {
 264     sink.clear();
 265 }
 266
 267 ///////////////////////////////cci.e///////////////////////////////////////
 268 #undef prefix_
 269
 270 \f
 271 // Local Variables:
 272 // mode: c++
 273 // fill-column: 100
 274 // comment-column: 40
 275 // c-file-style: "senf"
 276 // indent-tabs-mode: nil
 277 // ispell-local-dictionary: "american"
 278 // compile-command: "scons -u test"
 279 // End: