pub.hpp

Go to the documentation of this file.

#ifndef NGC_GATEWAY_DDT_PUB_H_
#define NGC_GATEWAY_DDT_PUB_H_
 
#include <string>
#include <mutex>
 
#define BOOST_BIND_GLOBAL_PLACEHOLDERS
#include <ddt/ddtDataPublisherApplication.hpp>
#include <ddt/ddtDataPublisher.hpp>
#include <ddt/ddtDataTransferFactory.hpp>
#include <ddt/ddtEncDecImage2D.hpp>
#include <ddt/ddtEncDecImage3D.hpp>
#include <ddt/ddtLogger.hpp>
 
#include <ngc/core/ngcdtt.hpp>
 
namespace ngc::gateway::ddt {

  class Publisher: public ngcdttPUBLISH {
  public:
    explicit Publisher(std::mutex &m, ::ddt::DdtLogger *logger = nullptr);
    
    explicit Publisher(std::mutex &m, int n, ::ddt::DdtLogger *logger = nullptr);
    
    virtual ~Publisher();
    

    Publisher(Publisher&) = delete;
    Publisher(Publisher&&) = delete;
    Publisher& operator=(Publisher&) = delete;
    
    virtual int Configure(const char *name, int nx, int ny) override;
    
    virtual void Shutdown() override;
    
    virtual int IdxOut() override;
    
    virtual int IdxIn() override;
    
    virtual int Locked(int idx) override;
    
    virtual int Lock(int idx) override;
    
    virtual int TryLock(int idx) override;
    
    virtual int Unlock(int idx) override;
    
    virtual int Wait(int idx) override;
    
    virtual int Publish(int idx) override;
    
    virtual void Invalidate(int idx) override;
    
  private:
    int m_registered;
    
    int m_num_buf;
    
    int m_idx_in; 
    
    int m_idx_out; 
    
    uint32_t m_image_id;
    
    int m_endian; 
    
    std::mutex &m_gw_mutex;
    
    ::ddt::DdtLogger *m_logger;
    
    std::unique_ptr<::ddt::DdtDataPublisher> m_publisher;
    
    DdtEncDecImage2D m_encoder;
    //DdtEncDecImage3D encoder_;
    
    void Init();
    
    void Free();
  };    
}
 
#endif /* NGC_GATEWAY_DTT_PUB_H_ */