sync_processor.h

Go to the documentation of this file.

 
#ifndef CPPLOGGING_PROCESSORS_SYNC_PROCESSOR_H
#define CPPLOGGING_PROCESSORS_SYNC_PROCESSOR_H
 
#include "logging/processor.h"
 
#include "threads/critical_section.h"
 
namespace CppLogging {
 
 
class SyncProcessor : public Processor
{
public:
 
    explicit SyncProcessor(const std::shared_ptr<Layout>& layout) : Processor(layout) {}
    SyncProcessor(const SyncProcessor&) = delete;
    SyncProcessor(SyncProcessor&&) = delete;
    virtual ~SyncProcessor() = default;
 
    SyncProcessor& operator=(const SyncProcessor&) = delete;
    SyncProcessor& operator=(SyncProcessor&&) = delete;
 
    // Implementation of Processor
    bool ProcessRecord(Record& record) override;
    void Flush() override;
 
private:
    CppCommon::CriticalSection _lock;
};
 
} // namespace CppLogging
 
#endif // CPPLOGGING_PROCESSORS_SYNC_PROCESSOR_H