ddtSender.hpp

Go to the documentation of this file.

 
#ifndef RTMPS2DDT_SENDER_HPP_
#define RTMPS2DDT_SENDER_HPP_
 
#define BOOST_BIND_NO_PLACEHOLDERS
 
#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/rtmslib/dataType.hpp>
#include <ifw/fnd/defs/dataType.hpp>
 
#include <ifw/rtmslib/logger.hpp>
#include <ifw/rtms2ddtlib/ddtImage.hpp>
 
namespace ifw::rtmstools {
 
    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;
 
        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();
 
    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<rtmstools::DdtImage>,
        boost::lockfree::capacity<5>> spsc_queue;
    };
}
 
#endif  // RTMPS2DDT_SENDER_HPP_