FESupervisor.h

#ifndef _ots_FESupervisor_h_
#define _ots_FESupervisor_h_
 
#include "otsdaq/CoreSupervisors/CoreSupervisorBase.h"
 
#include "zmq.hpp"
 
#include <memory>
#include <mutex>
#include <thread>
#include <vector>
 
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();  
 
    // Async FE Macro task tracking (for long-running macros that exceed SOAP timeout)
    struct AsyncMacroTask
    {
        uint64_t        taskID;
        std::string     interfaceID;
        std::thread::id threadID;
        std::string     outputArgs;
        std::string     error;
        bool            done      = false;
        time_t          startTime = 0;
        time_t          doneTime  = 0;
    };
    std::mutex                                   asyncMacroMutex_;
    std::vector<std::shared_ptr<AsyncMacroTask>> asyncMacroTasks_;
    uint64_t                                     asyncMacroTaskIDCounter_ = 0;
 
    // 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