|| || || || || || || ||

---

mainDataClient.cpp

Go to the documentation of this file.

#include <iomanip>

#include "Basis/CmdOptions.h"
#include "Util/Channel.h"
#include "Util/ChannelPool.h"
#include "Basis/Timer.h"
#include "Core/Geometry/PointZList.h"
#include "Core/Array/Arrays.h"
#include "Core/Array/RGB2Intensity.h"
#include "Core/Array/GetRgbPixels.h"
#include "Core/Array/GaussDerivative.h"
#include "Core/Array/WriteRaw.h"
#include "Core/Array/ProjectRange.h"
#include "Core/Array/GaussDerivative.h"
#include "Core/Array/Trait/BpoEqual.h"
#include "Core/Array/Harris.h"
#include "Core/Array/InvCompDer.h"
#include "Core/Array/Dilation.h"
#include "Core/Array/Set.h"
#include "Core/Matrix/MatSet.h"
#include "Core/Stream/RgbDataSrcFactory.h"

// since we are not using libraries:
#include "Link/ImpalaLib.cpp"

namespace Impala
{
namespace Application
{
namespace Client
{


using namespace Impala::Core::Array;
using namespace Impala::Core::Stream;

int         gNrIter;

void
ExampleReadRaw(Util::Channel* chanP)
{
    ILOG_VAR(Impala.Application.Client.ExampleReadRaw);
    CmdOptions& options = CmdOptions::GetInstance();

    Util::Channel& chan = *chanP;
    char* buf = chan.Buffer();
    int len;

    // ask server to read a raw image
    ILOG_DEBUG("requesting readraw");
    String fileName = "trui.raw";
    if (options.GetNrArg() > 2)
        fileName = options.GetArg(2);
    Array2dVec3UInt8* src = 0;
    Util::IOBuffer* ioBuf = ReadIOBufferFromChannel(chanP, fileName, "");
    ReadRaw(src, ioBuf);
    delete ioBuf;
    Array2dVec3Real64* srcV3R64 = 0;
    Set(srcV3R64, src);

    // do some processing
    Array2dScalarReal64* srcSR64 = 0;
    RGB2Intensity(srcSR64, srcV3R64);

    // ask server to open a ImageDataDst
    ILOG_DEBUG("requesting opendst");
    int width = src->CW();
    int height = src->CH();
    sprintf(buf, "opendst %d %d\0", width, height);
    len = chan.SendRequest(strlen(buf)+1);

    // prepare display data and ask server to show it
    ILOG_DEBUG("requesting show");
    sprintf(buf, "show\0");
    GetRgbPixels(srcSR64, (UInt8*)(buf + 5), "Stretch");
    len = chan.SendRequest(width*height*3 + 5);

    // do some more processing and ask server to show result
    for (int j=1 ; j<gNrIter ; j++)
    {
        for (int i=1 ; i<10 ; i++)
        {
            double sigma = 0.5 * i;
            Array2dScalarReal64* res = 0;
            GaussDerivative(res, srcSR64, sigma, 0, 0, 3.0);
            ILOG_DEBUG("requesting show " << i);
            sprintf(buf, "show\0");
            GetRgbPixels(res, (UInt8*)(buf + 5), "Stretch");
            len = chan.SendRequest(width*height*3 + 5);
        }
    }
}

void
ExampleRgbDataSrc(Util::Channel* chanP)
{
    ILOG_VAR(Impala.Application.Client.ExampleRgbDataSrc);
    CmdOptions& options = CmdOptions::GetInstance();

    Util::Channel& chan = *chanP;
    chan.MaximizeSendRecvBuffer();
    char* buf = chan.Buffer();
    int len;

    // ask server to open an RgbDataSrc
    String fileName = "bike.mpg";
    if (options.GetNrArg() > 2)
        fileName = options.GetArg(2);
    sprintf(buf, "opensrc \"%s\"\0", fileName.c_str());
    len = chan.SendRequest(strlen(buf)+1);
    buf[len] = 0;
    ILOG_INFO("answer : (" << len << " bytes) = [" << buf << "]");
    int width;
    int height;
    sscanf(buf, "%d %d", &width, &height);
    ILOG_INFO("sizes : " << width << " x " << height);

    // ask server to open a ImageDataDst
    sprintf(buf, "opendst %d %d\0", width, height);
    len = chan.SendRequest(strlen(buf)+1);

    Timer theTimer(1);
    for (int i=1 ; i<gNrIter ; i++)
    {
        // ask server for nextFrame of src
        sprintf(buf, "nextframe\0");
        len = chan.SendRequest(strlen(buf)+1);

        // convert data to a Array
        Array2dVec3UInt8* srcWrap =
            ArrayCreate<Array2dVec3UInt8>(width, height, 0, 0, (UInt8*) buf,
                                          true);
        Array2dVec3Real64* srcV3R64 = 0;
        Set(srcV3R64, srcWrap);

        // do some processing
        Array2dScalarReal64* srcSR64 = 0;
        RGB2Intensity(srcSR64, srcV3R64);

        // prepare display data and ask server to show it
        //
        sprintf(buf, "show\0");
        GetRgbPixels(srcSR64, (UInt8*)(buf + 5), "Stretch");
        len = chan.SendRequest(width*height*3 + 5);
        //
        double timeVal = theTimer.SplitTime();
        double fps = (double) i / timeVal;
        double bps = (2.0*i * width*height*3) / (1024.0*1024 * timeVal);
        std::cout << "Did " << i << " frames in " <<  std::setw(8) << std::left 
                  << timeVal << " sec = " << std::setw(8) << fps << " fps and "
                  << std::setw(8) << bps << " Mb/sec" << std::endl;

        delete srcWrap;
        delete srcV3R64;
        delete srcSR64;
    }
}

void
TestBandwidth(Util::Channel* chanP)
{
    ILOG_VAR(Impala.Application.Client.TestBandwidth);
    CmdOptions& options = CmdOptions::GetInstance();

    Util::Channel& chan = *chanP;
    char* buf = chan.Buffer();

    int width = 352;
    if (options.GetNrArg() > 2)
        width = atol(options.GetArg(2));
    int height = 288;
    if (options.GetNrArg() > 3)
        height = atol(options.GetArg(3));
    ILOG_INFO("sizes : " << width << " x " << height);

    bool doWrite = false;
    Timer theTimer(1);
    for (int i=1 ; i<gNrIter ; i++)
    {
        // ask server for data
        ILOG_DEBUG("requesting testdata");
        int nrBytes = width * height * 3;
        sprintf(buf, "testdata %d\0", nrBytes);
        int len = chan.SendRequest(strlen(buf)+1);

        if (doWrite)
        {
            // convert data to a Array
            Array2dVec3UInt8* srcWrap =
                ArrayCreate<Array2dVec3UInt8>(width, height, 0, 0, (UInt8*) buf,
                                              true);
            Array2dVec3Real64* srcV3R64 = 0;
            Set(srcV3R64, srcWrap);

            // do some processing
            Array2dScalarReal64* srcSR64 = 0;
            RGB2Intensity(srcSR64, srcV3R64);

            // write result to disc
            if (i < 5)
                WriteRaw(srcSR64, "res.raw" + MakeString(i),
                         &Util::Database::GetInstance(), false);

            delete srcWrap;
            delete srcV3R64;
            delete srcSR64;
        }
        double timeVal = theTimer.SplitTime();
        double fps = (double) i / timeVal;
        double bps = (1.0*i * width*height*3) / (1024.0*1024 * timeVal);
        std::cout << "Did " << i << " frames in " <<  std::setw(8) << std::left 
                  << timeVal << " sec = " << std::setw(8) << fps << " fps and "
                  << std::setw(8) << bps << " Mb/sec" << std::endl;
    }
}

void
TestMpg(Util::Channel* chanP)
{
    ILOG_VAR(Impala.Application.Client.TestMpg);
    CmdOptions& options = CmdOptions::GetInstance();

    Util::Channel& chan = *chanP;
    char* buf = chan.Buffer();
    int len;

    // open RgbDataSrc
    String fileName = "ANNA4.MPEG";
    if (options.GetNrArg() > 2)
        fileName = options.GetArg(2);
    ILOG_DEBUG("opening src " << fileName);
    RgbDataSrcFactory& factory = RgbDataSrcFactory::Instance();
    RgbDataSrc* theSrc = factory.Construct(fileName, options.GetString("src"));
    int width = theSrc->FrameWidth();
    int height = theSrc->FrameHeight();
    ILOG_INFO("sizes : " << width << " x " << height);

    // ask server to open a ImageDataDst
    ILOG_DEBUG("requesting opendst");
    sprintf(buf, "opendst %d %d\0", width, height);
    len = chan.SendRequest(strlen(buf)+1);

    Timer theTimer(1);
    for (int i=1 ; i<gNrIter ; i++)
    {
        // do nextFrame
        ILOG_DEBUG("doing nextframe");
        theSrc->NextFrame(1);

        // convert data to a Array
        Array2dVec3UInt8* srcWrap =
            ArrayCreate<Array2dVec3UInt8>(width, height, 0, 0,
                                          theSrc->DataPtr(), true);

        // prepare display data and ask server to show it
        sprintf(buf, "show\0");
        GetRgbPixels(srcWrap, (UInt8*)(buf + 5), "Direct");
        len = chan.SendRequest(width*height*3 + 5);

        double timeVal = theTimer.SplitTime();
        double fps = (double) i / timeVal;
        double bps = (1.0*i * width*height*3) / (1024.0*1024 * timeVal);
        std::cout << "Did " << i << " frames in " <<  std::setw(8) << std::left 
                  << timeVal << " sec = " << std::setw(8) << fps << " fps and "
                  << std::setw(8) << bps << " Mb/sec" << std::endl;

        delete srcWrap;
    }
}

int
mainClient(int argc, char* argv[])
{
    CmdOptions& options = CmdOptions::GetInstance();
    options.Initialise(true, false, true);
    options.AddOption(0, "file", "name", "");
    options.AddOption(0, "iter", "number", "1000");
    options.AddOption(0, "skip", "nrFrames", "0");
    String usageStr = "machine:port cmd = \n\n";
    usageStr += "  raw [trui.raw]\n";
    usageStr += "  src [bike.mpg]\n";
    usageStr += "  test [352] [288]\n";
    usageStr += "  mpg [ANNA4.MPEG]\n";
    if (! options.ParseArgs(argc, argv, usageStr, 2))
        return 1;

    ILOG_VAR(Impala.Application.Client.mainClient);

    String server = options.GetArg(0);
    if (server.empty())
    {
        ILOG_ERROR("need dataServer");
        return 1;
    }
    String passwordFile = options.GetString("passwordFile");
    Util::Channel* chanP = Util::ChannelPool::Instance().Get(server,
                                                             passwordFile); 
    if (!chanP || !chanP->Valid())
    {
        ILOG_ERROR("No Channel");
        return 1;
    }

    gNrIter = options.GetInt("iter");

    String cmd = options.GetArg(1);

    if (cmd == "raw")
        ExampleReadRaw(chanP);
    else if (cmd == "src")
        ExampleRgbDataSrc(chanP);
    else if (cmd == "test")
        TestBandwidth(chanP);
    else if (cmd == "mpg")
        TestMpg(chanP);

    return 0;
}

} // namespace Client
} // namespace Application
} // namespace Impala

int
main(int argc, char* argv[])
{
    return Impala::Application::Client::mainClient(argc, argv);
}

---