senf/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 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  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 const & 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 const & 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::v_init()
  91 {
  92     if (empty())
  93         output.throttle();
  94 }
  95
  96 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  97 // senf::ppi::module::debug::ActiveSink
  98
  99 prefix_ senf::ppi::module::debug::ActiveSink::ActiveSink()
 100 {
 101     noroute(input);
 102 }
 103
 104 prefix_ senf::Packet senf::ppi::module::debug::ActiveSink::request()
 105 {
 106     return input();
 107 }
 108
 109 prefix_ bool senf::ppi::module::debug::ActiveSink::boolean_test()
 110     const
 111 {
 112     return input;
 113 }
 114
 115 //-/////////////////////////////////////////////////////////////////////////////////////////////////
 116 // senf::ppi::module::debug::PassiveSink
 117
 118 prefix_ senf::ppi::module::debug::PassiveSink::PassiveSink()
 119 {
 120     noroute(input);
 121     input.onRequest(&PassiveSink::request);
 122 }
 123
 124 prefix_ void senf::ppi::module::debug::PassiveSink::throttle()
 125 {
 126     input.throttle();
 127 }
 128
 129 prefix_ void senf::ppi::module::debug::PassiveSink::unthrottle()
 130 {
 131     input.unthrottle();
 132 }
 133
 134 prefix_ bool senf::ppi::module::debug::PassiveSink::empty()
 135 {
 136     return packets_.empty();
 137 }
 138
 139 prefix_ senf::ppi::module::debug::PassiveSink::size_type
 140 senf::ppi::module::debug::PassiveSink::size()
 141 {
 142     return packets_.size();
 143 }
 144
 145 prefix_ senf::ppi::module::debug::PassiveSink::iterator
 146 senf::ppi::module::debug::PassiveSink::begin()
 147 {
 148     return packets_.begin();
 149 }
 150
 151 prefix_ senf::ppi::module::debug::PassiveSink::iterator
 152 senf::ppi::module::debug::PassiveSink::end()
 153 {
 154     return packets_.end();
 155 }
 156
 157 prefix_ senf::Packet senf::ppi::module::debug::PassiveSink::front()
 158 {
 159     if (empty())
 160         return Packet();
 161     else
 162         return packets_.front();
 163 }
 164
 165 prefix_ senf::Packet senf::ppi::module::debug::PassiveSink::pop_front()
 166 {
 167     Packet p (front());
 168     if (p)
 169         packets_.pop_front();
 170     return p;
 171 }
 172
 173 prefix_ void senf::ppi::module::debug::PassiveSink::clear()
 174 {
 175     packets_.erase(packets_.begin(), packets_.end());
 176 }
 177
 178 //-/////////////////////////////////////////////////////////////////////////////////////////////////
 179 // senf::ppi::module::debug::ActiveFeederSource
 180
 181 prefix_ senf::ppi::module::debug::ActiveFeederSource::ActiveFeederSource()
 182     : output(feeder.output)
 183 {
 184     ppi::connect(source,feeder);
 185 }
 186
 187 prefix_ void senf::ppi::module::debug::ActiveFeederSource::submit(Packet packet)
 188 {
 189     source.submit(packet);
 190 }
 191
 192 prefix_ bool senf::ppi::module::debug::ActiveFeederSource::empty()
 193 {
 194     return source.empty();
 195 }
 196
 197 prefix_ senf::ppi::module::debug::ActiveFeederSource::size_type
 198 senf::ppi::module::debug::ActiveFeederSource::size()
 199 {
 200     return source.size();
 201 }
 202
 203 //-/////////////////////////////////////////////////////////////////////////////////////////////////
 204 // senf::ppi::module::debug::ActiveFeederSink
 205
 206 prefix_ senf::ppi::module::debug::ActiveFeederSink::ActiveFeederSink()
 207     : input(feeder.input)
 208 {
 209     ppi::connect(feeder, sink);
 210 }
 211
 212 prefix_ bool senf::ppi::module::debug::ActiveFeederSink::empty()
 213 {
 214     return sink.empty();
 215 }
 216
 217 prefix_ senf::ppi::module::debug::ActiveFeederSink::size_type
 218 senf::ppi::module::debug::ActiveFeederSink::size()
 219 {
 220     return sink.size();
 221 }
 222
 223 prefix_ senf::ppi::module::debug::ActiveFeederSink::iterator
 224 senf::ppi::module::debug::ActiveFeederSink::begin()
 225 {
 226     return sink.begin();
 227 }
 228
 229 prefix_ senf::ppi::module::debug::ActiveFeederSink::iterator
 230 senf::ppi::module::debug::ActiveFeederSink::end()
 231 {
 232     return sink.end();
 233 }
 234
 235 prefix_ senf::Packet senf::ppi::module::debug::ActiveFeederSink::front()
 236 {
 237     return sink.front();
 238 }
 239
 240 prefix_ senf::Packet senf::ppi::module::debug::ActiveFeederSink::pop_front()
 241 {
 242     return sink.pop_front();
 243 }
 244
 245 prefix_ void senf::ppi::module::debug::ActiveFeederSink::clear()
 246 {
 247     sink.clear();
 248 }
 249
 250 //-/////////////////////////////////////////////////////////////////////////////////////////////////
 251 #undef prefix_
 252
 253 \f
 254 // Local Variables:
 255 // mode: c++
 256 // fill-column: 100
 257 // comment-column: 40
 258 // c-file-style: "senf"
 259 // indent-tabs-mode: nil
 260 // ispell-local-dictionary: "american"
 261 // compile-command: "scons -u test"
 262 // End: