4 // Fraunhofer Institute for Open Communication Systems (FOKUS)
5 // Competence Center NETwork research (NET), St. Augustin, GERMANY
6 // Mathias Kretschmer <mtk@berlios.de>
7 // Jens Moedeker <jens.moedeker@fokus.fraunhofer.de>
9 // This program is free software; you can redistribute it and/or modify
10 // it under the terms of the GNU General Public License as published by
11 // the Free Software Foundation; either version 2 of the License, or
12 // (at your option) any later version.
14 // This program is distributed in the hope that it will be useful,
15 // but WITHOUT ANY WARRANTY; without even the implied warranty of
16 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 // GNU General Public License for more details.
19 // You should have received a copy of the GNU General Public License
20 // along with this program; if not, write to the
21 // Free Software Foundation, Inc.,
22 // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
25 \brief TimerEventProxy public header */
27 #ifndef HH_SENF_Scheduler_TimerEventProxy_
28 #define HH_SENF_Scheduler_TimerEventProxy_ 1
31 #include <boost/multi_index_container.hpp>
32 #include <boost/multi_index/ordered_index.hpp>
33 #include <boost/multi_index/member.hpp>
35 #include <senf/Scheduler/ClockService.hh>
36 #include <senf/Scheduler/TimerEvent.hh>
37 #include <senf/Utils/Console/Console.hh>
39 ///////////////////////////////hh.p////////////////////////////////////////
43 /** \brief Deadline timer proxy
45 The TimerEventProxy is meant to host long term deadline timers to reduce the load of the
46 Scheduler with a huge count of TimerEvent items. It registers deadline timer callbacks which
47 will be called when the timer expires.
49 The functionality is based on one TimerEvent instance per TimerEventProxy instance and could
50 host a big count of timers.
52 template<typename IdType>
56 typedef boost::function<void(ClockService::clock_type, IdType const &)> Callback;
58 TimerEventProxy(); ///< Instantiate a TimerEventProxy
59 TimerEventProxy(std::string const & name, console::DirectoryNode & node);
60 /**< \brief Instantiate a TimerEventProxy and add the list
61 command to the give DirectoryNode */
63 void add(ClockService::clock_type timeout, IdType const & id, Callback cb);
64 ///< Add new deadline timer
66 bool remove(IdType const & id); ///< Remove timer by given \a id.
68 std::vector<std::pair<ClockService::clock_type, IdType> > list() const;
69 ///< Returns a vector of all active timers with timeout and id.
71 ClockService::clock_type timeout(IdType const & id) const;
72 ///< Returns timeout for given id
73 /**< if no timer for this id is registered \a 0 is returned. */
77 ClockService::clock_type timeout;
81 Entry(ClockService::clock_type _timeout, IdType _id, Callback _cb)
82 : timeout(_timeout), id(_id), cb(_cb) { }
87 // data structure to hold active timers
88 typedef boost::multi_index_container<
90 boost::multi_index::indexed_by<
91 boost::multi_index::ordered_non_unique<
92 boost::multi_index::tag<Timeout>,
93 boost::multi_index::member<Entry, ClockService::clock_type, &Entry::timeout>
95 boost::multi_index::ordered_unique<
96 boost::multi_index::tag<Id>,
97 boost::multi_index::member<Entry, IdType, &Entry::id>
101 typedef typename EntrySet_t::template index<Timeout>::type EntrySetByTimeout_t;
102 typedef typename EntrySet_t::template index<Id>::type EntrySetById_t;
105 EntrySetById_t & entrySetById;
106 EntrySetByTimeout_t & entrySetByTimeout;
108 scheduler::TimerEvent timer;
110 void timerEvent(); // callback for the Scheduler timer event
115 ///////////////////////////////hh.e////////////////////////////////////////
116 //#include "TimerEventProxy.cci"
117 #include "TimerEventProxy.ct"
118 //#include "TimerEventProxy.cti"
125 // comment-column: 40
126 // c-file-style: "senf"
127 // indent-tabs-mode: nil
128 // ispell-local-dictionary: "american"
129 // compile-command: "scons -u test"