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 */
31 #include "ConsoleTarget.hh"
33 //#include "Target.mpp"
35 ///////////////////////////////cc.p////////////////////////////////////////
37 ///////////////////////////////////////////////////////////////////////////
40 prefix_ senf::log::Target::Target()
42 detail::TargetRegistry::instance().registerTarget(this);
45 prefix_ senf::log::Target::~Target()
47 while( ! rib_.empty()) {
48 // This is terribly slow but simplifies the area cache handling and removing a target should
50 RIB::reverse_iterator i (rib_.rbegin());
51 unroute(i->stream_, i->area_, i->level_, i->action_);
53 detail::TargetRegistry::instance().unregisterTarget(this);
56 prefix_ void senf::log::Target::route(std::string const & stream, std::string const & area,
57 unsigned level, action_t action, int index)
59 detail::StreamBase const * s (StreamRegistry::instance().lookup(stream));
61 throw InvalidStreamException();
62 detail::AreaBase const * a (0);
64 a = AreaRegistry::instance().lookup(area);
66 throw InvalidAreaException();
68 route(s, a, level, action, index);
71 prefix_ void senf::log::Target::unroute(std::string const & stream, std::string const & area,
72 unsigned level, action_t action)
74 detail::StreamBase const * s (StreamRegistry::instance().lookup(stream));
76 throw InvalidStreamException();
77 detail::AreaBase const * a (0);
79 a = AreaRegistry::instance().lookup(area);
81 throw InvalidAreaException();
83 unroute(s, a, level, action);
86 prefix_ void senf::log::Target::unroute(int index)
90 if (RIB::size_type(-index) >= rib_.size())
94 std::advance(i, index);
97 if (RIB::size_type(index+1) >= rib_.size()) {
102 std::advance(i, index);
107 RoutingEntry entry (*i);
109 if (entry.action_ == ACCEPT)
110 updateRoutingCache(entry.stream_, entry.area_);
113 ////////////////////////////////////////
116 prefix_ void senf::log::Target::route(detail::StreamBase const * stream,
117 detail::AreaBase const * area, unsigned level,
118 action_t action, int index)
122 if (RIB::size_type(-index-1) >= rib_.size())
126 std::advance(i, index + 1 );
129 if (RIB::size_type(index) >= rib_.size())
133 std::advance(i, index);
136 rib_.insert(i, RoutingEntry(stream, area, level, action));
137 if (action == ACCEPT)
138 updateRoutingCache(stream, area);
139 // This disables the initial fallback routing
140 detail::TargetRegistry::instance().routed();
143 prefix_ void senf::log::Target::unroute(detail::StreamBase const * stream,
144 detail::AreaBase const * area, unsigned level,
147 RIB::iterator i = std::find(rib_.begin(), rib_.end(),
148 RoutingEntry(stream, area, level, action));
150 unroute(std::distance(rib_.begin(), i));
153 prefix_ void senf::log::Target::updateRoutingCache(detail::StreamBase const * stream,
154 detail::AreaBase const * area)
157 StreamRegistry::Registry::iterator i (StreamRegistry::instance().registry_.begin());
158 StreamRegistry::Registry::iterator const i_end (StreamRegistry::instance().registry_.end());
159 for (; i != i_end ; ++i)
160 updateRoutingCache(i->second, area);
164 AreaRegistry::Registry::iterator i (AreaRegistry::instance().registry_.begin());
165 AreaRegistry::Registry::iterator const i_end (AreaRegistry::instance().registry_.end());
166 for (; i != i_end ; ++i)
167 updateRoutingCache(stream, i->second);
170 unsigned limit (DISABLED::value);
171 RIB::iterator i (rib_.begin());
172 RIB::iterator const i_end (rib_.end());
173 for(; i != i_end; ++i)
174 if ( (! i->stream_ || i->stream_ == stream) &&
175 (! i->area_ || i->area_ == area) &&
176 i->action_ == ACCEPT ) {
177 unsigned l (i->level_ == NONE::value ? i->stream_->defaultRuntimeLimit() : i->level_);
181 if (limit == DISABLED::value)
182 area->removeRoutingCache(*this, *stream);
184 area->updateRoutingCache(*this, *stream, limit);
187 prefix_ void senf::log::Target::write(boost::posix_time::ptime timestamp,
188 detail::StreamBase const & stream,
189 detail::AreaBase const & area, unsigned level,
190 std::string const & message)
192 RIB::iterator i (rib_.begin());
193 RIB::iterator const i_end (rib_.end());
194 for (; i != i_end; ++i)
195 if ( (! i->stream_ || i->stream_ == &stream) &&
196 (! i->area_ || i->area_ == &area) &&
197 (i->level_ == NONE::value ? i->stream_->defaultRuntimeLimit() : i->level_) <= level ) {
198 if (i->action_ == ACCEPT)
199 v_write(timestamp, stream.v_name(), area.v_name(), level, message);
204 ///////////////////////////////////////////////////////////////////////////
205 // senf::log::detail::TargetRegistry
207 prefix_ void senf::log::detail::TargetRegistry::write(StreamBase const & stream,
208 AreaBase const & area, unsigned level,
211 if (fallbackRouting_)
212 static_cast<Target &>(ConsoleTarget::instance()).v_write(
213 (*timeSource_)(), stream.v_name(), area.v_name(), level, msg );
215 area.write( (*timeSource_)(), stream, level, msg );
218 ///////////////////////////////////////////////////////////////////////////
219 // senf::log::TimeSource
221 prefix_ senf::log::TimeSource::~TimeSource()
224 ///////////////////////////////////////////////////////////////////////////
225 // senf::log::SystemTimeSource
227 prefix_ boost::posix_time::ptime senf::log::SystemTimeSource::operator()()
230 return boost::posix_time::microsec_clock::universal_time();
233 ///////////////////////////////cc.e////////////////////////////////////////
235 //#include "Target.mpp"
241 // comment-column: 40
242 // c-file-style: "senf"
243 // indent-tabs-mode: nil
244 // ispell-local-dictionary: "american"
245 // compile-command: "scons -u test"