buffered_processor.h

Go to the documentation of this file.

 
#ifndef CPPLOGGING_PROCESSORS_BUFFERED_PROCESSOR_H
#define CPPLOGGING_PROCESSORS_BUFFERED_PROCESSOR_H
 
#include "logging/processor.h"
 
namespace CppLogging {
 
 
class BufferedProcessor : public Processor
{
public:
 
    explicit BufferedProcessor(const std::shared_ptr<Layout>& layout, size_t limit = 65536, size_t capacity = 8192) : Processor(layout), _limit(limit)
    { _buffer.reserve(capacity); }
    BufferedProcessor(const BufferedProcessor&) = delete;
    BufferedProcessor(BufferedProcessor&&) = delete;
    virtual ~BufferedProcessor() = default;
 
    BufferedProcessor& operator=(const BufferedProcessor&) = delete;
    BufferedProcessor& operator=(BufferedProcessor&&) = delete;
 
    // Implementation of Processor
    bool ProcessRecord(Record& record) override;
    void Flush() override;
 
private:
    size_t _limit;
    std::vector<Record> _buffer;
 
    void ProcessBufferedRecords();
};
 
} // namespace CppLogging
 
#endif // CPPLOGGING_PROCESSORS_BUFFERED_PROCESSOR_H