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

---

mainJobRunner.cpp

Go to the documentation of this file.

#include "Basis/String.h"
#include "Basis/CmdOptions.h"
#include "Job/Runner.h"

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

namespace Impala
{
namespace Application
{

int 
mainJobRunner(int argc, char* argv[])
{
    CmdOptions& options = CmdOptions::GetInstance();
    options.Initialise(false, false, true);
    String usageStr = "jobServerAddress \n\n";
    options.AddOption(0, "maxJobs", "nr", "0");
    options.AddOption(0, "maxIdle", "sec", "0");
    options.AddOption(0, "maxJobTime", "min", "0");
    options.AddOption(0, "sleepIntervalSec", "sec", "10");
    options.AddOption(0, "poisonServer", "", "0");
    options.AddOption(0, "stopServer", "", "0");
    options.AddOption(0, "cmdLineExtension", "string", "");
    if (! options.ParseArgs(argc, argv, usageStr, 1))
        return 1;

    ILOG_VAR(Impala.Application.mainJobRunner);

    String serverAddr = options.GetArg(0);
    //int port = atol(options.GetArg(1));
    int colonPos = serverAddr.find(":");
    if (colonPos <= 0)
    {
        ILOG_ERROR("Not a valid server address (port number is missing): " <<
                   serverAddr);
        return 2;
    }
    int port = atol(serverAddr.substr(colonPos + 1));
    serverAddr = serverAddr.substr(0, colonPos);
    //int verbose = options.GetInt("verb");
    int maxJobs = options.GetInt("maxJobs");
    int maxIdleTimeSec = options.GetInt("maxIdle");
    int maxJobTime = options.GetInt("maxJobTime");
    int sleepIntervalSec = options.GetInt("sleepIntervalSec");
    String passwordFile = options.GetString("passwordFile");
    String cmdLineExtension = options.GetString("cmdLineExtension");

    bool poisonServer = options.GetBool("poisonServer");
    bool stopServer = options.GetBool("stopServer");

    // main code for JobRunner application
    Job::Runner jobRunner;
    if (jobRunner.Connect(serverAddr, port, passwordFile))
    {
        if (stopServer)
            jobRunner.StopServer();
        else if (poisonServer)
            jobRunner.PoisonServer();
        else
        {
            jobRunner.RunJobs(maxJobs, maxIdleTimeSec, maxJobTime,
                              sleepIntervalSec, cmdLineExtension);
            jobRunner.Disconnect();
        }
    }

    const std::list<String>& jobsDone = jobRunner.GetJobList();
    //std::list<String>::iterator iter = jobsDone.begin();
    //while (iter != jobsDone.end())
    //{
    //    ILOG_INFO(*iter);
    //    iter++;
    //}
    int jobCount = jobsDone.size();
    ILOG_INFO("Jobs run: " << jobCount);
}

} // namespace 
} // namespace 

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

---