ddtSender.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <boost/lockfree/spsc_queue.hpp>
#include <boost/atomic.hpp>
 
#include <ddt/ddtDataPublisherApplication.hpp>
#include <ddt/ddtDataPublisher.hpp>
#include <ddt/ddtDataTransferFactory.hpp>
#include <ddt/ddtEncDecImage3D.hpp>
#include <ddt/ddtLogger.hpp>
 
#include <ifw/fnd/defs/dataType.hpp>
 
#include <ifw/rtmslib_llnetio/logger.hpp>
#include <ifw/rtmstools/rtms2ddtlib_llnetio/ddtImage.hpp>
 
namespace ifw::rtmstools::rtms2ddtlib_llnetio {
 
    constexpr short QUEUE_SIZE = 5;
    constexpr short DDT_BUFFER_ITEMS = 2;

    struct DdtSender {
 
        // Basic image information.
        int m_width;
        int m_height;
        ifw::fnd::datatype::DataType m_data_type;
 
        // Information to connect to the DDT broker.
        std::string m_broker_uri;
        std::string m_ddt_stream;
 
        // Interval to publish images.
        int m_interval;
 
        log4cplus::Logger  m_logger;
 
        std::unique_ptr<ddt::DdtDataPublisher> m_publisher;
        DdtEncDecImage3D                       m_encoder;
        std::size_t                            m_buffer_capacity{0};
 
        DdtSender(int width,
                  int height,
                  ifw::fnd::datatype::DataType datatype,
                  std::string broker_uri,
                  std::string ddt_stream,
                  int interval = 100);

        void RegisterPublisher();

        void Run();

        void Shutdown();
 
    public:
        static std::atomic<bool> new_data; // Flag to notify a new image
        static std::atomic<bool> stopped;  // Flag to stop infinite loop
 
        // Single-writer/single-reader FIFO queue.
        static boost::lockfree::spsc_queue<std::shared_ptr<DdtImage>,
        boost::lockfree::capacity<5>> spsc_queue;
    };
}