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

---

mainIDashServer.cpp

Go to the documentation of this file.

#include "Core/IDash/VideoSetWrapper.h"
#include "Util/Sleep.h"
#include "Basis/CmdOptions.h"
#include "Util/ChannelPool.h"
#include "Job/Server.h"
#include "Core/VideoJob/ServerProxy.h"
#include "Core/IDash/Server.h"
#include "Core/IDash/XmlJob.h"
#include "Core/IDash/XmlJobReference.h"
#include "Core/IDash/Client.h"
#include "Persistency/AnnotationTableSetRepository.h"

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


namespace Impala
{
namespace Application
{
namespace IDash
{

void
DoProcessAnnotationSet(CString setArg)
{
    ILOG_VAR(Impala.Application.IDash.DoProcessAnnotationSet);
    using namespace Persistency;

    Util::StringParser p(setArg);
    if (p.Contains("keyvalue"))
    {
        ILOG_ERROR("annotationset should not contain keyvalue");
        return;
    }
    p.Eat("keyword=");
    if (p.TheEnd())
    {
        ILOG_ERROR("annotationset should contain keyword");
        return;
    }
    String keyword = p.GetString('&', false);
    Core::Table::KeywordList keyList;
    keyList.push_back(keyword);
    Core::Table::AnnotationTableSet annoSet(keyList, 0);

    Core::IDash::VideoSetWrapper vidSet("idash_annotator.txt");
    Core::IDash::XmlAnnotationSet xmlAnnotationSetT(setArg + "&keyvalue=true");
    if (!xmlAnnotationSetT.Valid())
        return;
    Core::Table::AnnotationTable* tab = annoSet.GetTable(keyword);
    for (int i=0 ; i<xmlAnnotationSetT.GetNrMoments() ; i++)
    {
        Core::IDash::XmlShot xmlShot(xmlAnnotationSetT.GetMoment(i));
        Core::IDash::XmlVideo xmlVideo(xmlShot.GetVideo());
        Quid q = vidSet.Add(xmlVideo, xmlShot.GetShotIndex());
        tab->AddPositive(q);
    }

    Core::IDash::XmlAnnotationSet xmlAnnotationSetF(setArg + "&keyvalue=false");
    if (!xmlAnnotationSetF.Valid())
        return ;
    for (int i=0 ; i<xmlAnnotationSetF.GetNrMoments() ; i++)
    {
        Core::IDash::XmlShot xmlShot(xmlAnnotationSetF.GetMoment(i));
        Core::IDash::XmlVideo xmlVideo(xmlShot.GetVideo());
        Quid q = vidSet.Add(xmlVideo, xmlShot.GetShotIndex());
        tab->AddNegative(q);
    }

    Core::VideoSet::VideoSet* vs = vidSet.GetVideoSet();
    AnnotationTableSetLocator setLoc(vs->GetLocator(), QUID_CLASS_FRAME,
                                     "conceptsAnnotator.txt");
    AnnotationTableSetRepository().Add(setLoc, &annoSet);
}

int
mainIDashServer(int argc, char* argv[])
{
    CmdOptions& options = CmdOptions::GetInstance();
    options.Initialise(false, false, true);
    options.AddOption(0, "noIdle", "", "0");
    String usageStr = "cmd, with cmd = \n\n";
    usageStr += "  jobstatus jobserveraddr jobid\n";
    if (! options.ParseArgs(argc, argv, usageStr, 2))
        return 1;

    ILOG_VAR(Impala.Application.IDash.mainIDashServer);

    String passwordFile = options.GetString("passwordFile");
    String cmd = options.GetArg(0);
    if (cmd == "jobstate")
    {
        String jobServerAddr = options.GetArg(1);
        Core::VideoJob::ServerProxy jobServer(jobServerAddr, passwordFile, 10);
        if (!jobServer.IsConnected())
            return 1;

        int jobId = Impala::atol(options.GetArg(2));
        Job::State::StateType state;
        int exitCode;
        String errorLog;
        jobServer.GetJobState(jobId, state, exitCode, errorLog);
        ILOG_INFO("state = " << Job::State::ToString(state));
    }
    else if (cmd == "schedulejob")
    {
        String jobServerAddr = options.GetArg(1);
        Core::VideoJob::ServerProxy jobServer(jobServerAddr, passwordFile, 10);
        if (!jobServer.IsConnected())
            return 1;

        String cmdLine = options.GetArg(2);
        int res = jobServer.ScheduleJob(cmdLine, 0);
        ILOG_INFO("res = " << res);
        Util::Sleep(100); // need to stay alive a little for job to live on server
    }
    else if (cmd == "serve")
    {
        if (options.GetNrArg() < 4)
        {
            ILOG_ERROR("Need more parameters");
            return 1;
        }
        int port = atol(options.GetArg(1));
        int nrPorts = atol(options.GetArg(2));
        String jobServerAddr = options.GetArg(3);
        Core::IDash::Server server(port, nrPorts, passwordFile, jobServerAddr);
        bool doIdle = ! options.GetBool("noIdle");
        server.Start(doIdle);
    }
    else if (cmd == "processvideo")
    {
        if (options.GetNrArg() < 3)
        {
            ILOG_ERROR("Need more parameters");
            return 1;
        }
        String vidArg = options.GetArg(1);
        Core::IDash::XmlVideo xmlVideo(vidArg);
        if (!xmlVideo.Valid())
            return 1;
        String setArg = options.GetArg(2);
        Core::IDash::XmlQuerySet xmlQuerySet(setArg);
        if (!xmlQuerySet.Valid())
            return 1;
        Core::IDash::VideoSetWrapper vidSet("idash_vds.txt");
        vidSet.Add(xmlVideo, xmlQuerySet);
    }
    else if (cmd == "processqueryset")
    {
        if (options.GetNrArg() < 2)
        {
            ILOG_ERROR("Need more parameters");
            return 1;
        }
        String setArg = options.GetArg(1);
        Core::IDash::XmlQuerySet xmlQuerySet(setArg);
        if (!xmlQuerySet.Valid())
            return 1;
        Core::IDash::VideoSetWrapper vidSet("idash_vds.txt");
        vidSet.Add(xmlQuerySet);
    }
    else if (cmd == "processannotationset")
    {
        if (options.GetNrArg() < 2)
        {
            ILOG_ERROR("Need more parameters");
            return 1;
        }
        String setArg = options.GetArg(1);
        DoProcessAnnotationSet(setArg);
    }
    else if (cmd == "client")
    {
        String idashServerAddr = options.GetArg(1);
        Core::IDash::Client client(idashServerAddr, passwordFile);
        if (!client.IsConnected())
            return 1;

        String jobFileName = options.GetArg(2);

        Util::IOBufferFile srcBuf(jobFileName, true, true);
        char* charBuf = new char[srcBuf.Size()];
        srcBuf.Read(charBuf, srcBuf.Size());
        String job(charBuf, srcBuf.Size());

        ILOG_INFO("Sending [" << job << "], size = " << job.size());
        String ref = client.ScheduleJob("http://myserver:8080/", job);
        ILOG_INFO("ref = [" << ref << "]");
        delete charBuf;
    }
    else
    {
        ILOG_ERROR("Unknown cmd : " << cmd);
    }

    //Util::IOBufferFile srcBuf(jobServerAddr, true, true);
    //Core::IDash::XmlJobReference job(jobServerAddr, &srcBuf);
    //Util::IOBufferFile dstBuf("jobref_out.xml", false, false);
    //job.Export(&dstBuf);

    return ILOG_ERROR_COUNT;
}

} // namespace IDash
} // namespace Application
} // namespace Impala

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

---