processor.cpp

Go to the documentation of this file.

 
#include "logging/processor.h"
 
namespace CppLogging {
 
Processor::~Processor()
{
    // Flush all appenders
    for (auto& appender : _appenders)
        if (appender && appender->IsStarted())
            appender->Flush();
 
    // Flush all sub processors
    for (auto& processor : _processors)
        if (processor && processor->IsStarted())
            processor->Flush();
 
    // Stop the logging processor
    if (IsStarted())
        Stop();
}
 
bool Processor::Start()
{
    // Start logging layout
    if (_layout && !_layout->IsStarted())
        if (!_layout->Start())
            return false;
 
    // Start logging filters
    for (auto& filter : _filters)
        if (filter && !filter->IsStarted())
            if (!filter->Start())
                return false;
 
    // Start logging appenders
    for (auto& appender : _appenders)
        if (appender && !appender->IsStarted())
            if (!appender->Start())
                return false;
 
    // Start logging processors
    for (auto& processor : _processors)
        if (processor)
            if (!processor->Start())
                return false;
 
    _started = true;
 
    return true;
}
 
bool Processor::Stop()
{
    // Stop logging layout
    if (_layout && _layout->IsStarted())
        if (!_layout->Stop())
            return false;
 
    // Stop logging filters
    for (auto& filter : _filters)
        if (filter && filter->IsStarted())
            if (!filter->Stop())
                return false;
 
    // Stop logging appenders
    for (auto& appender : _appenders)
        if (appender && appender->IsStarted())
            if (!appender->Stop())
                return false;
 
    // Stop logging processors
    for (auto& processor : _processors)
        if (processor)
            if (!processor->Stop())
                return false;
 
    _started = false;
 
    return true;
}
 
bool Processor::FilterRecord(Record& record)
{
    // Filter the given logging record
    for (auto& filter : _filters)
        if (filter && filter->IsStarted() && !filter->FilterRecord(record))
            return false;
 
    return true;
}
 
bool Processor::ProcessRecord(Record& record)
{
    // Check if the logging processor started
    if (!IsStarted())
        return true;
 
    // Filter the given logging record
    if (!FilterRecord(record))
        return true;
 
    // Layout the given logging record
    if (_layout && _layout->IsStarted())
        _layout->LayoutRecord(record);
 
    // Append the given logging record
    for (auto& appender : _appenders)
        if (appender && appender->IsStarted())
            appender->AppendRecord(record);
 
    // Process the given logging record with sub processors
    for (auto& processor : _processors)
        if (processor && processor->IsStarted() && !processor->ProcessRecord(record))
            return false;
 
    return true;
}
 
void Processor::Flush()
{
    // Check if the logging processor started
    if (!IsStarted())
        return;
 
    // Flush all appenders
    for (auto& appender : _appenders)
        if (appender && appender->IsStarted())
            appender->Flush();
 
    // Flush all sub processors
    for (auto& processor : _processors)
        if (processor && processor->IsStarted())
            processor->Flush();
}
 
} // namespace CppLogging