Skip to content

Commit

Permalink
runDevice: remove const from getDevice parameter
Browse files Browse the repository at this point in the history
  • Loading branch information
rbx authored and dennisklein committed May 13, 2021
1 parent e6f67b3 commit a7dbead
Show file tree
Hide file tree
Showing 7 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion fairmq/devices/runBenchmarkSampler.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -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");
}

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>();
}
2 changes: 1 addition & 1 deletion fairmq/devices/runMerger.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ void addCustomOptions(bpo::options_description& options)
("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>();
}
2 changes: 1 addition & 1 deletion fairmq/devices/runMultiplier.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ void addCustomOptions(bpo::options_description& options)
("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>();
}
2 changes: 1 addition & 1 deletion fairmq/devices/runProxy.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ void addCustomOptions(bpo::options_description& options)
("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>();
}
2 changes: 1 addition & 1 deletion fairmq/devices/runSink.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ void addCustomOptions(bpo::options_description& options)
("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>();
}
2 changes: 1 addition & 1 deletion fairmq/devices/runSplitter.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ void addCustomOptions(bpo::options_description& options)
("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>();
}
2 changes: 1 addition & 1 deletion fairmq/runDevice.h
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
#include <memory>

// 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)
void addCustomOptions(boost::program_options::options_description&);
Expand Down

0 comments on commit a7dbead

Please sign in to comment.