async_wait_free_processor.h

Go to the documentation of this file.

 
#ifndef CPPLOGGING_PROCESSORS_ASYNC_WAIT_FREE_PROCESSOR_H
#define CPPLOGGING_PROCESSORS_ASYNC_WAIT_FREE_PROCESSOR_H
 
#include "logging/processor.h"
 
#include "logging/processors/async_wait_free_queue.h"
 
#include <functional>
 
namespace CppLogging {
 
 
class AsyncWaitFreeProcessor : public Processor
{
public:
 
    explicit AsyncWaitFreeProcessor(const std::shared_ptr<Layout>& layout, bool auto_start = true, size_t capacity = 8192, bool discard = false, const std::function<void ()>& on_thread_initialize = [](){}, const std::function<void ()>& on_thread_clenup = [](){});
    AsyncWaitFreeProcessor(const AsyncWaitFreeProcessor&) = delete;
    AsyncWaitFreeProcessor(AsyncWaitFreeProcessor&&) = delete;
    virtual ~AsyncWaitFreeProcessor();
 
    AsyncWaitFreeProcessor& operator=(const AsyncWaitFreeProcessor&) = delete;
    AsyncWaitFreeProcessor& operator=(AsyncWaitFreeProcessor&&) = delete;
 
    // Implementation of Processor
    bool Start() override;
    bool Stop() override;
    bool ProcessRecord(Record& record) override;
    void Flush() override;
 
private:
    bool _discard;
    AsyncWaitFreeQueue<Record> _queue;
    std::thread _thread;
    std::function<void ()> _on_thread_initialize;
    std::function<void ()> _on_thread_clenup;
 
    bool EnqueueRecord(bool discard, Record& record);
    void ProcessThread(const std::function<void ()>& on_thread_initialize, const std::function<void ()>& on_thread_clenup);
};
 
} // namespace CppLogging
 
#endif // CPPLOGGING_PROCESSORS_ASYNC_WAIT_FREE_PROCESSOR_H