// disable buggy boost enable_shared_from_this assert code
#define BOOST_DISABLE_ASSERTS

#include <stdlib.h>
#include <time.h>
#include <vector>
#include <map>
#include <math.h>

#include <epicsExit.h>
#include <epicsUnitTest.h>
#include <testMain.h>

#include <pv/logger.h>
#include <pv/pvAccess.h>
#include <pv/serverContext.h>
#include <pv/clientFactory.h>
#include <pv/clientContextImpl.h>
#include <pv/standardPVField.h>
#include <pv/pvTimeStamp.h>

#include <pv/current_function.h>

#include "channelAccessIFTest.h"

//#define ENABLE_STRESS_TESTS
#define TESTSERVERNOMAIN

#include "testServer.cpp"

namespace TR1 = std::tr1;


// int value, 1Hz increment by one
std::string ChannelAccessIFTest::TEST_COUNTER_CHANNEL_NAME = "testCounter";
// int value, increment on process
std::string ChannelAccessIFTest::TEST_SIMPLECOUNTER_CHANNEL_NAME = "testSimpleCounter";
// double value, NTScalar
std::string ChannelAccessIFTest::TEST_CHANNEL_NAME = "testValue";
// double value
std::string ChannelAccessIFTest::TEST_VALUEONLY_CHANNEL_NAME = "testValueOnly";
// RPC sum service: int a + int b -> int c
std::string ChannelAccessIFTest::TEST_SUMRPC_CHANNEL_NAME = "testSum";
// double[] value
std::string ChannelAccessIFTest::TEST_ARRAY_CHANNEL_NAME = "testArray1";

#ifdef ENABLE_STRESS_TESTS
#define EXTRA_STRESS_TESTS 5
#else
#define EXTRA_STRESS_TESTS 0
#endif

namespace {
struct ScopedClientFactory {
    ScopedClientFactory() {
        ClientFactory::start();
    }
    ~ScopedClientFactory() {
        ClientFactory::stop();
    }
};
}

int ChannelAccessIFTest::runAllTest() {

    testPlan(152+EXTRA_STRESS_TESTS);

    epics::pvAccess::Configuration::shared_pointer base_config(ConfigurationBuilder()
            //.add("EPICS_PVA_DEBUG", "3")
            .add("EPICS_PVAS_INTF_ADDR_LIST", "127.0.0.1")
            .add("EPICS_PVA_ADDR_LIST", "127.0.0.1")
            .add("EPICS_PVA_AUTO_ADDR_LIST","0")
            .add("EPICS_PVA_SERVER_PORT", "0")
            .add("EPICS_PVA_BROADCAST_PORT", "0")
            .push_map()
            .build());

    TestServer::shared_pointer tstserv(new TestServer(base_config));
    tstserv->start();
    testDiag("TestServer on ports TCP=%u UDP=%u\n",
             tstserv->getServerPort(),
             tstserv->getBroadcastPort());
    ConfigurationFactory::registerConfiguration("pvAccess-client",
            ConfigurationBuilder()
            .push_config(base_config)
            .add("EPICS_PVA_BROADCAST_PORT", tstserv->getBroadcastPort())
            .push_map()
            .build());
    ScopedClientFactory SCF;

    test_implementation();
    test_providerName();

    test_createEmptyChannel();
    test_createChannelWithInvalidPriority();
    test_createChannel();
    test_findEmptyChannel();
    test_findChannel();
    test_channel();

    test_channelGetWithInvalidChannelAndRequester();
    test_channelGetNoProcess();
    test_channelGetIntProcess();
    test_channelGetTestNoConnection();
    test_channelGetNotYetConnected();

    test_channelPutWithInvalidChannelAndRequester();
    test_channelPutNoProcess();
    test_channelPutIntProcess();
    test_channelPutTestNoConnection();
    test_channelPutNotYetConnected();

    test_channelGetFieldAll();
    test_channelGetFieldValue();
    test_channelGetFieldInvalid();

    test_channelProcesstWithInvalidRequesterAndRequest();
    test_channelProcess();
    test_channelProcessNoConnection();

    test_channelPutGetWithInvalidRequesterAndRequest();
    test_channelPutGetNoProcess_putGet();
    test_channelPutGetNoProcess_getPut();
    test_channelPutGetNoProcess_getGet();
    test_channelPutGetNoProcess_destroy();
    test_channelPutGetIntProcess();

    test_channelRPC();
    test_channelRPC_destroy();
    test_channelRPCWithInvalidRequesterAndRequest();

    test_channelMonitorWithInvalidRequesterAndRequest();
    test_channelMonitor(1);

    test_channelArray();
    test_channelArray_destroy();
    test_channelArrayTestNoConnection();

#ifdef ENABLE_STRESS_TESTS
    test_stressPutAndGetLargeArray();
    test_stressConnectDisconnect();
    test_stressConnectGetDisconnect();
    test_stressMonitorAndProcess();
#endif

    test_recreateChannelOnDestroyedProvider();

    return testDone();
}


Channel::shared_pointer ChannelAccessIFTest::createChannel(string channelName, bool debug )
{

    TR1::shared_ptr<SyncChannelRequesterImpl> channelReq(new SyncChannelRequesterImpl(debug));
    Channel::shared_pointer channel = getChannelProvider()->createChannel(channelName, channelReq);
    return channel;
}


Channel::shared_pointer ChannelAccessIFTest::syncCreateChannel(string channelName, bool debug )
{

    TR1::shared_ptr<SyncChannelRequesterImpl> channelReq(new SyncChannelRequesterImpl(debug));
    Channel::shared_pointer channel = getChannelProvider()->createChannel(channelName, channelReq);
    bool isConnected = channelReq->waitUntilStateChange(getTimeoutSec());
    if (!isConnected) {
        std::cerr << "[" << channelName << "] failed to connect to the channel. " << std::endl;
        return TR1::shared_ptr<Channel>();
    }

    return channel;
}


SyncChannelGetRequesterImpl::shared_pointer ChannelAccessIFTest::syncCreateChannelGet(
    Channel::shared_pointer const & channel, string const & request, bool debug )
{

    TR1::shared_ptr<SyncChannelGetRequesterImpl>
    channelGetReq(new SyncChannelGetRequesterImpl(channel->getChannelName(), debug));

    PVStructure::shared_pointer pvRequest = CreateRequest::create()->createRequest(request);

    channel->createChannelGet(channelGetReq,pvRequest);
    bool succStatus = channelGetReq->waitUntilGetDone(getTimeoutSec());
    if (!succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] failed to get. " << std::endl;
        return TR1::shared_ptr<SyncChannelGetRequesterImpl>();
    }
    return channelGetReq;
}


SyncChannelPutRequesterImpl::shared_pointer ChannelAccessIFTest::syncCreateChannelPut(
    Channel::shared_pointer const & channel, string const & request, bool debug )
{

    TR1::shared_ptr<SyncChannelPutRequesterImpl>
    channelPutReq(new SyncChannelPutRequesterImpl(channel->getChannelName(), debug));


    PVStructure::shared_pointer pvRequest = CreateRequest::create()->createRequest(request);

    channel->createChannelPut(channelPutReq,pvRequest);
    bool succStatus = channelPutReq->waitUntilConnected(getTimeoutSec());

    if (!succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] failed to create a put channel. " << std::endl;
        return TR1::shared_ptr<SyncChannelPutRequesterImpl>();
    }
    return channelPutReq;
}


SyncChannelPutGetRequesterImpl::shared_pointer ChannelAccessIFTest::syncCreateChannelPutGet(
    Channel::shared_pointer const & channel, string const & request, bool debug )
{

    TR1::shared_ptr<SyncChannelPutGetRequesterImpl>
    channelPutGetReq(new SyncChannelPutGetRequesterImpl(debug));

    PVStructure::shared_pointer pvRequest = CreateRequest::create()->createRequest(request);

    channel->createChannelPutGet(channelPutGetReq,pvRequest);
    bool succStatus = channelPutGetReq->waitUntilConnected(getTimeoutSec());

    if (!succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] failed to create a put get channel. " << std::endl;
        return TR1::shared_ptr<SyncChannelPutGetRequesterImpl>();
    }
    return channelPutGetReq;
}


SyncChannelRPCRequesterImpl::shared_pointer ChannelAccessIFTest::syncCreateChannelRPC(
    Channel::shared_pointer const & channel, bool debug )
{

    TR1::shared_ptr<SyncChannelRPCRequesterImpl>
    channelRPCReq(new SyncChannelRPCRequesterImpl(debug));

    PVStructure::shared_pointer pvRequest = CreateRequest::create()->createRequest(string());

    channel->createChannelRPC(channelRPCReq, pvRequest);
    bool succStatus = channelRPCReq->waitUntilConnected(getTimeoutSec());

    if (!succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] failed to create a RPC channel. " << std::endl;
        return TR1::shared_ptr<SyncChannelRPCRequesterImpl>();
    }
    return channelRPCReq;
}


SyncMonitorRequesterImpl::shared_pointer ChannelAccessIFTest::syncCreateChannelMonitor(
    Channel::shared_pointer const & channel, string const & request, bool debug )
{
    TR1::shared_ptr<SyncMonitorRequesterImpl> monitorReq(new SyncMonitorRequesterImpl(debug));

    PVStructure::shared_pointer pvRequest = CreateRequest::create()->createRequest(request);

    channel->createMonitor(monitorReq, pvRequest);
    bool succStatus = monitorReq->waitUntilConnected(getTimeoutSec());

    if (!succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] failed to create a monitor channel. " << std::endl;
        return TR1::shared_ptr<SyncMonitorRequesterImpl>();
    }
    return monitorReq;
}


SyncChannelArrayRequesterImpl::shared_pointer ChannelAccessIFTest::syncCreateChannelArray(
    Channel::shared_pointer const & channel, PVStructure::shared_pointer pvRequest, bool debug )
{
    TR1::shared_ptr<SyncChannelArrayRequesterImpl> arrayReq(new SyncChannelArrayRequesterImpl(debug));

    channel->createChannelArray(arrayReq, pvRequest);
    bool succStatus = arrayReq->waitUntilConnected(getTimeoutSec());

    if (!succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] failed to create an array channel. " << std::endl;
        return TR1::shared_ptr<SyncChannelArrayRequesterImpl>();
    }
    return arrayReq;
}


void ChannelAccessIFTest::test_implementation() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    testOk(getChannelProvider().get() != 0, "%s: channel provider is provided", CURRENT_FUNCTION );
    ChannelProvider::shared_pointer cp1 = getChannelProvider();
    ChannelProvider::shared_pointer cp2 = getChannelProvider();
    testOk(cp1 == cp2, "%s: calling getChannelProvider twice", CURRENT_FUNCTION);
    testOk(getTimeoutSec() > 0, "%s: timeout is set", CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_providerName() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    testOk(!getChannelProvider()->getProviderName().empty(), "%s: provider name is set", CURRENT_FUNCTION);
    testOk(getChannelProvider()->getProviderName()== getChannelProvider()->getProviderName(),
           "%s: calling getProviderName twice should return the same provider", CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_createEmptyChannel() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    TR1::shared_ptr<SyncChannelRequesterImpl> channelReq(new SyncChannelRequesterImpl());

    try {
        Channel::shared_pointer channel = getChannelProvider()->createChannel(std::string(), channelReq);
        testFail("%s: empty channel name should not be allowed", CURRENT_FUNCTION);
        return;
    } catch(std::runtime_error &) {
    }

    testOk(channelReq->getCreatedCount() == 0,
           "%s: checking for empty channel name", CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_createChannelWithInvalidPriority() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    TR1::shared_ptr<SyncChannelRequesterImpl> channelReq(new SyncChannelRequesterImpl());

    try {
        Channel::shared_pointer channel = getChannelProvider()->createChannel(std::string(), channelReq,
                                          ChannelProvider::PRIORITY_MIN - 1 );
        testFail("%s: invalid priority should not be allowed when creating a channel",CURRENT_FUNCTION);
        return;
    } catch(std::runtime_error &) {
    }

    testOk(channelReq->getCreatedCount() == 0,
           "%s: checking for invalid priority when creating a new channel",CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_createChannel() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    TR1::shared_ptr<SyncChannelRequesterImpl> channelReq(new SyncChannelRequesterImpl());
    Channel::shared_pointer channel = getChannelProvider()->createChannel(TEST_COUNTER_CHANNEL_NAME, channelReq);
    bool succStatus = channelReq->waitUntilStateChange(getTimeoutSec());
    if (!succStatus) {
        std::cerr << "[" << TEST_COUNTER_CHANNEL_NAME << "] failed to connect. " << std::endl;
        testFail("%s: could not create a channel", CURRENT_FUNCTION);
        return;
    }

    channel->destroy();
    testOk(channelReq->getStatus().isSuccess(), "%s: create a channel", CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_recreateChannelOnDestroyedProvider() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    if (isLocal()) {
        testOk(true, "%s: recreating channel on destroyed provider", CURRENT_FUNCTION);
        return;
    }

    ChannelProvider::shared_pointer provider = getChannelProvider();
    provider->destroy();

    try {
        test_createChannel();
        testFail("%s: exception expected when creating a channel on destroyed context", CURRENT_FUNCTION);
    } catch(std::runtime_error &) {
    }
}


void ChannelAccessIFTest::test_findEmptyChannel() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    try {
        TR1::shared_ptr<SyncChannelFindRequesterImpl> channelFindReq(new SyncChannelFindRequesterImpl());
        getChannelProvider()->channelFind(std::string(), channelFindReq);
        testFail("%s: empty channel name shoud never be allowed when searching for channels", CURRENT_FUNCTION);
        return;

    } catch(std::runtime_error &) {
    }

    testOk(true, "%s: finding an empty channel", CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_findChannel() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    TR1::shared_ptr<SyncChannelFindRequesterImpl> channelFindReq(new SyncChannelFindRequesterImpl());
    getChannelProvider()->channelFind(TEST_COUNTER_CHANNEL_NAME, channelFindReq);
    bool isFindResult = channelFindReq->waitUntilFindResult(getTimeoutSec());
    if (!isFindResult) {
        std::cerr << "[" << TEST_COUNTER_CHANNEL_NAME << "] failed to connect. " << std::endl;
        testFail("%s: could not find a channel", CURRENT_FUNCTION);
        return;
    }
    testSkip(1, "finding a channel not implemented");
}


void ChannelAccessIFTest::test_channel() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    TR1::shared_ptr<SyncChannelRequesterImpl> channelReq(new SyncChannelRequesterImpl());
    Channel::shared_pointer channel = getChannelProvider()->createChannel(TEST_COUNTER_CHANNEL_NAME, channelReq);
    bool succStatus = channelReq->waitUntilStateChange(getTimeoutSec());
    if (!succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] failed to connect. " << std::endl;
        testFail("%s: could not create a channel", CURRENT_FUNCTION);
        return;
    }

    testOk(channelReq->getCreatedCount() == 1, "%s: channel created count", CURRENT_FUNCTION);
    testOk(channelReq->getStatus().isSuccess(), "%s: succ created a channel", CURRENT_FUNCTION);
    testOk(channelReq->getStateChangeCount() == 1, "%s: channel state change count", CURRENT_FUNCTION);
    testOk(channel->getChannelName() == TEST_COUNTER_CHANNEL_NAME, "%s: channel name match", CURRENT_FUNCTION);
    testOk(channel->getChannelRequester() == channelReq, "%s: channel requesters match", CURRENT_FUNCTION);
    //testOk(channel->getRequesterName() == channelRequesterPtr->getRequesterName(),
    //    " channel requester's name match");
    testSkip(1, "channel requester's name mismatch");
    testOk(channel->getProvider() == getChannelProvider(), "%s: channel provider match", CURRENT_FUNCTION);
    testOk(!channel->getRemoteAddress().empty(), "%s: channel remote address set", CURRENT_FUNCTION);
    testOk(channel->isConnected(), "%s: channel connected ", CURRENT_FUNCTION);
    testOk(channel->getConnectionState() == Channel::CONNECTED ,
           "%s: channel connection state connected ", CURRENT_FUNCTION);

    testDiag("%s: destroying the channel", CURRENT_FUNCTION);
    channel->destroy();

    succStatus = channelReq->waitUntilStateChange(getTimeoutSec());
    if (!succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] failed to register a destroy event " << std::endl;
        testFail("%s: a destroy event was not caught for the testing channel ", CURRENT_FUNCTION);
        return;
    }

    testOk(channelReq->getCreatedCount() == 1,
           "%s: channel created count should be the same on the destroyed channel", CURRENT_FUNCTION);
    testOk(channelReq->getStateChangeCount() == 3,
           "%s: channel state change count should increase on the destroyed channel", CURRENT_FUNCTION);
    testOk(!channel->isConnected(), "%s: channel should not be connected ", CURRENT_FUNCTION);
    testOk(channel->getConnectionState() == Channel::DESTROYED ,
           "%s: channel connection state DESTROYED ", CURRENT_FUNCTION);

    testDiag("%s: destroying the channel yet again", CURRENT_FUNCTION);
    channel->destroy();

    succStatus = channelReq->waitUntilStateChange(getTimeoutSec());
    if (succStatus) {
        std::cerr << "[" << channel->getChannelName() << "] registered a duplicate destroy event " << std::endl;
        testFail("%s: a destroy event was caught for the testing channel that was destroyed twice ",
                 CURRENT_FUNCTION);
        return;
    }

    testOk(channelReq->getCreatedCount() == 1,
           "%s: channel created count should be the same on the yet again destroyed channel", CURRENT_FUNCTION);

    testOk(!channel->isConnected(), "%s: yet again destroyed channel should not be connected ", CURRENT_FUNCTION);
    testOk(channel->getConnectionState() == Channel::DESTROYED ,
           "%s: yet again destroyed channel connection state DESTROYED ", CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_channelGetWithInvalidChannelAndRequester() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    testSkip(1, " creating a channel get with a null channel");
    //SyncChannelGetRequesterImpl::shared_pointer channelGetReq =  synCreateChannelGet(Channel::shared_pointer(),
    //    string("field(timeStamp,value)"));


    testSkip(1, " creating a channel get with an empty request");
    //SyncChannelGetRequesterImpl::shared_pointer channelGetReq =  syncCreateChannelGet(Channel::shared_pointer(),
    //   string());

    channel->destroy();
}


void ChannelAccessIFTest::test_channelGetNoProcess() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "field(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_VALUEONLY_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelGetRequesterImpl::shared_pointer channelGetReq =  syncCreateChannelGet(channel,request);

    if (!channelGetReq.get()) {
        testFail("%s: channel get not created ", CURRENT_FUNCTION);
        return;
    }

    testOk(channelGetReq->getBitSet()->cardinality() == 1, "%s: bitset cardinality", CURRENT_FUNCTION);
    testOk(channelGetReq->getBitSet()->get(0) == true, "%s: bitset get(0)", CURRENT_FUNCTION);

    bool succStatus = channelGetReq->syncGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync get failed ", CURRENT_FUNCTION);
        return;
    }

    testOk(channelGetReq->getBitSet()->cardinality() == 0,
           "%s: bitset cardinality after first sync get", CURRENT_FUNCTION);

    succStatus = channelGetReq->syncGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync get failed ", CURRENT_FUNCTION);
        return;
    }

    testOk(channelGetReq->getBitSet()->cardinality() == 0,
           "%s: bitset cardinality after second sync get", CURRENT_FUNCTION);

    channelGetReq->getChannelGet()->destroy();
    testOk(channelGetReq->syncGet(false, getTimeoutSec()) == false,
           "%s: after the channel get destroy, sync get must fail", CURRENT_FUNCTION);

    channel->destroy();
}


void ChannelAccessIFTest::test_channelGetIntProcess() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_SIMPLECOUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    test_channelGetIntProcessInternal(channel, CURRENT_FUNCTION);

    channel->destroy();
}


void ChannelAccessIFTest::test_channelGetNotYetConnected() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = createChannel(TEST_SIMPLECOUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    test_channelGetIntProcessInternal(channel, CURRENT_FUNCTION);

    channel->destroy();
}


void ChannelAccessIFTest::test_channelGetIntProcessInternal(Channel::shared_pointer channel,
        string const & testMethodName) {

    string request = "record[process=true]field(timeStamp,value)";

    SyncChannelGetRequesterImpl::shared_pointer channelGetReq = syncCreateChannelGet(channel, request);
    if (!channelGetReq.get()) {
        testFail("%s: channel get not created ", testMethodName.c_str());
        return;
    }

    TR1::shared_ptr<PVInt> value = channelGetReq->getPVStructure()->getSubField<PVInt>("value");

    PVTimeStamp pvTimeStamp;

    testOk(pvTimeStamp.attach(channelGetReq->getPVStructure()->getSubField<PVStructure>("timeStamp")),
           "%s: attaching a timestamp", testMethodName.c_str());

    TimeStamp timeStamp;

    bool succStatus = channelGetReq->syncGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync get failed ", testMethodName.c_str());
        return;
    }

    pvTimeStamp.get(timeStamp);

    testOk(channelGetReq->getBitSet()->cardinality() == 1, "%s: bitset cardinality", testMethodName.c_str());
    testOk(channelGetReq->getBitSet()->get(0) == true, "%s: bitset get(0)", testMethodName.c_str());

    int numOfTimes = 3;

    for (int i = 0; i < numOfTimes; i++) {

        int previousValue = value->get();
        TimeStamp previousTimestamp = timeStamp;

        epicsThreadSleep(1.0);

        bool succStatus = channelGetReq->syncGet(false, getTimeoutSec());
        if (!succStatus) {
            testFail("%s: sync get failed ", testMethodName.c_str());
            return;
        }

        pvTimeStamp.get(timeStamp);
        double deltaT = TimeStamp::diff(timeStamp, previousTimestamp);

        testOk((previousValue +1)/*%11*/ == value->get(), "%s: testing the counter value change",
               testMethodName.c_str());
        testOk(deltaT > 0.9 && deltaT < 2.0,
               "%s: timestamp change was %g", testMethodName.c_str(), deltaT);
    }

    channelGetReq->getChannelGet()->destroy();
    testOk(channelGetReq->syncGet(false, getTimeoutSec()) == false,
           "%s: after the channel get destroy, sync get must fail", testMethodName.c_str());

    channel->destroy();
}


void ChannelAccessIFTest::test_channelGetTestNoConnection() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "field(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_COUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelGetRequesterImpl::shared_pointer channelGetReq = syncCreateChannelGet(channel, request);
    if (!channelGetReq.get()) {
        testFail("%s: channel get not created ", CURRENT_FUNCTION);
        return;
    }

    channel->destroy();

    bool succStatus = channelGetReq->syncGet(false, getTimeoutSec());
    if (!succStatus) {
        testOk(true, "%s: get failed on destroy channel ", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: get should fail on destroy channel ", CURRENT_FUNCTION);
    }
}


void ChannelAccessIFTest::test_channelPutWithInvalidChannelAndRequester() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    testSkip(1, " creating a channel put with a null channel: seg fault");
    //SyncChannelPutRequesterImpl::shared_pointer channelPutReq =  syncCreateChannelPut(Channel::shared_pointer(),
    //    string("field(timeStamp,value)"));


    testSkip(1, " creating a channel put with an empty request: seg fault");
    //SyncChannelPutRequesterImpl::shared_pointer channelPutReq1 =  syncCreateChannelPut(channel,
    //   string());

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutNoProcess() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "field(value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelPutRequesterImpl::shared_pointer channelPutReq =  syncCreateChannelPut(channel,request);

    if (!channelPutReq.get()) {
        testFail("%s: channel put not created ", CURRENT_FUNCTION);
        return;
    }

    // first do a get to get pvStrcuture
    bool succStatus = channelPutReq->syncGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync get failed ", CURRENT_FUNCTION);
        return;
    }

    TR1::shared_ptr<PVDouble> value = channelPutReq->getPVStructure()->getSubField<PVDouble>("value");
    if (!value.get()) {
        testFail("%s: getting double value field failed ", CURRENT_FUNCTION);
        return;
    }

    double initVal = 123.0;

    value->put(initVal);
    channelPutReq->getBitSet()->set(value->getFieldOffset());

    /*bool*/ succStatus = channelPutReq->syncPut(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync put failed ", CURRENT_FUNCTION);
        return;
    }

    succStatus = channelPutReq->syncGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync get failed ", CURRENT_FUNCTION);
        return;
    }


    testOk(initVal == value->get(), "%s: initial value matches the get value ", CURRENT_FUNCTION);

    value->put(initVal + 2);
    channelPutReq->getBitSet()->clear();

    succStatus = channelPutReq->syncPut(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: second sync put failed ", CURRENT_FUNCTION);
        return;
    }

    succStatus = channelPutReq->syncGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: second sync get failed ", CURRENT_FUNCTION);
        return;
    }

    if (isLocal()) {
        testOk(initVal+2 == value->get(),
               "%s: value should not change since bitset is not set unless is local ", CURRENT_FUNCTION);
    }
    else {
        testOk(initVal == value->get(), "%s: value should not change since bitset is not set ", CURRENT_FUNCTION);
    }

    value->put(initVal + 1);
    channelPutReq->getBitSet()->set(value->getFieldOffset());

    succStatus = channelPutReq->syncPut(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: third sync put failed ", CURRENT_FUNCTION);
        return;
    }

    succStatus = channelPutReq->syncGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: third sync get failed ", CURRENT_FUNCTION);
        return;
    }

    testOk(initVal+1 == value->get(), "%s: changed value matches the get value ", CURRENT_FUNCTION);

    testDiag("%s: Ok, let's destroy the put channel", CURRENT_FUNCTION);

    succStatus = channelPutReq->syncPut(true, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: destroying sync put failed ", CURRENT_FUNCTION);
        return;
    }

    channelPutReq->getChannelPut()->destroy();

    succStatus = channelPutReq->syncPut(true, getTimeoutSec());
    if (!succStatus) {
        testOk(true, "%s: put on destroyed put channel should not succeed ", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: put on destroyed put channel did succeed ", CURRENT_FUNCTION);
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutIntProcess() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_SIMPLECOUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    test_channelPutIntProcessInternal(channel, CURRENT_FUNCTION);

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutNotYetConnected() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = createChannel(TEST_SIMPLECOUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    test_channelPutIntProcessInternal(channel, CURRENT_FUNCTION);

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutIntProcessInternal(Channel::shared_pointer channel,
        string const & testMethodName) {

    string request = "record[process=true]field(value)";

    SyncChannelPutRequesterImpl::shared_pointer channelPutReq =  syncCreateChannelPut(channel,request);

    if (!channelPutReq.get()) {
        testFail("%s: channel put not created ", testMethodName.c_str());
        return;
    }

    // first do a get to get pvStructure
    bool succStatus = channelPutReq->syncGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync get failed ", testMethodName.c_str());
        return;
    }

    TR1::shared_ptr<PVInt> value = channelPutReq->getPVStructure()->getSubField<PVInt>("value");
    if (!value.get()) {
        testFail("%s: getting int value field failed ", testMethodName.c_str());
        return;
    }

    int initVal = 3;

    value->put(initVal);
    channelPutReq->getBitSet()->set(value->getFieldOffset());

    /*bool*/ succStatus = channelPutReq->syncPut(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync put failed ", testMethodName.c_str());
        return;
    }

    succStatus = channelPutReq->syncGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync get failed ", testMethodName.c_str());
        return;
    }

    testOk(initVal + 1 == value->get(), "%s: value changed +1 due to processing ", testMethodName.c_str());

    value->put(initVal + 3);
    channelPutReq->getBitSet()->clear();

    succStatus = channelPutReq->syncPut(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: second sync put failed ", testMethodName.c_str());
        return;
    }

    succStatus = channelPutReq->syncGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: second sync get failed ", testMethodName.c_str());
        return;
    }

    if (isLocal()) {
        testOk(initVal+4 == value->get(),
               "%s: value changed due to processing unless is local ", testMethodName.c_str());
    }
    else {
        testOk(initVal+2 == value->get(), "%s: value not changed ", testMethodName.c_str());
    }


    testDiag("%s: Ok, let's destroy the put channel", testMethodName.c_str());

    succStatus = channelPutReq->syncPut(true, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: destroying sync put failed ", testMethodName.c_str());
        return;
    }

    channelPutReq->getChannelPut()->destroy();

    succStatus = channelPutReq->syncPut(true, getTimeoutSec());
    if (!succStatus) {
        testOk(true, "%s: put on destroyed put channel should not succeed ", testMethodName.c_str());
    }
    else {
        testFail("%s: put on destroyed put channel did succeed ", testMethodName.c_str());
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutTestNoConnection() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "field(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_COUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelPutRequesterImpl::shared_pointer channelPutReq = syncCreateChannelPut(channel, request);
    if (!channelPutReq.get()) {
        testFail("%s: channel put not created ", CURRENT_FUNCTION);
        return;
    }

    channel->destroy();

    bool succStatus = channelPutReq->syncPut(false, getTimeoutSec());
    if (!succStatus) {
        testOk(true, "%s: put failed on destroy channel ", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: put should fail on destroy channel ", CURRENT_FUNCTION);
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelGetFieldAll() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_COUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    TR1::shared_ptr<SyncGetFieldRequesterImpl>
    channelGetFieldReq(new SyncGetFieldRequesterImpl());

    channel->getField(channelGetFieldReq, string());

    bool succStatus = channelGetFieldReq->waitUntilGetDone(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: get all fields failed ", CURRENT_FUNCTION);
    }
    else {
        testOk(true, "%s: get all fields succeeded ", CURRENT_FUNCTION);
        testOk(channelGetFieldReq->getField()->getType() == structure,
               "%s: field type is structure ", CURRENT_FUNCTION);
    }

    channel->destroy();

}


void ChannelAccessIFTest::test_channelGetFieldValue() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_COUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    TR1::shared_ptr<SyncGetFieldRequesterImpl>
    channelGetFieldReq(new SyncGetFieldRequesterImpl());

    channel->getField(channelGetFieldReq, "value");

    bool succStatus = channelGetFieldReq->waitUntilGetDone(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: get field value failed ", CURRENT_FUNCTION);
    }
    else {
        testOk(true, "%s: get field value succeeded ", CURRENT_FUNCTION);
        testOk(channelGetFieldReq->getField()->getType() == scalar,
               "%s: field type is scalar", CURRENT_FUNCTION);
    }

    channel->destroy();

}


void ChannelAccessIFTest::test_channelGetFieldInvalid() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_COUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    TR1::shared_ptr<SyncGetFieldRequesterImpl>
    channelGetFieldReq(new SyncGetFieldRequesterImpl());

    channel->getField(channelGetFieldReq, "invalid");

    bool succStatus = channelGetFieldReq->waitUntilGetDone(getTimeoutSec());
    if (!succStatus) {
        testOk(true, "%s: get invalid field should not succeed ", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: get invalid field succeded ", CURRENT_FUNCTION);
    }

    channel->destroy();

}


void ChannelAccessIFTest::test_channelProcesstWithInvalidRequesterAndRequest() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    ChannelProcess::shared_pointer channelProcess =
        channel->createChannelProcess(ChannelProcessRequester::shared_pointer(),
                                      epics::pvData::PVStructure::shared_pointer());

    testSkip(1, " creating a channel process get with a null requester/request");
    /*
    if (!channelProcess.get()) {
      testOk(true, "%s: creating channel process with null requester/request should not succeed ", CURRENT_FUNCTION);
    }
    else {
      testFail("%s: creating channel process with null requester/request succeded ", CURRENT_FUNCTION);
    }
    */

    channel->destroy();
}


void ChannelAccessIFTest::test_channelProcess() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "field(value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_SIMPLECOUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelGetRequesterImpl::shared_pointer channelGetReq = syncCreateChannelGet(channel, request);
    if (!channelGetReq.get()) {
        testFail("%s: channel get not created ", CURRENT_FUNCTION);
        return;
    }

    bool succStatus = channelGetReq->syncGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: sync get failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: syncGet the initial state", CURRENT_FUNCTION);
    }

    TR1::shared_ptr<SyncChannelProcessRequesterImpl>
    channelProcessReq(new SyncChannelProcessRequesterImpl());


    ChannelProcess::shared_pointer channelProcess =
        channel->createChannelProcess(channelProcessReq,
                                      epics::pvData::PVStructure::shared_pointer());

    succStatus = channelProcessReq->waitUntilConnected(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: a channel process is not connected ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true,"%s: a process channel with an empty request connected", CURRENT_FUNCTION);
    }


    succStatus = channelGetReq->syncGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: second sync get failed ", CURRENT_FUNCTION);
        return;
    }

    testOk(channelGetReq->getBitSet()->cardinality() == 0, "%s: bitset cardinality is 0", CURRENT_FUNCTION);

    succStatus = channelProcessReq->syncProcess(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncProcess failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: a sync process succeeded", CURRENT_FUNCTION);
    }

    succStatus = channelGetReq->syncGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: third sync get failed ", CURRENT_FUNCTION);
        return;
    }


    testOk(channelGetReq->getBitSet()->cardinality() == 1,
           "%s: bitset cardinality should change after process", CURRENT_FUNCTION);

    testDiag("%s: destroying the process channel", CURRENT_FUNCTION);
    channelProcessReq->getChannelProcess()->destroy();

    succStatus = channelProcessReq->syncProcess(false, getTimeoutSec());
    if (!succStatus) {
        testOk(true, "%s: processing on a destroyed process channel should not succeed", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: processing on a destroyed process channel succeed ", CURRENT_FUNCTION);
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelProcessNoConnection() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "field(value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_COUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelGetRequesterImpl::shared_pointer channelGetReq = syncCreateChannelGet(channel, request);
    if (!channelGetReq.get()) {
        testFail("%s: channel get not created ", CURRENT_FUNCTION);
        return;
    }

    testDiag("%s: destroying the channel", CURRENT_FUNCTION);
    channel->destroy();

    bool succStatus = channelGetReq->syncGet(false, getTimeoutSec());
    if (!succStatus) {
        testOk(true, "%s: processing on a destroyed channel should not succeed", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: processing on a destroyed channel succeed ", CURRENT_FUNCTION);
    }
}


void ChannelAccessIFTest::test_channelPutGetWithInvalidRequesterAndRequest() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    testSkip(1, " creating a channel put get with a null channel");
    //SyncChannelPutGetRequesterImpl::shared_pointer channelPutGetReq =
    //  syncCreateChannelPutGet(Channel::shared_pointer(),request);

    testSkip(1, " creating a channel put get with an empty request");
    //SyncChannelPutGetRequesterImpl::shared_pointer channelPutGetReq1 =
    //syncCreateChannelPutGet(channel,String());

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutGetNoProcess_putGet() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_VALUEONLY_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelPutGetRequesterImpl::shared_pointer channelPutGetReq =
        syncCreateChannelPutGet(channel,request);
    if (!channelPutGetReq.get()) {
        testFail("%s: creating a channel putget failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    bool succStatus = channelPutGetReq->syncGetPut(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetPut failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    succStatus = channelPutGetReq->syncGetGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetGet failed ", CURRENT_FUNCTION);
        return;
    }


    TR1::shared_ptr<PVDouble> putValue = channelPutGetReq->getPVPutStructure()->getSubField<PVDouble>("value");
    if (!putValue.get()) {
        testFail("%s: getting put double value field failed ", CURRENT_FUNCTION);
        return;
    }

    double initVal = 321.0;
    putValue->put(initVal);

    TR1::shared_ptr<PVDouble> getValuePtr = channelPutGetReq->getPVGetStructure()->getSubField<PVDouble>("value");
    if (!getValuePtr.get()) {
        testFail("%s: getting get double value field failed ", CURRENT_FUNCTION);
        return;
    }

    /*bool*/ succStatus = channelPutGetReq->syncPutGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncPutGet failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: a syncPutGet succeeded", CURRENT_FUNCTION);
    }

    testOk(getValuePtr->get() == initVal, "value after syncPutGet should be initVal");

    testDiag("%s: testing putGet", CURRENT_FUNCTION);

    putValue->put(initVal + 1.0);

    succStatus = channelPutGetReq->syncPutGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: second syncPutGet failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: a syncPutGet succeeded", CURRENT_FUNCTION);
    }

    testOk(getValuePtr->get() == initVal + 1.0, "value after syncPutGet should be initVal + 1");

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutGetNoProcess_getPut() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_VALUEONLY_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelPutGetRequesterImpl::shared_pointer channelPutGetReq =
        syncCreateChannelPutGet(channel,request);
    if (!channelPutGetReq.get()) {
        testFail("%s: creating a channel putget failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    bool succStatus = channelPutGetReq->syncGetPut(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetPut failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    succStatus = channelPutGetReq->syncGetGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetGet failed ", CURRENT_FUNCTION);
        return;
    }


    TR1::shared_ptr<PVDouble> putValue = channelPutGetReq->getPVPutStructure()->getSubField<PVDouble>("value");
    if (!putValue.get()) {
        testFail("%s: getting put double value field failed ", CURRENT_FUNCTION);
        return;
    }

    double initVal = 321.0;
    putValue->put(initVal);

    TR1::shared_ptr<PVDouble> getValuePtr = channelPutGetReq->getPVGetStructure()->getSubField<PVDouble>("value");
    if (!getValuePtr.get()) {
        testFail("%s: getting get double value field failed ", CURRENT_FUNCTION);
        return;
    }

    testDiag("%s: first put the initial pvPutStructure into the record", CURRENT_FUNCTION);

    /*bool*/ succStatus = channelPutGetReq->syncPutGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncPutGet failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: a syncPutGet succeeded", CURRENT_FUNCTION);
    }

    testDiag("%s: get the current data from the record and put it into pvPutStructure", CURRENT_FUNCTION);

    succStatus = channelPutGetReq->syncGetPut(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetPut failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: a syncGetPut succeeded", CURRENT_FUNCTION);
    }

    testOk(putValue->get() == initVal, "value after syncGetPut should be initVal");

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutGetNoProcess_getGet() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_VALUEONLY_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelPutGetRequesterImpl::shared_pointer channelPutGetReq =
        syncCreateChannelPutGet(channel,request);
    if (!channelPutGetReq.get()) {
        testFail("%s: creating a channel putget failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    bool succStatus = channelPutGetReq->syncGetPut(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetPut failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    succStatus = channelPutGetReq->syncGetGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetGet failed ", CURRENT_FUNCTION);
        return;
    }


    TR1::shared_ptr<PVDouble> putValue = channelPutGetReq->getPVPutStructure()->getSubField<PVDouble>("value");
    if (!putValue.get()) {
        testFail("%s: getting put double value field failed ", CURRENT_FUNCTION);
        return;
    }

    double initVal = 432.0;
    putValue->put(initVal);

    TR1::shared_ptr<PVDouble> getValuePtr = channelPutGetReq->getPVGetStructure()->getSubField<PVDouble>("value");
    if (!getValuePtr.get()) {
        testFail("%s: getting get double value field failed ", CURRENT_FUNCTION);
        return;
    }

    testDiag("%s: first put the initial pvPutStructure into the record", CURRENT_FUNCTION);

    /*bool*/ succStatus = channelPutGetReq->syncPutGet(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncPutGet failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: a syncPutGet succeeded", CURRENT_FUNCTION);
    }

    testDiag("%s: get the current data from the record and put it into pvGetStructure", CURRENT_FUNCTION);

    succStatus = channelPutGetReq->syncGetGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetGet failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: a syncGetGet succeeded", CURRENT_FUNCTION);
    }

    testOk(getValuePtr->get() == initVal, "value after syncGetGet should be initVal");

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutGetNoProcess_destroy() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_VALUEONLY_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelPutGetRequesterImpl::shared_pointer channelPutGetReq =
        syncCreateChannelPutGet(channel,request);
    if (!channelPutGetReq.get()) {
        testFail("%s: creating a channel putget failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    bool succStatus = channelPutGetReq->syncGetPut(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetPut failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    succStatus = channelPutGetReq->syncGetGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetGet failed ", CURRENT_FUNCTION);
        return;
    }


    /*bool*/ succStatus = channelPutGetReq->syncPutGet(true, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncPutGet failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: syncPutGet succeeded", CURRENT_FUNCTION);
    }

    testDiag("%s: destroying a channel putget", CURRENT_FUNCTION);
    channelPutGetReq->getChannelPutGet()->destroy();


    succStatus = channelPutGetReq->syncPutGet(true, getTimeoutSec());
    if (!succStatus) {
        testOk(true, "%s: syncPutGet on a destroyed channel should not succeed", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: syncPutGet on a destroyed channel succeeded ", CURRENT_FUNCTION);
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelPutGetIntProcess() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "record[process=true]putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_SIMPLECOUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelPutGetRequesterImpl::shared_pointer channelPutGetReq =
        syncCreateChannelPutGet(channel,request);
    if (!channelPutGetReq.get()) {
        testFail("%s: creating a channel putget failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    bool succStatus = channelPutGetReq->syncGetPut(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetPut failed ", CURRENT_FUNCTION);
        return;
    }

    // first get a pvStructure
    succStatus = channelPutGetReq->syncGetGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetGet failed ", CURRENT_FUNCTION);
        return;
    }


    TR1::shared_ptr<PVInt> putValue = channelPutGetReq->getPVPutStructure()->getSubField<PVInt>("value");
    if (!putValue.get()) {
        testFail("%s: getting put int value field failed ", CURRENT_FUNCTION);
        return;
    }

    int initVal = 3;
    putValue->put(initVal);

    TR1::shared_ptr<PVInt> getValuePtr = channelPutGetReq->getPVGetStructure()->getSubField<PVInt>("value");
    if (!getValuePtr.get()) {
        testFail("%s: getting get int value field failed ", CURRENT_FUNCTION);
        return;
    }

    PVTimeStamp pvTimeStamp;

    testOk(pvTimeStamp.attach(channelPutGetReq->getPVGetStructure()->getSubField<PVStructure>("timeStamp")),
           "%s: attaching a timestamp", CURRENT_FUNCTION);

    TimeStamp timeStamp;

    /*bool*/ succStatus = channelPutGetReq->syncGetGet(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: syncGetGet failed ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(true, "%s: a syncGetGet succeeded", CURRENT_FUNCTION);
    }

    pvTimeStamp.get(timeStamp);

    int numOfTimes = 3;

    for (int i = 0; i < numOfTimes; i++) {

        int previousValue = getValuePtr->get();
        TimeStamp previousTimestamp = timeStamp;

        //cout << "previousValue:" << previousValue << " previousTimestampSec:" << previousTimestampSec << endl;
        //cout << "next val:" << ((previousValue +1) % 11) << endl;


        putValue->put((previousValue + 1) /*% 11*/);

        succStatus = channelPutGetReq->syncPutGet(i ==  numOfTimes, getTimeoutSec());
        if (!succStatus) {
            testFail("%s: syncPutGet failed ", CURRENT_FUNCTION);
            return;
        }

        epicsThreadSleep(1.0);

        pvTimeStamp.get(timeStamp);
        double deltaT = TimeStamp::diff(timeStamp, previousTimestamp);

        int testValue = (previousValue +1 + 1) /*% 11*/; //+1 (new value) +1 (process)

        //cout << "Testing1:" << testValue << " == " << getValuePtr->get() << endl;
        //cout << "Testing2:" << timeStamp.getSecondsPastEpoch() << ">" << previousTimestampSec << endl;
        testOk( testValue == getValuePtr->get(), "%s: testing the counter value change",
                CURRENT_FUNCTION);
        testOk(deltaT > 0.9 && deltaT < 2.0,
               "%s: timestamp change is %g", CURRENT_FUNCTION, deltaT);
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelRPC() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "record[process=true]putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_SUMRPC_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelRPCRequesterImpl::shared_pointer channelRPCReq = syncCreateChannelRPC(channel);
    if (!channelRPCReq.get()) {
        testFail("%s: creating a channel rpc failed ", CURRENT_FUNCTION);
        return;
    }

    bool succStatus = channelRPCReq->syncRPC(
                          createSumArgumentStructure(1,2),false, getTimeoutSec());
    if (succStatus) {
        testOk(true, "%s: calling sum rpc service successfull", CURRENT_FUNCTION);
        testOk(channelRPCReq->getLastResponse()->getSubField<PVInt>("c")->get() == 3,
               "%s: rpc service returned correct sum", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: error calling syncRPC ", CURRENT_FUNCTION);
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelRPC_destroy() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "record[process=true]putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_SUMRPC_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelRPCRequesterImpl::shared_pointer channelRPCReq = syncCreateChannelRPC(channel);
    if (!channelRPCReq.get()) {
        testFail("%s: creating a channel rpc failed ", CURRENT_FUNCTION);
        return;
    }

    testDiag("%s: destroying the channel rpc", CURRENT_FUNCTION);
    channelRPCReq->getChannelRPC()->destroy();

    bool succStatus = channelRPCReq->syncRPC(
                          createSumArgumentStructure(1,2),false, getTimeoutSec());
    if (succStatus) {
        testFail("%s: rpc call succeded on a destroyed channel ", CURRENT_FUNCTION);
    }
    else {
        testOk(true, "%s: rpc call should not succeed on a destroyed channel ", CURRENT_FUNCTION);
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelRPCWithInvalidRequesterAndRequest() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "record[process=true]putField(value)getField(timeStamp,value)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_SUMRPC_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    testSkip(1, " creating a channel rpc with a null channel");
    //SyncChannelRPCRequesterImpl::shared_pointer channelRPCReq =
    //syncCreateChannelRPC(Channel::shared_pointer());

    SyncChannelRPCRequesterImpl::shared_pointer channelRPCReq = syncCreateChannelRPC(channel);
    if (!channelRPCReq.get()) {
        testFail("%s: creating a channel rpc failed ", CURRENT_FUNCTION);
        return;
    }


    testSkip(1, " skiping a rpc request with an empty pvArguments");
    //bool succStatus = channelRPCReq->syncRPC(
    //     PVStructure::shared_pointer(), false, getTimeoutSec());
    // if (!succStatus) {
    //   testOk(true, "%s: calling sum rpc service with an empty pvArguments should not succeed", CURRENT_FUNCTION);
    // }
    // else {
    //   testFail("%s: rpc request with an empty pvArguments succeeded ", CURRENT_FUNCTION);
    // }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelMonitorWithInvalidRequesterAndRequest() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "record[queueSize=3]field(timeStamp)";

    Channel::shared_pointer channel = syncCreateChannel(TEST_COUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    testSkip(true, " creating a monitoring channel with a null channel");

    //SyncMonitorRequesterImpl::shared_pointer monitorReq =
    //  syncCreateChannelMonitor(Channel::shared_pointer(), request);


    SyncMonitorRequesterImpl::shared_pointer monitorReq1 =
        syncCreateChannelMonitor(channel, string());
    if (monitorReq1.get()) {
        testOk(true, "%s: a monitor requester with an empty request created  ", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: a monitor requester with an empty request not created ", CURRENT_FUNCTION);
    }

    channel->destroy();
}


void ChannelAccessIFTest::test_channelMonitor(int queueSize) {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);
    ostringstream ostream;
    ostream << queueSize;
    string request = "record[queueSize=";
    request.append(ostream.str());
    request.append("]field(timeStamp,value)");

    Channel::shared_pointer channel = syncCreateChannel(TEST_COUNTER_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncMonitorRequesterImpl::shared_pointer monitorReq =
        syncCreateChannelMonitor(channel,request);
    if (!monitorReq.get()) {
        testFail("%s: creating a channel monitor failed ", CURRENT_FUNCTION);
        return;
    }

    testOk(monitorReq->getMonitorCounter() == 0, "%s: monitoring counter before calling start should be zero",
           CURRENT_FUNCTION);

    monitorReq->getChannelMonitor()->start();

    bool succStatus = monitorReq->waitUntilMonitor(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: no monitoring event happened ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(monitorReq->getMonitorCounter() == 1, "%s: monitor event happened", CURRENT_FUNCTION);
        testOk(monitorReq->getChangedBitSet()->cardinality() == 1, "%s: monitor cardinality is 1", CURRENT_FUNCTION);
        testOk(monitorReq->getChangedBitSet()->get(0) == true, "%s: changeBitSet get(0) is true ", CURRENT_FUNCTION);
    }

    TR1::shared_ptr<PVField> valueField = monitorReq->getPVStructure()->getSubField("value");
    TR1::shared_ptr<PVField> previousValue = getPVDataCreate()->createPVField(valueField->getField());

    std::ostringstream oss;
//oss << *monitorReq->getChangedBitSet() << std::endl;
    oss << *monitorReq->getPVStructure();
    testDiag("%s:\n%s", CURRENT_FUNCTION, oss.str().c_str());

    previousValue->copyUnchecked(*valueField);

    testOk(valueField->equals(*previousValue.get()) == true , "%s: value field equals to a previous value",
           CURRENT_FUNCTION);

    for (int i = 2; i < 5; i++ ) {

        succStatus = monitorReq->waitUntilMonitor(getTimeoutSec());
        if (!succStatus) {
            testFail("%s: no further monitoring event happened ", CURRENT_FUNCTION);
            return;
        }

        testOk(monitorReq->getMonitorCounter() == i, "%s: monitor event happened for i=%d", CURRENT_FUNCTION, i);

        if (queueSize == 1 ) {
            testOk(monitorReq->getChangedBitSet()->cardinality() == 1, "%s: monitor cardinality is 1 (queue size = 1)",
                   CURRENT_FUNCTION);
            testOk(monitorReq->getChangedBitSet()->get(0) == true, "%s: changeBitSet get(0) is true (queue size = 1)",
                   CURRENT_FUNCTION);
        }
        else {
            testOk(monitorReq->getChangedBitSet()->cardinality() == 2, "%s: monitor cardinality is 1 (queue size != 1)",
                   CURRENT_FUNCTION);
            testOk(monitorReq->getChangedBitSet()->get(1) == true, "%s: changeBitSet get(1) is true (queue size != 1)",
                   CURRENT_FUNCTION);
            testOk(monitorReq->getChangedBitSet()->get(4) == true, "%s: changeBitSet get(4) is true (queue size != 1)",
                   CURRENT_FUNCTION);

        }

        valueField = monitorReq->getPVStructure()->getSubField("value");

        std::ostringstream oss;
        oss << "previous value : " << *previousValue << std::endl;
        oss << "current value  : " << *valueField << std::endl;
//oss << "changed        : " << *monitorReq->getChangedBitSet() << std::endl;
        oss << *monitorReq->getPVStructure();
        testDiag("%s:\n%s", CURRENT_FUNCTION, oss.str().c_str());

        testOk(valueField->equals(*previousValue.get()) == false , "%s: value field not equals to a previous value",
               CURRENT_FUNCTION);

        previousValue->copyUnchecked(*valueField);
    }


    monitorReq->getChannelMonitor()->stop();
    epicsThreadSleep(1.0);
    int mc = monitorReq->getMonitorCounter();
    epicsThreadSleep(2.0);
    testOk(mc == monitorReq->getMonitorCounter(), "%s: after monitor stop the counter should not increase",
           CURRENT_FUNCTION);
    channel->destroy();
}


void ChannelAccessIFTest::test_channelArray() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_ARRAY_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelArrayRequesterImpl::shared_pointer arrayReq =
        syncCreateChannelArray(channel, createArrayPvRequest());
    if (!arrayReq.get()) {
        testFail("%s: creating a channel array failed ", CURRENT_FUNCTION);
        return;
    }

    // first get to get pvArray
    bool succStatus = arrayReq->syncGet(false, 0, 0, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncGet failed (0) ", CURRENT_FUNCTION);
        return;
    }

    PVDoubleArrayPtr array = TR1::static_pointer_cast<PVDoubleArray>(arrayReq->getArray());

    /*bool*/ succStatus = arrayReq->syncGet(false, 0, 2, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncGet failed (1) ", CURRENT_FUNCTION);
        return;
    }

    unsigned numOfElements = 5;
    PVDoubleArray::svector newdata;

    //inserting 1.1 2.2 3.3 4.4 5.5
    for (unsigned i = 1 ; i <= numOfElements; i++) {
        double val = i+i*0.1;
        newdata.push_back(val);
    }

    array->replace(freeze(newdata));

    succStatus = arrayReq->syncPut(false, 0, 0, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncPut failed (2) ", CURRENT_FUNCTION);
        return;
    }

    succStatus = arrayReq->syncGet(false, 0, 0, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncGet failed (3) ", CURRENT_FUNCTION);
        return;
    }

    PVDoubleArray::const_svector data(array->view());
    testOk(data.size() == numOfElements, "%s: data array size should be %d",
           CURRENT_FUNCTION, numOfElements);


    //checking 1.1 2.2 3.3 4.4 5.5
    for (unsigned i = 0; i < numOfElements; i++) {
        int ii = i + 1;
        testOk(data[i] == (ii+ii*0.1), "%s: data slot %d should be %f", CURRENT_FUNCTION, i, (ii+ii*0.1));
    }


    succStatus = arrayReq->syncPut(false, 4, data.size(), getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncPut failed (5)", CURRENT_FUNCTION);
        return;
    }

    succStatus = arrayReq->syncGet(false, 3, 3, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncGet failed (6) ", CURRENT_FUNCTION);
        return;
    }


    PVDoubleArrayPtr array1 = TR1::static_pointer_cast<PVDoubleArray>(arrayReq->getArray());
    PVDoubleArray::const_svector data1(array1->view());
    testOk(data1[0] == 4.4 , "%s: 1.check 0: %f", CURRENT_FUNCTION, data1[0]);
    testOk(data1[1] == 1.1 , "%s: 1.check 1: %f", CURRENT_FUNCTION, data1[1]);
    // TODO java put can aut-extend array, C++ implementation does not
    testOk(data1.size() == 2 , "%s: data1.size() == 2", CURRENT_FUNCTION);
    //testOk(data1[2] == 2.2 , "%s: check 2: %f", CURRENT_FUNCTION, data1[2]);


    succStatus = arrayReq->syncSetLength(false, 3, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array setLength failed ", CURRENT_FUNCTION);
        return;
    }

    succStatus = arrayReq->syncGet(false, 0, 0, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncGet failed (7) ", CURRENT_FUNCTION);
        return;
    }

    //checking 1.1 2.2 3.3
    PVDoubleArrayPtr array2 = TR1::static_pointer_cast<PVDoubleArray>(arrayReq->getArray());
    PVDoubleArray::const_svector data2(array2->view());
    testOk(data2.size() == 3, "%s: data size after calling setLength should be 3 ",
           CURRENT_FUNCTION);
    testOk(data2[0] == 1.1 , "%s:  2.check 0: %f", CURRENT_FUNCTION, data2[0]);
    testOk(data2[1] == 2.2 , "%s:  2.check 1: %f", CURRENT_FUNCTION, data2[1]);
    testOk(data2[2] == 3.3,  "%s:  2.check 2: %f", CURRENT_FUNCTION, data2[2]);

    size_t newLength = 2;
    succStatus = arrayReq->syncSetLength(false, newLength, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array setLength failed (2) ", CURRENT_FUNCTION);
        return;
    }

    succStatus = arrayReq->syncGet(false, 0, 0, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncGet failed (8) ", CURRENT_FUNCTION);
        return;
    }

    //checking 1.1 2.2
    PVDoubleArrayPtr array3 = TR1::static_pointer_cast<PVDoubleArray>(arrayReq->getArray());
    PVDoubleArray::const_svector data3(array3->view());
    testOk(data3.size() == newLength,
           "%s: data size after calling setLength should be %lu", CURRENT_FUNCTION, (unsigned long) newLength);
    testOk(data3[0] == 1.1 , "%s: 3.check 0: %f", CURRENT_FUNCTION, data3[0]);
    testOk(data3[1] == 2.2 , "%s: 3.check 1: %f", CURRENT_FUNCTION, data3[1]);


    size_t bigCapacity = 10000;
    succStatus = arrayReq->syncSetLength(false, bigCapacity, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array setLength failed (3) ", CURRENT_FUNCTION);
        return;
    }

    succStatus = arrayReq->syncGet(false, 0, 0, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncGet failed (9) ", CURRENT_FUNCTION);
        return;
    }

    PVDoubleArrayPtr array4 = TR1::static_pointer_cast<PVDoubleArray>(arrayReq->getArray());
    PVDoubleArray::const_svector data4(array4->view());
    testOk(data4.size() == bigCapacity, "%s: data size after calling setLength should be %lu",
           CURRENT_FUNCTION, (unsigned long) bigCapacity);
    testOk(data4[0] == 1.1 , "%s: 4.check 0: %f", CURRENT_FUNCTION, data4[0]);
    testOk(data4[1] == 2.2 , "%s: 4.check 1: %f", CURRENT_FUNCTION, data4[1]);
    /*
    if (data4.size() == bigCapacity) {
      size_t i = newCap;
      for (; i < bigCapacity; i++) {
        if (data4[i] != 0.0) {  // NOTE: floating-point number check, introduce epsilon value
          break;
        }
      }
      if (i == bigCapacity)
        testOk("%s: 4.check: all data 0.0", CURRENT_FUNCTION);
      else
        testFail("%s: 4.check: data at %lu should be 0.0 but was %f", CURRENT_FUNCTION, (unsigned long) i, data4[i]);
    }
    else {
      testFail("%s: will not check the rest of the array if the size is not correct", CURRENT_FUNCTION);
    }
    */

    size_t newLen = bigCapacity/2;
    succStatus = arrayReq->syncSetLength(false, newLen, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array setLength failed (4) ", CURRENT_FUNCTION);
        return;
    }
    succStatus = arrayReq->syncGetLength(false, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array getLength failed", CURRENT_FUNCTION);
        return;
    }
    testOk(arrayReq->getLength() == newLen, "%s: retrieved length should be %lu", CURRENT_FUNCTION, (unsigned long) newLen);


    channel->destroy();
}


void ChannelAccessIFTest::test_channelArrayTestNoConnection() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    Channel::shared_pointer channel = syncCreateChannel(TEST_ARRAY_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }


    SyncChannelArrayRequesterImpl::shared_pointer arrayReq =
        syncCreateChannelArray(channel, createArrayPvRequest());
    if (!arrayReq.get()) {
        testFail("%s: creating a channel array failed ", CURRENT_FUNCTION);
        return;
    }

    testDiag("%s: Ok, let's destroy the channel", CURRENT_FUNCTION);

    channel->destroy();

    bool succStatus = arrayReq->syncGet(false, 1, 2, getTimeoutSec());
    if (succStatus) {
        testFail("%s: an array syncGet should fail after the channel had been destroyed ", CURRENT_FUNCTION);
    }
    else {
        testOk(true, "%s: an array syncGet failed on the destroyed channel", CURRENT_FUNCTION);
    }


    succStatus = arrayReq->syncPut(false, 1, 2, getTimeoutSec());
    if (succStatus) {
        testFail("%s: an array syncPut should fail after the channel had been destroyed ", CURRENT_FUNCTION);
    }
    else {
        testOk(true, "%s: an array syncPut failed on the destroyed channel", CURRENT_FUNCTION);
    }


    succStatus = arrayReq->syncSetLength(false, 1, getTimeoutSec());
    if (succStatus) {
        testFail("%s: an array syncSetLength should fail after the channel had been destroyed ", CURRENT_FUNCTION);
    }
    else {
        testOk(true, "%s: an array syncSetLength failed on the destroyed channel", CURRENT_FUNCTION);
    }


}


void ChannelAccessIFTest::test_channelArray_destroy() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    bool debug = false;

    Channel::shared_pointer channel = syncCreateChannel(TEST_ARRAY_CHANNEL_NAME, debug);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelArrayRequesterImpl::shared_pointer arrayReq =
        syncCreateChannelArray(channel, createArrayPvRequest());
    if (!arrayReq.get()) {
        testFail("%s: creating a channel array failed ", CURRENT_FUNCTION);
        return;
    }

    bool succStatus = arrayReq->syncGet(false, 0, 2, getTimeoutSec());
    if (!succStatus) {
        testFail("%s: an array syncGet failed ", CURRENT_FUNCTION);
        return;
    }

    testDiag("%s: Destroying the channels", CURRENT_FUNCTION);

    channel->destroy();

    arrayReq->getChannelArray()->destroy();

    succStatus = arrayReq->syncGet(false, 0, 2, getTimeoutSec());
    if (!succStatus) {
        testOk(true,"%s: an array sync get should not succeed on a destroyed channel", CURRENT_FUNCTION);
    }
    else {
        testFail("%s: an array syncGet failed ", CURRENT_FUNCTION);
    }

}


void ChannelAccessIFTest::test_stressPutAndGetLargeArray() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "field(value)";
    size_t minSize = 1;
    size_t step = 25471;
    size_t maxSize = 8*1024*1024;  // 8MB
    bool debug  = false;

    Channel::shared_pointer channel = syncCreateChannel(TEST_ARRAY_CHANNEL_NAME);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncChannelPutRequesterImpl::shared_pointer putReq =
        syncCreateChannelPut(channel, request, debug);
    if (!putReq.get()) {
        testFail("%s: creating a channel put failed ", CURRENT_FUNCTION);
        return;
    }

    bool s = putReq->syncGet(getTimeoutSec());
    if (!s) {
        testFail("%s: sync get failed", CURRENT_FUNCTION);
        return;
    }

    PVDoubleArray::shared_pointer value = putReq->getPVStructure()->getSubField<PVDoubleArray>("value");
    if (!value.get()) {
        testFail("%s: getting double array value field failed ", CURRENT_FUNCTION);
        return;
    }

    PVDoubleArray::svector newdata;

    for (size_t len = minSize; len <= maxSize; len+=step) {

        //testDiag("%s: array size %lu", CURRENT_FUNCTION, (unsigned long) len);

        // prepare data
        newdata.resize(len);
        for (size_t i = 0; i < len; i++)
            newdata[i] = i;

        value->replace(freeze(newdata));
        putReq->getBitSet()->set(value->getFieldOffset());

        bool succStatus = putReq->syncPut(false, getTimeoutSec());
        if (!succStatus) {
            testFail("%s: sync put failed at array size %lu", CURRENT_FUNCTION, (unsigned long) len);
            return;
        }

        succStatus = putReq->syncGet(getTimeoutSec());
        if (!succStatus) {
            testFail("%s: sync get failed at array size %lu", CURRENT_FUNCTION, (unsigned long) len);
            return;
        }

        // length check
        if (value->getLength() != len) {
            testFail("%s: length does not match %lu != %lu", CURRENT_FUNCTION, (unsigned long) len, (unsigned long) value->getLength());
            return;
        }

        // value check
        PVDoubleArray::const_svector data(value->view());
        for (size_t i = 0; i < len; i++) {
            if (i != data[i])        // NOTE: floating-point value comparison without delta
                testFail("%s: data slot %lu does not match %f != %f at array size %lu", CURRENT_FUNCTION, (unsigned long) i, (double)i, data[i], (unsigned long) len);
        }

    }

    channel->destroy();

    testOk(true, "%s: stress test put-and-get large array successfull", CURRENT_FUNCTION);


}



void ChannelAccessIFTest::test_stressConnectDisconnect() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    int count = 300;
    bool debug = false;

    testDiag("%s: stress test connect-disconnect %d times", CURRENT_FUNCTION, count);

    for (int i = 0; i < count; i++) {
        Channel::shared_pointer channel = syncCreateChannel(TEST_VALUEONLY_CHANNEL_NAME, debug);
        if (!channel.get()) {
            testFail("%s: channel not created (%d) ", CURRENT_FUNCTION, i);
            return;
        }
        channel->destroy();
    }

    testOk(true, "%s: stress test connect-disconnect successfull", CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_stressConnectGetDisconnect() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "field(value)";
    int count = 300;
    bool debug  = false;


    testDiag("%s: stress testing connect-get-disconnect %d times", CURRENT_FUNCTION, count);

    for (int i = 0; i < count; i++) {

        Channel::shared_pointer channel = syncCreateChannel(TEST_VALUEONLY_CHANNEL_NAME, debug);
        if (!channel.get()) {
            testFail("%s: channel not created (%d) ", CURRENT_FUNCTION, i);
            return;
        }


        SyncChannelGetRequesterImpl::shared_pointer channelGetReq = syncCreateChannelGet(channel, request, debug);
        if (!channelGetReq.get()) {
            testFail("%s: channel get not created (%d) ", CURRENT_FUNCTION, i);
            return;
        }

        bool succStatus = channelGetReq->syncGet(true, getTimeoutSec());
        if (!succStatus) {
            testFail("%s: sync get failed (%d) ", CURRENT_FUNCTION, i);
            return;
        }

        channel->destroy();
    }

    testOk(true, "%s: stress test connect-disconnect successfull", CURRENT_FUNCTION);
}


void ChannelAccessIFTest::test_stressMonitorAndProcess() {

    testDiag("BEGIN TEST %s:", CURRENT_FUNCTION);

    string request = "record[queueSize=3]field(timeStamp,value,alarm.severity.choices)";
    bool debug = false;

    Channel::shared_pointer channel = syncCreateChannel(TEST_SIMPLECOUNTER_CHANNEL_NAME, debug);
    if (!channel.get()) {
        testFail("%s: channel not created ", CURRENT_FUNCTION);
        return;
    }

    SyncMonitorRequesterImpl::shared_pointer monitorReq =
        syncCreateChannelMonitor(channel, request, debug);
    if (!monitorReq.get()) {
        testFail("%s: creating a channel monitor failed ", CURRENT_FUNCTION);
        return;
    }

    testOk(monitorReq->getMonitorCounter() == 0, "%s: monitoring counter before calling start should be zero",
           CURRENT_FUNCTION);


    TR1::shared_ptr<SyncChannelProcessRequesterImpl>
    channelProcessReq(new SyncChannelProcessRequesterImpl(debug));

    ChannelProcess::shared_pointer channelProcess =
        channel->createChannelProcess(channelProcessReq,
                                      epics::pvData::PVStructure::shared_pointer());

    bool succStatus = channelProcessReq->waitUntilConnected(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: a channel process is not connected ", CURRENT_FUNCTION);
        return;
    }


    monitorReq->getChannelMonitor()->start();

    succStatus = monitorReq->waitUntilMonitor(getTimeoutSec());
    if (!succStatus) {
        testFail("%s: no monitoring event happened ", CURRENT_FUNCTION);
        return;
    }
    else {
        testOk(monitorReq->getMonitorCounter() == 1, "%s: monitor event happened", CURRENT_FUNCTION);
    }

    int count = 50000;

    testDiag("%s: stress testing monitor-process %d times", CURRENT_FUNCTION, count);

    for (int i = 2; i < count; i++ ) {

        succStatus = channelProcessReq->syncProcess(false, getTimeoutSec());
        if (!succStatus) {
            testFail("%s: syncProcess failed (%d) ", CURRENT_FUNCTION, i);
            return;
        }

        monitorReq->waitUntilMonitor(i, getTimeoutSec());

        int counter = monitorReq->getMonitorCounter();

        if (counter != i ) {
            testFail("%s: monitor counter != i. monitorCounter: %d, i:%d", CURRENT_FUNCTION, counter, i);
            return;
        }
    }

    testOk(true, "%s: stress testing monitor-process successfull", CURRENT_FUNCTION);
}


PVStructure::shared_pointer ChannelAccessIFTest::createSumArgumentStructure(int a, int b) {

    int i = 0;
    StringArray fieldNames(2);
    FieldConstPtrArray fields(2);
    fieldNames[i] = "a";
    fields[i++] = getFieldCreate()->createScalar(pvInt);
    fieldNames[i] = "b";
    fields[i++] = getFieldCreate()->createScalar(pvInt);

    PVStructure::shared_pointer pvArguments(
        getPVDataCreate()->createPVStructure(
            getFieldCreate()->createStructure(fieldNames, fields)));

    pvArguments->getSubField<PVInt>("a")->put(a);
    pvArguments->getSubField<PVInt>("b")->put(b);

    return pvArguments;

}


PVStructure::shared_pointer ChannelAccessIFTest::createArrayPvRequest() {

    StringArray fieldNames;
    fieldNames.push_back("field");
    FieldConstPtrArray fields;
    fields.push_back(getFieldCreate()->createScalar(pvString));
    PVStructure::shared_pointer pvRequest(getPVDataCreate()->createPVStructure(
            getFieldCreate()->createStructure(fieldNames, fields)));

    PVString::shared_pointer pvFieldName = pvRequest->getSubField<PVString>("field");
    pvFieldName->put("value");
    return pvRequest;
}


class ChannelAccessIFRemoteTest: public ChannelAccessIFTest  {

public:

    virtual ChannelProvider::shared_pointer getChannelProvider() {
        return getChannelProviderRegistry()->getProvider(
                   "pva");
    }


    virtual long getTimeoutSec() {
        return 3;
    }


    virtual bool isLocal() {
        return false;
    }

};

MAIN(testChannelAccess)
{
    SET_LOG_LEVEL(logLevelError);
    ChannelAccessIFRemoteTest caRemoteTest;
    return caRemoteTest.runAllTest();
}