/*
 * Copyright information and license terms for this software can be
 * found in the file LICENSE that is included with the distribution
 */

/**
 * @author mrk
 * @date 2013.08.09
 */

#define epicsExportSharedSymbols
#include <pv/longArrayPut.h>

namespace epics { namespace exampleCPP { namespace arrayPerformance { 

using namespace std;
using namespace epics::pvData;
using namespace epics::pvAccess;
using namespace epics::pvaClient;



LongArrayPut::LongArrayPut(
    string const &providerName,
    string const & channelName,
    size_t arraySize,
    int iterBetweenCreateChannel,
    int iterBetweenCreateChannelPut,
    double delayTime)
: providerName(providerName),
  channelName(channelName),
  arraySize(arraySize),
  iterBetweenCreateChannel(iterBetweenCreateChannel),
  iterBetweenCreateChannelPut(iterBetweenCreateChannelPut),
  delayTime(delayTime)
{
     thread = std::auto_ptr<epicsThread>(new epicsThread(
        *this,
        "longArrayPut",
        epicsThreadGetStackSize(epicsThreadStackSmall),
        epicsThreadPriorityLow));
     thread->start();
}

void LongArrayPut::stop()
{
    runStop.signal();
    runReturn.wait();
}

void LongArrayPut::run()
{
    PvaClientPtr pva(PvaClient::get("pva"));
    PvaClientChannelPtr pvaChannel(pva->createChannel(channelName,providerName));
    PvaClientPutPtr pvaPut(pvaChannel->createPut("value"));
    TimeStamp timeStamp;
    TimeStamp timeStampLast;
    timeStampLast.getCurrent();
    int numChannelPut = 0;
    int numChannelCreate = 0;
    size_t nElements = 0;
    while(true) {
        if(runStop.tryWait()) {
             runReturn.signal();
             return;
        }
        PvaClientPutDataPtr putData(pvaPut->getData());
        PVStructurePtr pvStructure(putData->getPVStructure());
        BitSetPtr bitSet(putData->getChangedBitSet());
        PVLongArrayPtr pvLongArray(pvStructure->getSubField<PVLongArray>("value"));
        nElements +=  arraySize;
        shared_vector<int64> xxx(arraySize,numChannelPut);
        shared_vector<const int64> data(freeze(xxx));
        pvLongArray->replace(data);
        bitSet->set(pvLongArray->getFieldOffset());
        pvaPut->put();
        timeStamp.getCurrent();
        double diff = TimeStamp::diff(timeStamp,timeStampLast);
        if(diff>=1.0) {
            timeStampLast = timeStamp;
            ostringstream out;
            out << "put " << numChannelPut ;
            double elementsPerSec = nElements;
            elementsPerSec /= diff;
            if(elementsPerSec>1e9) {
                 elementsPerSec /= 1e9;
                 out << " gigaElements/sec " << elementsPerSec;
            } else if(elementsPerSec>1e6) {
                 elementsPerSec /= 1e6;
                 out << " megaElements/sec " << elementsPerSec;
            } else if(elementsPerSec>1e3) {
                 elementsPerSec /= 1e3;
                 out << " kiloElements/sec " << elementsPerSec;
            } else  {
                 out << " Elements/sec " << elementsPerSec;
            }
            if(iterBetweenCreateChannelPut!=0) out << " numChannelPut " << numChannelPut;
            if(iterBetweenCreateChannel!=0) out << " numChannelCreate " << numChannelCreate;
            cout << out.str() << endl;
            nElements = 0;
        }
        if(delayTime>0.0) epicsThreadSleep(delayTime);
        ++numChannelPut;
        bool createPut = false;
        if(iterBetweenCreateChannelPut!=0) {
            if(numChannelPut>=iterBetweenCreateChannelPut) createPut = true;
        }
        if(createPut) {
             pvaPut = pvaChannel->createPut("value");
             numChannelPut = 0;
        }
        ++numChannelCreate;
        if(iterBetweenCreateChannel!=0) {
            if(numChannelCreate>=iterBetweenCreateChannel) {
                pvaChannel = pva->createChannel(channelName,providerName);
                pvaPut = pvaChannel->createPut("value");
                numChannelCreate = 0;
            }
        }
    }
}


}}}