X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FScheduler%2FEventHook.cci;fp=senf%2FScheduler%2FEventHook.cci;h=8cbec85410f5429d2f99898a8705294549c5179d;hb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;hp=0000000000000000000000000000000000000000;hpb=164fe477094d42463722584e527a02379ab5d985;p=senf.git diff --git a/senf/Scheduler/EventHook.cci b/senf/Scheduler/EventHook.cci new file mode 100644 index 0000000..8cbec85 --- /dev/null +++ b/senf/Scheduler/EventHook.cci @@ -0,0 +1,100 @@ +// $Id$ +// +// Copyright (C) 2008 +// Fraunhofer Institute for Open Communication Systems (FOKUS) +// Competence Center NETwork research (NET), St. Augustin, GERMANY +// Stefan Bund +// +// This program is free software; you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation; either version 2 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program; if not, write to the +// Free Software Foundation, Inc., +// 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + +/** \file + \brief EventHook inline non-template implementation */ + +#include "EventHook.ih" + +// Custom includes + +#define prefix_ inline +///////////////////////////////cci.p/////////////////////////////////////// + +/////////////////////////////////////////////////////////////////////////// +// senf::scheduler::EventHook + +prefix_ senf::scheduler::EventHook::EventHook(std::string const & name, Callback const & cb, + detail::FIFORunner::TaskInfo::Priority priority, + bool initiallyEnabled) + : detail::FIFORunner::TaskInfo(name, priority), cb_ (cb) +{ + if (initiallyEnabled) + enable(); +} + +prefix_ senf::scheduler::EventHook::~EventHook() +{ + if (detail::EventHookDispatcher::alive()) + disable(); +} + +prefix_ void senf::scheduler::EventHook::disable() +{ + if (enabled()) + detail::EventHookDispatcher::instance().remove(*this); +} + +prefix_ void senf::scheduler::EventHook::enable() +{ + if (! enabled()) { + detail::EventHookDispatcher::instance().add(*this); + setRunnable(); + } +} + +prefix_ void senf::scheduler::EventHook::action(Callback const & cb) +{ + cb_ = cb; +} + +/////////////////////////////////////////////////////////////////////////// +// senf::scheduler::detail::EventHookDispatcher + +prefix_ void senf::scheduler::detail::EventHookDispatcher::add(EventHook & event) +{ + events_.push_back(event); + FIFORunner::instance().enqueue(&event); +} + +prefix_ bool senf::scheduler::detail::EventHookDispatcher::empty() + const +{ + return events_.empty(); +} + +prefix_ senf::scheduler::detail::EventHookDispatcher::EventHookDispatcher() +{} + +///////////////////////////////cci.e/////////////////////////////////////// +#undef prefix_ + + +// Local Variables: +// mode: c++ +// fill-column: 100 +// comment-column: 40 +// c-file-style: "senf" +// indent-tabs-mode: nil +// ispell-local-dictionary: "american" +// compile-command: "scons -u test" +// End: