54 lines
1.5 KiB
C++
54 lines
1.5 KiB
C++
|
/*
|
||
|
|
* Copyright 2002, Log4cpp Project. All rights reserved.
|
||
|
|
*
|
||
|
|
* See the COPYING file for the terms of usage and distribution.
|
||
|
|
*/
|
||
|
|
|
||
|
|
#include "PortabilityImpl.hh"
|
||
|
|
#include <log4cpp/BufferingAppender.hh>
|
||
|
|
#include <algorithm>
|
||
|
|
#include <sstream>
|
||
|
|
#include <memory>
|
||
|
|
|
||
|
|
namespace log4cpp
|
||
|
|
{
|
||
|
|
BufferingAppender::BufferingAppender(const std::string name, unsigned long max_size,
|
||
|
|
std::auto_ptr<Appender> sink, std::auto_ptr<TriggeringEventEvaluator> evaluator)
|
||
|
|
:LayoutAppender(name), max_size_(max_size), sink_(sink), evaluator_(evaluator), lossy_(false)
|
||
|
|
{
|
||
|
|
max_size_ = (max)(1UL, max_size_);
|
||
|
|
}
|
||
|
|
|
||
|
|
void BufferingAppender::_append(const LoggingEvent& event)
|
||
|
|
{
|
||
|
|
if (queue_.size() == max_size_)
|
||
|
|
if (lossy_)
|
||
|
|
queue_.pop_back();
|
||
|
|
else
|
||
|
|
dump();
|
||
|
|
|
||
|
|
queue_.push_front(event);
|
||
|
|
|
||
|
|
if (evaluator_->eval(event))
|
||
|
|
{
|
||
|
|
dump();
|
||
|
|
queue_.clear();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static const std::string EMPTY;
|
||
|
|
|
||
|
|
void BufferingAppender::dump()
|
||
|
|
{
|
||
|
|
Layout& layout = _getLayout();
|
||
|
|
std::ostringstream s;
|
||
|
|
// Solaris 10 CC can't work with const_reverse_iterator
|
||
|
|
for(queue_t::reverse_iterator i = queue_.rbegin(), last = queue_.rend(); i != last; ++i)
|
||
|
|
s << layout.format(*i);
|
||
|
|
|
||
|
|
LoggingEvent event(EMPTY, s.str(), EMPTY, Priority::NOTSET);
|
||
|
|
sink_->doAppend(event);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|