4 // Fraunhofer Institute for Open Communication Systems (FOKUS)
5 // Competence Center NETwork research (NET), St. Augustin, GERMANY
6 // Stefan Bund <g0dil@berlios.de>
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.
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.
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.
24 \brief FdDispatcher non-inline non-template implementation */
31 #include "../Utils/senfassert.hh"
33 //#include "FdEvent.mpp"
35 ///////////////////////////////cc.p////////////////////////////////////////
37 ///////////////////////////////////////////////////////////////////////////
38 // senf::scheduler::detail::FdDispatcher
40 prefix_ senf::scheduler::detail::FdDispatcher::~FdDispatcher()
42 for (FdSet::iterator i (fds_.begin()); i != fds_.end(); ++i) {
43 detail::FdManager::instance().remove(i->fd_);
44 detail::FIFORunner::instance().dequeue(&(*i));
48 prefix_ bool senf::scheduler::detail::FdDispatcher::add(FdEvent & event)
50 std::pair<FdSet::iterator,FdSet::iterator> range (fds_.equal_range(event));
52 for (FdSet::iterator i (range.first); i != range.second; ++i)
54 if (event.events_ & events)
55 throw FdEvent::DuplicateEventRegistrationException() << "vinfo: " << event.v_info();
57 if (! detail::FdManager::instance().set(event.fd_, events | event.events_, &event))
60 detail::FIFORunner::instance().enqueue(&event);
61 fds_.insert(range.first, event);
66 prefix_ void senf::scheduler::detail::FdDispatcher::remove(FdEvent & event)
68 fds_.erase(FdSet::current(event));
69 detail::FIFORunner::instance().dequeue(&event);
71 std::pair<FdSet::iterator,FdSet::iterator> range (fds_.equal_range(event));
72 if (range.first == range.second)
73 detail::FdManager::instance().remove(event.fd_);
76 for (FdSet::iterator i (range.first); i != range.second; ++i)
78 detail::FdManager::instance().set(event.fd_, events, &(*range.first));
82 ///////////////////////////////////////////////////////////////////////////
83 // senf::scheduler::detail::FileDispatcher
85 prefix_ void senf::scheduler::detail::FileDispatcher::add(FdEvent & event)
87 std::pair<FdSet::iterator,FdSet::iterator> range (fds_.equal_range(event));
89 for (FdSet::iterator i (range.first); i != range.second; ++i)
91 if (event.events_ & events)
92 throw FdEvent::DuplicateEventRegistrationException() << "vinfo: " << event.v_info();
94 detail::FIFORunner::instance().enqueue(&event);
95 fds_.insert(range.first, event);
97 detail::FdManager::instance().timeout(0);
100 prefix_ senf::scheduler::detail::FileDispatcher::FileDispatcher()
101 : managerTimeout_ (scheduler::detail::FdManager::instance().timeout())
104 prefix_ senf::scheduler::detail::FileDispatcher::~FileDispatcher()
106 detail::FdManager::instance().timeout(-1);
107 for (FdSet::iterator i (fds_.begin()); i != fds_.end(); ++i)
108 detail::FIFORunner::instance().dequeue(&(*i));
111 prefix_ void senf::scheduler::detail::FileDispatcher::prepareRun()
113 for (FdSet::iterator i (fds_.begin()); i != fds_.end(); ++i) {
114 i->signaledEvents_ = i->events_;
119 prefix_ void senf::scheduler::detail::FileDispatcher::remove(FdEvent & event)
121 fds_.erase(FdSet::current(event));
122 detail::FIFORunner::instance().dequeue(&event);
124 detail::FdManager::instance().timeout(managerTimeout_);
127 ///////////////////////////////////////////////////////////////////////////
128 // senf::scheduler::FdEvent
130 prefix_ void senf::scheduler::FdEvent::disable()
134 detail::FdDispatcher::instance().remove(*this);
136 detail::FileDispatcher::instance().remove(*this);
140 prefix_ void senf::scheduler::FdEvent::enable()
142 if (! enabled() && events_ && fd_ != -1) {
143 if (pollable_ && detail::FdDispatcher::instance().add(*this))
145 detail::FileDispatcher::instance().add(*this);
150 prefix_ senf::scheduler::FdEvent & senf::scheduler::FdEvent::events(int events)
160 prefix_ void senf::scheduler::FdEvent::signal(int events)
162 detail::FdDispatcher::FdSet::iterator i (detail::FdDispatcher::FdSet::current(*this));
163 detail::FdDispatcher::FdSet::iterator const i_end (detail::FdDispatcher::instance().fds_.end());
164 bool all ((events & (EV_ERR | EV_HUP)) && ! (events & (EV_READ | EV_PRIO | EV_WRITE)));
165 for (; i != i_end && fd_ == i->fd_; ++i) {
166 i->signaledEvents_ = events;
167 if (i->events_ & events || all)
172 prefix_ void senf::scheduler::FdEvent::v_run()
174 cb_(signaledEvents_);
177 prefix_ char const * senf::scheduler::FdEvent::v_type()
183 prefix_ std::string senf::scheduler::FdEvent::v_info()
186 std::stringstream ss;
190 ss << " (NOT pollable)";
191 if (events_ & EV_READ)
193 if (events_ & EV_PRIO)
195 if (events_ & EV_WRITE)
200 ///////////////////////////////cc.e////////////////////////////////////////
202 //#include "FdEvent.mpp"
208 // comment-column: 40
209 // c-file-style: "senf"
210 // indent-tabs-mode: nil
211 // ispell-local-dictionary: "american"
212 // compile-command: "scons -u test"