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

---

Client.h

Go to the documentation of this file.

#ifndef Impala_Core_IDash_Client_h
#define Impala_Core_IDash_Client_h

#include "Basis/ILog.h"
#include "Util/StringParser.h"
#include "Util/ChannelProxy.h"

namespace Impala
{
namespace Core
{
namespace IDash
{


class Client
{
public:

    Client(CString socketName, CString passwordFile)
    {
        int colonPos = socketName.find(":");
        if (colonPos <= 0)
        {
            ILOG_ERROR("Not a valid server address (port number is missing): "
                       << socketName);
            return;
        }
        Init(socketName.substr(0, colonPos),
             atol(socketName.substr(colonPos + 1)), passwordFile);
    }

    Client(CString serverAddress, int port, CString passwordFile)
    {
        Init(serverAddress, port, passwordFile);
    }

    virtual
    ~Client()
    {
        Disconnect();
    }

    bool
    IsConnected()
    {
        return (mChannelProxy && mChannelProxy->ChannelIsValid());
    }

    String
    ScheduleJob(CString baseUri, CString job)
    {
        if (!IsConnected())
            return "ERROR: 500: Not connected to IDash server";

        String request = "ScheduleJob:baseUri=" + baseUri + ";job=" + job;
        String response = mChannelProxy->Send(request);
        if (response.substr(0, 19) == "JobAccepted:jobRef=")
        {
            String res = response.substr(19);
            return res;
        }
        ILOG_ERROR("ScheduleJob failed: " << response);
            
        return response;
    }

    String
    GetJobs(CString baseUri)
    {
        if (!IsConnected())
            return "ERROR: 500: Not connected";

        String request = "GetJobs:baseUri=" + baseUri + ";";
        String response = mChannelProxy->Send(request);
        if (response.substr(0, 5) == "Jobs:")
        {
            String res = response.substr(5);
            return res;
        }
        ILOG_ERROR("GetJobs failed: " << response);
            
        return response;
    }

    String
    StatusJob(CString baseUri, CString jobId)
    {
        if (!IsConnected())
            return "ERROR: 500: Not connected";

        String request = "StatusJob:job=" + jobId + ";";
        String response = mChannelProxy->Send(request);
        if (response.substr(0, 14) == "JobStatus:job=")
        {
            String res = response.substr(14);
            return res;
        }
        ILOG_ERROR("StatusJob failed: " << response);
            
        return response;
    }

    String
    DeleteCases()
    {
        if (!IsConnected())
            return "ERROR: 500: Not connected";

        String response = mChannelProxy->Send("DeleteCases");
        return response;
    }

private:

    void
    Init(CString serverAddress, int port, CString passwordFile)
    {
        mServerAddress = serverAddress;
        mPort = port;
        mPasswordFile = passwordFile;

        mChannelProxy = 0;

        if (! Connect(mServerAddress, mPort, mPasswordFile))
        {
            ILOG_ERROR("Cannot connect to IDash server at " << mServerAddress
                       << ':' << mPort);
        }
    }

    bool
    Connect(CString serverAddress, int port, CString passwordFile)
    {
        ILOG_INFO("");
        ILOG_INFO("");
        ILOG_INFO("");
        ILOG_INFO("Connecting");
        mChannelProxy = new Util::ChannelProxy(serverAddress, port,
                                               passwordFile);
        if (!mChannelProxy->GetChannel())
        {
            ILOG_ERROR("Failed to connect to idash server");
            Disconnect();
            return false;
        }

        return true;
    }

    void
    Disconnect()
    {
        ILOG_INFO("Disconnecting");
        if (mChannelProxy)
        {
            //mChannelProxy->CloseChannel();
            delete mChannelProxy;
            mChannelProxy = 0;
        }
    }

    ILOG_VAR_DECL;

    String mServerAddress;
    int    mPort;
    String mPasswordFile;

    Util::ChannelProxy* mChannelProxy;

};

ILOG_VAR_INIT(Client, Impala.Core.IDash);

} // namespace 
} // namespace 
} // namespace 

#endif

---