TCPDataListenerProducer.h

#ifndef _ots_TCPDataListenerProducer_h_
#define _ots_TCPDataListenerProducer_h_
 
#include "otsdaq/Configurable/Configurable.h"
#include "otsdaq/DataManager/DataProducer.h"
#include "otsdaq/NetworkUtilities/TCPListenServer.h"  // Make sure this is always first because <sys/types.h> (defined in Socket.h) must be first
 
#include <atomic>
#include <chrono>
#include <cstdint>
#include <map>
#include <string>
 
namespace ots
{
class ConfigurationTree;
 
class TCPDataListenerProducer : public DataProducer,
                                public Configurable,
                                public TCPListenServer
{
  public:
    TCPDataListenerProducer(std::string              supervisorApplicationUID,
                            std::string              bufferUID,
                            std::string              processorUID,
                            const ConfigurationTree& theXDAQContextConfigTree,
                            const std::string&       configurationPath);
    virtual ~TCPDataListenerProducer(void);
    virtual void startProcessingData(std::string runNumber) override;
    virtual void stopProcessingData(void) override;
 
    std::map<std::string, std::string> getExtraStatus(void) const override;
 
  protected:
    bool workLoopThread(toolbox::task::WorkLoop* workLoop) override;
    void slowWrite(void);
    void fastWrite(void);
    void sampleSocketBacklog(void);  
 
    std::atomic<uint64_t>                 statClients_{0};
    std::atomic<uint64_t>                 statSocketBacklogBytes_{0};
    std::chrono::steady_clock::time_point lastBacklogSample_{};
    std::string                        data_;
    std::map<std::string, std::string> header_;
    std::string*                        dataP_;
    std::map<std::string, std::string>* headerP_;
 
    std::string dataType_;
    unsigned    port_;
 
    // bool getNextFragment(void);
};
 
}  // namespace ots
 
#endif