FESupervisor.h

#ifndef _ots_FESupervisor_h_
#define _ots_FESupervisor_h_
 
#include "otsdaq/CoreSupervisors/CoreSupervisorBase.h"
 
#include "zmq.hpp"
 
namespace ots
{
class FEVInterfacesManager;
 
class FESupervisor : public CoreSupervisorBase
{
    // friend FEVInterface;
 
  public:
    XDAQ_INSTANTIATOR();
 
    FESupervisor(xdaq::ApplicationStub* s);
    virtual ~FESupervisor(void);
 
    xoap::MessageReference         frontEndCommunicationRequest(xoap::MessageReference message);
    xoap::MessageReference         macroMakerSupervisorRequest(xoap::MessageReference message);
    virtual xoap::MessageReference workLoopStatusRequest(
        xoap::MessageReference message) override;
 
    virtual void transitionConfiguring(toolbox::Event::Reference event) override;
    virtual void transitionHalting(toolbox::Event::Reference event) override;
 
    void publishData(const char* dataPtr, size_t dataSize);
    bool isPublishingData() const { return dp_isInitialized_; }
 
  protected:
    FEVInterfacesManager* theFEInterfacesManager_;
 
    void initDataPublishing(const std::string& endpoint,
                            const std::string& topic = "test");
 
    void closeDataPublishing(bool alsoCloseContext = true);
 
  private:
    FEVInterfacesManager*
    extractFEInterfacesManager();  
 
    // ZeroMQ Publisher
    zmq::context_t dp_context_;                
    zmq::socket_t  dp_socket_;                 
    std::string    dp_endpoint_;               
    std::string    dp_topic_;                  
    bool           dp_isInitialized_ = false;  
};
 
}  // namespace ots
 
#endif