senf/Scheduler/FdEvent.cc

   1 // $Id$
   2 //
   3 // Copyright (C) 2008
   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 FdDispatcher non-inline non-template implementation */
  30
  31 #include "FdEvent.hh"
  32 #include "FdEvent.ih"
  33
  34 // Custom includes
  35 #include <sstream>
  36
  37 //#include "FdEvent.mpp"
  38 #define prefix_
  39 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  40
  41 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  42 // senf::scheduler::detail::FdDispatcher
  43
  44 prefix_ senf::scheduler::detail::FdDispatcher::~FdDispatcher()
  45 {
  46     for (FdSet::iterator i (fds_.begin()); i != fds_.end(); ++i) {
  47         detail::FdManager::instance().remove(i->fd_);
  48         detail::FIFORunner::instance().dequeue(&(*i));
  49     }
  50 }
  51
  52 prefix_ bool senf::scheduler::detail::FdDispatcher::add(FdEvent & event)
  53 {
  54     std::pair<FdSet::iterator,FdSet::iterator> range (fds_.equal_range(event));
  55     int events (0);
  56     for (FdSet::iterator i (range.first); i != range.second; ++i)
  57         events |= i->events_;
  58     if (event.events_ & events)
  59         throw FdEvent::DuplicateEventRegistrationException() << "vinfo: " << event.v_info();
  60
  61     if (! detail::FdManager::instance().set(event.fd_, events | event.events_, &event))
  62         return false;
  63
  64     detail::FIFORunner::instance().enqueue(&event);
  65     fds_.insert(range.first, event);
  66
  67     return true;
  68 }
  69
  70 prefix_ void senf::scheduler::detail::FdDispatcher::remove(FdEvent & event)
  71 {
  72     fds_.erase(FdSet::current(event));
  73     detail::FIFORunner::instance().dequeue(&event);
  74
  75     std::pair<FdSet::iterator,FdSet::iterator> range (fds_.equal_range(event));
  76     if (range.first == range.second)
  77         detail::FdManager::instance().remove(event.fd_);
  78     else {
  79         int events (0);
  80         for (FdSet::iterator i (range.first); i != range.second; ++i)
  81             events |= i->events_;
  82         detail::FdManager::instance().set(event.fd_, events, &(*range.first));
  83     }
  84 }
  85
  86 //-/////////////////////////////////////////////////////////////////////////////////////////////////
  87 // senf::scheduler::detail::FileDispatcher
  88
  89 prefix_ void senf::scheduler::detail::FileDispatcher::add(FdEvent & event)
  90 {
  91     std::pair<FdSet::iterator,FdSet::iterator> range (fds_.equal_range(event));
  92     int events (0);
  93     for (FdSet::iterator i (range.first); i != range.second; ++i)
  94         events |= i->events_;
  95     if (event.events_ & events)
  96         throw FdEvent::DuplicateEventRegistrationException() << "vinfo: " << event.v_info();
  97
  98     detail::FIFORunner::instance().enqueue(&event);
  99     fds_.insert(range.first, event);
 100
 101     detail::FdManager::instance().timeout(0);
 102 }
 103
 104 prefix_ senf::scheduler::detail::FileDispatcher::FileDispatcher()
 105     : managerTimeout_ (scheduler::detail::FdManager::instance().timeout())
 106 {}
 107
 108 prefix_ senf::scheduler::detail::FileDispatcher::~FileDispatcher()
 109 {
 110     detail::FdManager::instance().timeout(-1);
 111     for (FdSet::iterator i (fds_.begin()); i != fds_.end(); ++i)
 112         detail::FIFORunner::instance().dequeue(&(*i));
 113 }
 114
 115 prefix_ void senf::scheduler::detail::FileDispatcher::prepareRun()
 116 {
 117     for (FdSet::iterator i (fds_.begin()); i != fds_.end(); ++i) {
 118         i->signaledEvents_ = i->events_;
 119         i->setRunnable();
 120     }
 121 }
 122
 123 prefix_ void senf::scheduler::detail::FileDispatcher::remove(FdEvent & event)
 124 {
 125     fds_.erase(FdSet::current(event));
 126     detail::FIFORunner::instance().dequeue(&event);
 127     if (fds_.empty())
 128         detail::FdManager::instance().timeout(managerTimeout_);
 129 }
 130
 131 //-/////////////////////////////////////////////////////////////////////////////////////////////////
 132 // senf::scheduler::FdEvent
 133
 134 prefix_ void senf::scheduler::FdEvent::disable()
 135 {
 136     if (enabled()) {
 137         if (pollable_)
 138             detail::FdDispatcher::instance().remove(*this);
 139         else
 140             detail::FileDispatcher::instance().remove(*this);
 141     }
 142 }
 143
 144 prefix_ void senf::scheduler::FdEvent::enable()
 145 {
 146     if (! enabled() && events_ && fd_ != -1) {
 147         if (pollable_ && detail::FdDispatcher::instance().add(*this))
 148             return;
 149         detail::FileDispatcher::instance().add(*this);
 150         pollable_ = false;
 151     }
 152 }
 153
 154 prefix_ senf::scheduler::FdEvent & senf::scheduler::FdEvent::events(int events)
 155 {
 156     bool en = enabled();
 157     disable();
 158     events_ = events;
 159     if (en)
 160         enabled();
 161     return *this;
 162 }
 163
 164 prefix_ void senf::scheduler::FdEvent::signal(int events)
 165 {
 166     detail::FdDispatcher::FdSet::iterator i (detail::FdDispatcher::FdSet::current(*this));
 167     detail::FdDispatcher::FdSet::iterator const i_end (detail::FdDispatcher::instance().fds_.end());
 168     bool all ((events & (EV_ERR | EV_HUP)) && ! (events & (EV_READ | EV_PRIO | EV_WRITE)));
 169     for (; i != i_end && fd_ == i->fd_; ++i) {
 170         i->signaledEvents_ = events & (EV_ERR | EV_HUP | i->events_);
 171         if (i->events_ & events || all)
 172             i->setRunnable();
 173     }
 174 }
 175
 176 prefix_ void senf::scheduler::FdEvent::v_run()
 177 {
 178     cb_(signaledEvents_);
 179 }
 180
 181 prefix_ char const * senf::scheduler::FdEvent::v_type()
 182     const
 183 {
 184     return "fd";
 185 }
 186
 187 prefix_ std::string senf::scheduler::FdEvent::v_info()
 188     const
 189 {
 190     std::stringstream ss;
 191
 192     ss << "fd " << fd_;
 193     if (! pollable_)
 194         ss << " (NOT pollable)";
 195     if (events_ & EV_READ)
 196         ss << " READ";
 197     if (events_ & EV_PRIO)
 198         ss << " PRIO";
 199     if (events_ & EV_WRITE)
 200         ss << " WRITE";
 201     return ss.str();
 202 }
 203
 204 //-/////////////////////////////////////////////////////////////////////////////////////////////////
 205 #undef prefix_
 206 //#include "FdEvent.mpp"
 207
 208 \f
 209 // Local Variables:
 210 // mode: c++
 211 // fill-column: 100
 212 // comment-column: 40
 213 // c-file-style: "senf"
 214 // indent-tabs-mode: nil
 215 // ispell-local-dictionary: "american"
 216 // compile-command: "scons -u test"
 217 // End: