PPI/DebugModules.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 DebugModules inline non-template implementation */
  25
  26 // Custom includes
  27
  28 #define prefix_ inline
  29 ///////////////////////////////cci.p///////////////////////////////////////
  30
  31 ///////////////////////////////////////////////////////////////////////////
  32 // senf::ppi::module::debug::ActivePacketSource
  33
  34 prefix_ senf::ppi::module::debug::ActivePacketSource::ActivePacketSource()
  35 {
  36     noroute(output);
  37 }
  38
  39 prefix_ void senf::ppi::module::debug::ActivePacketSource::submit(Packet packet)
  40 {
  41     output(packet);
  42 }
  43
  44 ///////////////////////////////////////////////////////////////////////////
  45 // senf::ppi::module::debug::PassivePacketSource
  46
  47 prefix_ senf::ppi::module::debug::PassivePacketSource::PassivePacketSource()
  48 {
  49     noroute(output);
  50     output.onRequest(&PassivePacketSource::request);
  51 }
  52
  53 prefix_ void senf::ppi::module::debug::PassivePacketSource::submit(Packet packet)
  54 {
  55     packets_.push_back(packet);
  56     output.unthrottle();
  57 }
  58
  59 prefix_ bool senf::ppi::module::debug::PassivePacketSource::empty()
  60 {
  61     return packets_.empty();
  62 }
  63
  64 prefix_ senf::ppi::module::debug::PassivePacketSource::size_type
  65 senf::ppi::module::debug::PassivePacketSource::size()
  66 {
  67     return packets_.size();
  68 }
  69
  70 ////////////////////////////////////////
  71 // private members
  72
  73 prefix_ void senf::ppi::module::debug::PassivePacketSource::request()
  74 {
  75     BOOST_ASSERT( ! packets_.empty() );
  76     output(packets_.front());
  77     packets_.pop_front();
  78     if (packets_.empty())
  79         output.throttle();
  80 }
  81
  82 prefix_ void senf::ppi::module::debug::PassivePacketSource::init()
  83 {
  84     output.throttle();
  85 }
  86
  87 ///////////////////////////////////////////////////////////////////////////
  88 // senf::ppi::module::debug::ActivePacketSink
  89
  90 prefix_ senf::ppi::module::debug::ActivePacketSink::ActivePacketSink()
  91 {
  92     noroute(input);
  93 }
  94
  95 prefix_ senf::Packet senf::ppi::module::debug::ActivePacketSink::request()
  96 {
  97     return input();
  98 }
  99
 100 ///////////////////////////////////////////////////////////////////////////
 101 // senf::ppi::module::debug::PassivePacketSink
 102
 103 prefix_ senf::ppi::module::debug::PassivePacketSink::PassivePacketSink()
 104 {
 105     noroute(input);
 106     input.onRequest(&PassivePacketSink::request);
 107 }
 108
 109 prefix_ bool senf::ppi::module::debug::PassivePacketSink::empty()
 110 {
 111     return packets_.empty();
 112 }
 113
 114 prefix_ senf::ppi::module::debug::PassivePacketSink::size_type
 115 senf::ppi::module::debug::PassivePacketSink::size()
 116 {
 117     return packets_.size();
 118 }
 119
 120 prefix_ senf::ppi::module::debug::PassivePacketSink::iterator
 121 senf::ppi::module::debug::PassivePacketSink::begin()
 122 {
 123     return packets_.begin();
 124 }
 125
 126 prefix_ senf::ppi::module::debug::PassivePacketSink::iterator
 127 senf::ppi::module::debug::PassivePacketSink::end()
 128 {
 129     return packets_.end();
 130 }
 131
 132 prefix_ senf::Packet senf::ppi::module::debug::PassivePacketSink::back()
 133 {
 134     if (empty())
 135         return Packet();
 136     else
 137         return packets_.back();
 138 }
 139
 140 prefix_ senf::Packet senf::ppi::module::debug::PassivePacketSink::pop_back()
 141 {
 142     Packet p (back());
 143     if (p)
 144         packets_.pop_back();
 145     return p;
 146 }
 147
 148 prefix_ void senf::ppi::module::debug::PassivePacketSink::clear()
 149 {
 150     packets_.erase(packets_.begin(), packets_.end());
 151 }
 152
 153 ////////////////////////////////////////
 154 // private members
 155
 156 prefix_ void senf::ppi::module::debug::PassivePacketSink::request()
 157 {
 158     packets_.push_back(input());
 159 }
 160
 161 ///////////////////////////////cci.e///////////////////////////////////////
 162 #undef prefix_
 163
 164 \f
 165 // Local Variables:
 166 // mode: c++
 167 // fill-column: 100
 168 // comment-column: 40
 169 // c-file-style: "senf"
 170 // indent-tabs-mode: nil
 171 // ispell-local-dictionary: "american"
 172 // compile-command: "scons -u test"
 173 // End: