/******************************************************************************** * Copyright (C) 2014 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH * * * * This software is distributed under the terms of the * * GNU Lesser General Public Licence (LGPL) version 3, * * copied verbatim in the file "LICENSE" * ********************************************************************************/ #include #include #include namespace bpo = boost::program_options; class Sink : public FairMQDevice { public: Sink() : fMaxIterations(0) , fNumIterations(0) { // register a handler for data arriving on "data" channel OnData("data", &Sink::HandleData); } protected: void InitTask() override { // Get the fMaxIterations value from the command line options (via fConfig) fMaxIterations = fConfig->GetProperty("max-iterations"); } bool HandleData(FairMQMessagePtr& msg, int) { LOG(info) << "Received: \"" << std::string(static_cast(msg->GetData()), msg->GetSize()) << "\""; if (fMaxIterations > 0 && ++fNumIterations >= fMaxIterations) { LOG(info) << "Configured maximum number of iterations reached. Leaving RUNNING state."; return false; } // return true if you want the handler to be called again (otherwise return false go to the // Ready state) return true; } private: uint64_t fMaxIterations; uint64_t fNumIterations; }; void addCustomOptions(bpo::options_description& options) { options.add_options() ("max-iterations", bpo::value()->default_value(0), "Maximum number of iterations of Run/ConditionalRun/OnData (0 - infinite)"); } std::unique_ptr getDevice(fair::mq::ProgOptions& /*config*/) { return std::make_unique(); }