/******************************************************************************** * 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 // uint64_t namespace bpo = boost::program_options; struct Sampler : fair::mq::Device { void InitTask() override { fIterations = fConfig->GetValue("iterations"); } bool ConditionalRun() override { // NewSimpleMessage creates a copy of the data and takes care of its destruction (after the transfer takes place). // Should only be used for small data because of the cost of an additional copy FairMQMessagePtr msg(NewSimpleMessage("Data")); LOG(info) << "Sending \"Data\""; // in case of error or transfer interruption, return false to go to IDLE state // successfull transfer will return number of bytes transfered (can be 0 if sending an empty message). if (Send(msg, "data1") < 0) { return false; } if (fIterations > 0) { ++fCounter; if (fCounter >= fIterations) { LOG(info) << "Sent " << fCounter << " messages. Finished."; return false; } } return true; } private: uint64_t fIterations = 0; uint64_t fCounter = 0; }; void addCustomOptions(bpo::options_description& options) { options.add_options()( "iterations,i", bpo::value()->default_value(1000), "Maximum number of iterations of Run/ConditionalRun/OnData (0 - infinite)"); } std::unique_ptr getDevice(fair::mq::ProgOptions& /*config*/) { return std::make_unique(); }