senf/PPI/SocketSource.ct

   1 // $Id$
   2 //
   3 // Copyright (C) 2007
   4 // Fraunhofer Institute for Open Communication Systems (FOKUS)
   5 //
   6 // The contents of this file are subject to the Fraunhofer FOKUS Public License
   7 // Version 1.0 (the "License"); you may not use this file except in compliance
   8 // with the License. You may obtain a copy of the License at
   9 // http://senf.berlios.de/license.html
  10 //
  11 // The Fraunhofer FOKUS Public License Version 1.0 is based on,
  12 // but modifies the Mozilla Public License Version 1.1.
  13 // See the full license text for the amendments.
  14 //
  15 // Software distributed under the License is distributed on an "AS IS" basis,
  16 // WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
  17 // for the specific language governing rights and limitations under the License.
  18 //
  19 // The Original Code is Fraunhofer FOKUS code.
  20 //
  21 // The Initial Developer of the Original Code is Fraunhofer-Gesellschaft e.V.
  22 // (registered association), Hansastraße 27 c, 80686 Munich, Germany.
  23 // All Rights Reserved.
  24 //
  25 // Contributor(s):
  26 //   Stefan Bund <g0dil@berlios.de>
  27
  28 /** \file
  29     \brief SocketSource non-inline template implementation  */
  30
  31 //#include "SocketSource.ih"
  32
  33 // Custom includes
  34
  35 #define prefix_
  36 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  37
  38 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  39 // senf::ppi::DgramReader<Packet,MaxSize>
  40
  41 template <class Packet, unsigned MaxSize>
  42 prefix_ Packet senf::ppi::DgramReader<Packet,MaxSize>::operator()(Handle & handle)
  43 {
  44     Packet packet (Packet::create(senf::noinit));
  45     handle.read(packet.data(), MaxSize);
  46     return packet;
  47 }
  48
  49 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  50 // senf::ppi::module::ActiveSocketSource<Reader>
  51
  52 template <class Reader>
  53 prefix_ senf::ppi::module::ActiveSocketSource<Reader>::ActiveSocketSource()
  54 {
  55     registerEvent( event_, &ActiveSocketSource::read );
  56     route(event_, output);
  57 }
  58
  59 template <class Reader>
  60 prefix_ senf::ppi::module::ActiveSocketSource<Reader>::ActiveSocketSource(Reader reader)
  61     : reader_(reader)
  62 {
  63     registerEvent( event_, &ActiveSocketSource::read );
  64     route(event_, output);
  65 }
  66
  67 template <class Reader>
  68 prefix_ senf::ppi::module::ActiveSocketSource<Reader>::ActiveSocketSource(Handle const & handle)
  69     : handle_(handle), event_(handle_, IOEvent::Read)
  70 {
  71     registerEvent( event_, &ActiveSocketSource::read );
  72     route(event_, output);
  73 }
  74
  75 template <class Reader>
  76 prefix_ senf::ppi::module::ActiveSocketSource<Reader>::ActiveSocketSource(Handle const & handle,
  77                                                                           Reader reader)
  78     : handle_(handle), event_(handle_, IOEvent::Read), reader_(reader)
  79 {
  80     registerEvent( event_, &ActiveSocketSource::read );
  81     route(event_, output);
  82 }
  83
  84 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  85 // senf::ppi::module::ActiveBurstSocketSource<Reader>
  86
  87 template <class Reader>
  88 prefix_ senf::ppi::module::ActiveBurstSocketSource<Reader>::ActiveBurstSocketSource(unsigned max_burst)
  89     : maxBurst_(max_burst)
  90 {
  91     registerEvent( event_, &ActiveBurstSocketSource::read );
  92     route(event_, output);
  93 }
  94
  95 template <class Reader>
  96 prefix_ senf::ppi::module::ActiveBurstSocketSource<Reader>::ActiveBurstSocketSource(Reader reader, unsigned max_burst)
  97     : reader_(reader), maxBurst_(maxBurst)
  98 {
  99     registerEvent( event_, &ActiveBurstSocketSource::read );
 100     route(event_, output);
 101 }
 102
 103 template <class Reader>
 104 prefix_ senf::ppi::module::ActiveBurstSocketSource<Reader>::ActiveBurstSocketSource(Handle const & handle, unsigned max_burst)
 105     : handle_(handle), event_(handle_, IOEvent::Read), maxBurst_(max_burst)
 106 {
 107     registerEvent( event_, &ActiveBurstSocketSource::read );
 108     route(event_, output);
 109 }
 110
 111 template <class Reader>
 112 prefix_ senf::ppi::module::ActiveBurstSocketSource<Reader>::ActiveBurstSocketSource(Handle const & handle,
 113                                                                           Reader reader, unsigned max_burst)
 114     : handle_(handle), event_(handle_, IOEvent::Read), reader_(reader), maxBurst_(max_burst)
 115 {
 116     registerEvent( event_, &ActiveBurstSocketSource::read );
 117     route(event_, output);
 118 }
 119
 120 template <class Reader>
 121 prefix_ void senf::ppi::module::ActiveBurstSocketSource<Reader>::maxBurst(unsigned max_burst)
 122 {
 123     maxBurst_ = max_burst;
 124 }
 125
 126 template <class Reader>
 127 prefix_ unsigned senf::ppi::module::ActiveBurstSocketSource<Reader>::maxBurst()
 128     const
 129 {
 130     return maxBurst_;
 131 }
 132
 133 template <class Reader>
 134 prefix_ void senf::ppi::module::ActiveBurstSocketSource<Reader>::read()
 135 {
 136     output(reader_(handle_));
 137     for (unsigned int i = 0; i < maxBurst_; ++i) {
 138         typename Reader::PacketType p (reader_(handle_));
 139         if (p.data().size() > 0)
 140             output( p);
 141         else
 142             break;
 143     }
 144 }
 145
 146 //-/////////////////////////////////////////////////////////////////////////////////////////////////
 147 #undef prefix_
 148
 149 \f
 150 // Local Variables:
 151 // mode: c++
 152 // fill-column: 100
 153 // comment-column: 40
 154 // c-file-style: "senf"
 155 // indent-tabs-mode: nil
 156 // ispell-local-dictionary: "american"
 157 // compile-command: "scons -u test"
 158 // End: