/********************************************************************************
 *    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"                       *
 ********************************************************************************/
/**
 * Sampler.cpp
 *
 * @since 2014-10-10
 * @author A. Rybalchenko
 */

#include <thread> // this_thread::sleep_for
#include <chrono>

#include "Sampler.h"

using namespace std;

namespace example_dds
{

Sampler::Sampler()
{
}

void Sampler::InitTask()
{
    fIterations = fConfig->GetValue<uint64_t>("iterations");
    fCounter = 0;
}

bool Sampler::ConditionalRun()
{
    std::this_thread::sleep_for(std::chrono::seconds(1));

    // 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;
}

Sampler::~Sampler()
{
}

}