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 */
27 //#include "Target.ih"
31 //#include "Target.mpp"
33 ///////////////////////////////cc.p////////////////////////////////////////
35 ///////////////////////////////////////////////////////////////////////////
38 prefix_ senf::log::Target::Target()
40 TargetRegistry::instance().registerTarget(this);
43 prefix_ senf::log::Target::~Target()
45 while( ! rib_.empty()) {
46 // This is terribly slow but simplifies the area cache handling and removing a target should
48 RIB::reverse_iterator i (rib_.rbegin());
49 unroute(i->stream_, i->area_, i->level_, i->action_);
51 TargetRegistry::instance().unregisterTarget(this);
54 prefix_ void senf::log::Target::route(std::string const & stream, std::string const & area,
55 unsigned level, action_t action, int index)
57 detail::StreamBase const * s (StreamRegistry::instance().lookup(stream));
59 throw InvalidStreamException();
60 detail::AreaBase const * a (0);
62 a = AreaRegistry::instance().lookup(area);
64 throw InvalidAreaException();
66 route(s, a, level, action, index);
69 prefix_ void senf::log::Target::unroute(int index)
73 if (RIB::size_type(-index) >= rib_.size())
77 std::advance(i, -index);
80 if (RIB::size_type(index+1) >= rib_.size()) {
85 std::advance(i, index);
88 RoutingEntry entry (*i);
90 if (entry.action_ == ACCEPT)
91 updateRoutingCache(entry.stream_, entry.area_);
94 ////////////////////////////////////////
97 prefix_ void senf::log::Target::route(detail::StreamBase const * stream,
98 detail::AreaBase const * area, unsigned level,
99 action_t action, int index)
103 if (RIB::size_type(-index-1) >= rib_.size())
107 std::advance(i, -index - 1);
110 if (RIB::size_type(index) >= rib_.size())
114 std::advance(i, index);
117 rib_.insert(i, RoutingEntry(stream, area, level, action));
118 if (action == ACCEPT)
119 updateRoutingCache(stream, area);
122 prefix_ void senf::log::Target::unroute(detail::StreamBase const * stream,
123 detail::AreaBase const * area, unsigned level,
126 RIB::iterator i = std::find(rib_.begin(), rib_.end(),
127 RoutingEntry(stream, area, level, action));
129 unroute(std::distance(rib_.begin(), i));
132 prefix_ void senf::log::Target::updateRoutingCache(detail::StreamBase const * stream,
133 detail::AreaBase const * area)
136 StreamRegistry::Registry::iterator i (StreamRegistry::instance().registry_.begin());
137 StreamRegistry::Registry::iterator const i_end (StreamRegistry::instance().registry_.end());
138 for (; i != i_end ; ++i)
139 updateRoutingCache(i->second, area);
143 AreaRegistry::Registry::iterator i (AreaRegistry::instance().registry_.begin());
144 AreaRegistry::Registry::iterator const i_end (AreaRegistry::instance().registry_.end());
145 for (; i != i_end ; ++i)
146 updateRoutingCache(stream, i->second);
149 unsigned limit (DISABLED::value);
150 RIB::iterator i (rib_.begin());
151 RIB::iterator const i_end (rib_.end());
152 for(; i != i_end; ++i)
153 if ( (! i->stream_ || i->stream_ == stream) &&
154 (! i->area_ || i->area_ == area) &&
155 i->action_ == ACCEPT ) {
156 unsigned l (i->level_ == NONE::value ? i->stream_->defaultRuntimeLimit() : i->level_);
160 if (limit == DISABLED::value)
161 area->removeRoutingCache(*this, *stream);
163 area->updateRoutingCache(*this, *stream, limit);
166 prefix_ void senf::log::Target::write(boost::posix_time::ptime timestamp,
167 detail::StreamBase const & stream,
168 detail::AreaBase const & area, unsigned level,
169 std::string const & message)
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->level_ == NONE::value ? i->stream_->defaultRuntimeLimit() : i->level_) <= level ) {
177 if (i->action_ == ACCEPT)
178 v_write(timestamp, stream.v_name(), area.v_name(), level, message);
183 ///////////////////////////////////////////////////////////////////////////
184 // senf::log::TargetRegistry
186 prefix_ void senf::log::TargetRegistry::write(detail::StreamBase const & stream,
187 detail::AreaBase const & area, unsigned level,
190 boost::posix_time::ptime timestamp (boost::posix_time::microsec_clock::universal_time());
191 area.write(timestamp, stream, level, msg);
194 ///////////////////////////////cc.e////////////////////////////////////////
196 //#include "Target.mpp"
202 // comment-column: 40
203 // c-file-style: "senf"
204 // indent-tabs-mode: nil
205 // ispell-local-dictionary: "american"
206 // compile-command: "scons -u test"