diff --git a/src/WZDmaInputFilter.h b/src/WZDmaInputFilter.h index 1460702c370417c6a3f7de3e144a63416ea9a25c..2d9e8c217e0f5cadb4f3bbe8d423cfc5641db171 100644 --- a/src/WZDmaInputFilter.h +++ b/src/WZDmaInputFilter.h @@ -32,6 +32,10 @@ private: } stats; struct wz_private dma_; + + std::string sconeHost_; + std::string sconePort_; + std::string sconeBoard_; }; typedef std::shared_ptr<WZDmaInputFilter> WZDmaInputFilterPtr; diff --git a/src/config.h b/src/config.h index e25680e5059012f9fb9711a88589ac29c0af1bbe..5a898c7b269dcb20f09f73d208a5f11232da908b 100644 --- a/src/config.h +++ b/src/config.h @@ -36,40 +36,46 @@ public: } throw std::invalid_argument("Configuration error: Wrong input type '" + input + "'"); } + const std::string& getDmaDevice() const { return vmap.at("dma_dev"); } + uint64_t getDmaPacketBufferSize() const { std::string v = vmap.at("dma_packet_buffer_size"); return boost::lexical_cast<uint64_t>(v.c_str()); } + uint32_t getNumberOfDmaPacketBuffers() const { std::string v = vmap.at("dma_number_of_packet_buffers"); return boost::lexical_cast<uint32_t>(v.c_str()); } + uint32_t getPacketsPerReport() const { std::string v = vmap.at("packets_per_report"); return boost::lexical_cast<uint32_t>(v.c_str()); } + const std::string& getInputFile() const { return vmap.at("input_file"); } - const std::string& getElasticUrl() const - { + + const std::string& getElasticUrl() const { return vmap.at("elastic_url"); } + uint32_t getQualCut() const { std::string v = vmap.at("quality_cut"); return boost::lexical_cast<uint32_t>(v.c_str()); } + uint32_t getPtCut() const { std::string v = vmap.at("pt_cut"); return boost::lexical_cast<uint32_t>(v.c_str()); } - const std::string& getBitFileName() const - { + const std::string& getBitFileName() const { return vmap.at("bitFileName"); } @@ -90,59 +96,81 @@ public: throw std::invalid_argument("Configuration error: Wrong processor type '" + input + "'"); } - const std::string& getOutputFilenamePrefix() const - { + const std::string& getOutputFilenamePrefix() const { return vmap.at("output_filename_prefix"); } - const std::string& getOutputFilenameBase() const - { + + const std::string& getOutputFilenameBase() const { return vmap.at("output_filename_base"); } + uint64_t getOutputMaxFileSize() const { std::string v = vmap.at("max_file_size"); return boost::lexical_cast<uint64_t>(v.c_str()); } + bool getOutputForceWrite() const { return (true ? vmap.at("output_force_write") == "yes" : false); } bool getLoadBitFile() const { return (true ? vmap.at("loadBitFile") == "yes" : false); -} + } uint32_t getNOrbitsPerDMAPacket() const { std::string v = vmap.at("NOrbitsPerDMAPacket"); return boost::lexical_cast<uint32_t>(v.c_str()); } + uint32_t getPrescaleFactor() const { std::string v = vmap.at("prescale_factor"); return boost::lexical_cast<uint32_t>(v.c_str()); } + uint32_t getNumThreads() const { std::string v = vmap.at("threads"); return boost::lexical_cast<uint32_t>(v.c_str()); } + short getPortNumber() const { std::string v = vmap.at("port"); return boost::lexical_cast<short>(v.c_str()); } + bool getEnableStreamProcessor() const { return (true ? vmap.at("enable_stream_processor") == "yes" : false); } + bool getEnableElasticProcessor() const { return (true ? vmap.at("enable_elastic_processor") == "yes" : false); } + bool getDoZS() const { return (true ? vmap.at("doZS") == "yes" : false); } + bool getVerbosity() const { std::string v = vmap.at("verbosity"); return boost::lexical_cast<uint32_t>(v.c_str()); } + uint32_t getNOrbitsPerFile() const { //If > 0, the fixed N orbits per file option is performed std::string v = vmap.at("nOrbitsPerFile"); return boost::lexical_cast<uint32_t>(v.c_str()); } + + const std::string getSconeHost() const { + return vmap.at("scone_host"); + } + + const std::string getSconePort() const { + return vmap.at("scone_port"); + } + + const std::string getSconeBoard() const { + return vmap.at("scone_board"); + } + private: std::map<std::string,std::string> vmap;