4 // Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS)
5 // Kompetenzzentrum fuer Satelitenkommunikation (SatCom)
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 Target non-inline non-template implementation */
32 //#include "Target.mpp"
34 ///////////////////////////////cc.p////////////////////////////////////////
36 ///////////////////////////////////////////////////////////////////////////
39 prefix_ senf::log::Target::Target()
41 detail::TargetRegistry::instance().registerTarget(this);
44 prefix_ senf::log::Target::~Target()
46 while( ! rib_.empty()) {
47 // This is terribly slow but simplifies the area cache handling and removing a target should
49 RIB::reverse_iterator i (rib_.rbegin());
50 unroute(i->stream_, i->area_, i->level_, i->action_);
52 detail::TargetRegistry::instance().unregisterTarget(this);
55 prefix_ void senf::log::Target::route(std::string const & stream, std::string const & area,
56 unsigned level, action_t action, int index)
58 detail::StreamBase const * s (StreamRegistry::instance().lookup(stream));
60 throw InvalidStreamException();
61 detail::AreaBase const * a (0);
63 a = AreaRegistry::instance().lookup(area);
65 throw InvalidAreaException();
67 route(s, a, level, action, index);
70 prefix_ void senf::log::Target::unroute(std::string const & stream, std::string const & area,
71 unsigned level, action_t action)
73 detail::StreamBase const * s (StreamRegistry::instance().lookup(stream));
75 throw InvalidStreamException();
76 detail::AreaBase const * a (0);
78 a = AreaRegistry::instance().lookup(area);
80 throw InvalidAreaException();
82 unroute(s, a, level, action);
85 prefix_ void senf::log::Target::unroute(int index)
89 if (RIB::size_type(-index) >= rib_.size())
93 std::advance(i, index);
96 if (RIB::size_type(index+1) >= rib_.size()) {
101 std::advance(i, index);
106 RoutingEntry entry (*i);
108 if (entry.action_ == ACCEPT)
109 updateRoutingCache(entry.stream_, entry.area_);
112 ////////////////////////////////////////
115 prefix_ void senf::log::Target::route(detail::StreamBase const * stream,
116 detail::AreaBase const * area, unsigned level,
117 action_t action, int index)
121 if (RIB::size_type(-index-1) >= rib_.size())
125 std::advance(i, index + 1 );
128 if (RIB::size_type(index) >= rib_.size())
132 std::advance(i, index);
135 rib_.insert(i, RoutingEntry(stream, area, level, action));
136 if (action == ACCEPT)
137 updateRoutingCache(stream, area);
140 prefix_ void senf::log::Target::unroute(detail::StreamBase const * stream,
141 detail::AreaBase const * area, unsigned level,
144 RIB::iterator i = std::find(rib_.begin(), rib_.end(),
145 RoutingEntry(stream, area, level, action));
147 unroute(std::distance(rib_.begin(), i));
150 prefix_ void senf::log::Target::updateRoutingCache(detail::StreamBase const * stream,
151 detail::AreaBase const * area)
154 StreamRegistry::Registry::iterator i (StreamRegistry::instance().registry_.begin());
155 StreamRegistry::Registry::iterator const i_end (StreamRegistry::instance().registry_.end());
156 for (; i != i_end ; ++i)
157 updateRoutingCache(i->second, area);
161 AreaRegistry::Registry::iterator i (AreaRegistry::instance().registry_.begin());
162 AreaRegistry::Registry::iterator const i_end (AreaRegistry::instance().registry_.end());
163 for (; i != i_end ; ++i)
164 updateRoutingCache(stream, i->second);
167 unsigned limit (DISABLED::value);
168 RIB::iterator i (rib_.begin());
169 RIB::iterator const i_end (rib_.end());
170 for(; i != i_end; ++i)
171 if ( (! i->stream_ || i->stream_ == stream) &&
172 (! i->area_ || i->area_ == area) &&
173 i->action_ == ACCEPT ) {
174 unsigned l (i->level_ == NONE::value ? i->stream_->defaultRuntimeLimit() : i->level_);
178 if (limit == DISABLED::value)
179 area->removeRoutingCache(*this, *stream);
181 area->updateRoutingCache(*this, *stream, limit);
184 prefix_ void senf::log::Target::write(boost::posix_time::ptime timestamp,
185 detail::StreamBase const & stream,
186 detail::AreaBase const & area, unsigned level,
187 std::string const & message)
189 RIB::iterator i (rib_.begin());
190 RIB::iterator const i_end (rib_.end());
191 for (; i != i_end; ++i)
192 if ( (! i->stream_ || i->stream_ == &stream) &&
193 (! i->area_ || i->area_ == &area) &&
194 (i->level_ == NONE::value ? i->stream_->defaultRuntimeLimit() : i->level_) <= level ) {
195 if (i->action_ == ACCEPT)
196 v_write(timestamp, stream.v_name(), area.v_name(), level, message);
201 ///////////////////////////////////////////////////////////////////////////
202 // senf::log::TimeSource
204 prefix_ senf::log::TimeSource::~TimeSource()
207 ///////////////////////////////////////////////////////////////////////////
208 // senf::log::SystemTimeSource
210 prefix_ boost::posix_time::ptime senf::log::SystemTimeSource::operator()()
213 return boost::posix_time::microsec_clock::universal_time();
216 ///////////////////////////////cc.e////////////////////////////////////////
218 //#include "Target.mpp"
224 // comment-column: 40
225 // c-file-style: "senf"
226 // indent-tabs-mode: nil
227 // ispell-local-dictionary: "american"
228 // compile-command: "scons -u test"