Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 16:46:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

runDevice: remove const from getDevice parameter

Browse Source
This commit is contained in:
Alexey Rybalchenko 2021-05-13 21:52:58 +02:00 committed by Dennis Klein
parent e6f67b3658
commit a7dbeadd1c
7 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
fairmq/devices/runBenchmarkSampler.cxx
View File

@ -24,7 +24,7 @@ void addCustomOptions(bpo::options_description& options)
("msg-rate", bpo::value<float>()->default_value(0), "Msg rate limit in maximum number of messages per second"); ("msg-rate", bpo::value<float>()->default_value(0), "Msg rate limit in maximum number of messages per second");
} }
std::unique_ptr<fair::mq::Device> getDevice(const fair::mq::ProgOptions& /* config */) std::unique_ptr<fair::mq::Device> getDevice(fair::mq::ProgOptions& /* config */)
{ {
return std::make_unique<fair::mq::BenchmarkSampler>(); return std::make_unique<fair::mq::BenchmarkSampler>();
} }

2
fairmq/devices/runMerger.cxx
View File

@ -19,7 +19,7 @@ void addCustomOptions(bpo::options_description& options)
("multipart", bpo::value<bool>()->default_value(true), "Handle multipart payloads"); ("multipart", bpo::value<bool>()->default_value(true), "Handle multipart payloads");
} }
std::unique_ptr<fair::mq::Device> getDevice(const fair::mq::ProgOptions& /*config*/) std::unique_ptr<fair::mq::Device> getDevice(fair::mq::ProgOptions& /*config*/)
{ {
return std::make_unique<fair::mq::Merger>(); return std::make_unique<fair::mq::Merger>();
} }

2
fairmq/devices/runMultiplier.cxx
View File

@ -19,7 +19,7 @@ void addCustomOptions(bpo::options_description& options)
("multipart", bpo::value<bool>()->default_value(true), "Handle multipart payloads"); ("multipart", bpo::value<bool>()->default_value(true), "Handle multipart payloads");
} }
std::unique_ptr<fair::mq::Device> getDevice(const fair::mq::ProgOptions& /*config*/) std::unique_ptr<fair::mq::Device> getDevice(fair::mq::ProgOptions& /*config*/)
{ {
return std::make_unique<fair::mq::Multiplier>(); return std::make_unique<fair::mq::Multiplier>();
} }

2
fairmq/devices/runProxy.cxx
View File

@ -19,7 +19,7 @@ void addCustomOptions(bpo::options_description& options)
("multipart", bpo::value<bool>()->default_value(true), "Handle multipart payloads"); ("multipart", bpo::value<bool>()->default_value(true), "Handle multipart payloads");
} }
std::unique_ptr<fair::mq::Device> getDevice(const fair::mq::ProgOptions& /*config*/) std::unique_ptr<fair::mq::Device> getDevice(fair::mq::ProgOptions& /*config*/)
{ {
return std::make_unique<fair::mq::Proxy>(); return std::make_unique<fair::mq::Proxy>();
} }

2
fairmq/devices/runSink.cxx
View File

@ -21,7 +21,7 @@ void addCustomOptions(bpo::options_description& options)
("multipart", bpo::value<bool>()->default_value(false), "Handle multipart payloads"); ("multipart", bpo::value<bool>()->default_value(false), "Handle multipart payloads");
} }
std::unique_ptr<fair::mq::Device> getDevice(const fair::mq::ProgOptions& /*config*/) std::unique_ptr<fair::mq::Device> getDevice(fair::mq::ProgOptions& /*config*/)
{ {
return std::make_unique<fair::mq::Sink>(); return std::make_unique<fair::mq::Sink>();
} }

2
fairmq/devices/runSplitter.cxx
View File

@ -19,7 +19,7 @@ void addCustomOptions(bpo::options_description& options)
("multipart", bpo::value<bool>()->default_value(true), "Handle multipart payloads"); ("multipart", bpo::value<bool>()->default_value(true), "Handle multipart payloads");
} }
std::unique_ptr<fair::mq::Device> getDevice(const fair::mq::ProgOptions& /*config*/) std::unique_ptr<fair::mq::Device> getDevice(fair::mq::ProgOptions& /*config*/)
{ {
return std::make_unique<fair::mq::Splitter>(); return std::make_unique<fair::mq::Splitter>();
} }

2
fairmq/runDevice.h
View File

@ -11,7 +11,7 @@
#include <memory> #include <memory>
// to be implemented by the user to return a child class of FairMQDevice // to be implemented by the user to return a child class of FairMQDevice
std::unique_ptr<fair::mq::Device> getDevice(const fair::mq::ProgOptions& config); std::unique_ptr<fair::mq::Device> getDevice(fair::mq::ProgOptions& config);
// to be implemented by the user to add custom command line options (or just with empty body) // to be implemented by the user to add custom command line options (or just with empty body)
void addCustomOptions(boost::program_options::options_description&); void addCustomOptions(boost::program_options::options_description&);