eventHandling.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_RTRSERVER_EVENTHANDLING_HPP
#define RTCTK_RTRSERVER_EVENTHANDLING_HPP
 
#include <atomic>
#include <chrono>
#include <condition_variable>
#include <cstdint>
#include <mutex>
#include <nlohmann/json.hpp>
#include <optional>
#include <queue>
#include <set>
#include <string>
#include <thread>
 
using Event = nlohmann::json;
 
Event MakeWriteEvent(const std::set<std::string>& datapoints,
                     uint64_t sequence_id,
                     uint64_t timestamp);
Event MakeCreateEvent(const std::string& datapoint);
Event MakeDeleteEvent(const std::string& datapoint);
 
class EventQueue {
public:
    void Post(const Event& data);
    std::optional<Event> Pend(std::chrono::milliseconds timeout);
 
private:
    // cppcheck-suppress-begin unusedStructMember
 
    std::mutex m_mutex;
    std::condition_variable m_cv;
    std::queue<Event> m_queue;
 
    // cppcheck-suppress-end unusedStructMember
};
 
class EventPublisher {
public:
    EventPublisher(const std::string& topic, EventQueue& queue);
    ~EventPublisher();
 
private:
    void Work();
 
    // cppcheck-suppress-begin unusedStructMember
 
    std::string m_topic_name;
    EventQueue& m_queue;
    std::atomic<bool> m_stop;
    std::thread m_thread;
 
    // cppcheck-suppress-end unusedStructMember
};
 
#endif  // RTCTK_RTRSERVER_EVENTHANDLING_HPP