#include "tfarmserver.h"
//#include "ttcpip.h"
#include "tfarmproxy.h"
#include "tconvert.h"
namespace
{
//------------------------------------------------------------------------------
class FarmServerProxy : public TFarmServer, public TFarmProxy
{
public:
FarmServerProxy(const QString &hostName, const QString &addr, int port)
: TFarmProxy(hostName, addr, port) {}
// TFarmServer interface implementation
int addTask(const QString &taskid, const QString &cmdline);
int terminateTask(const QString &taskid);
int getTasks(vector<QString> &tasks);
void queryHwInfo(HwInfo &hwInfo);
void attachController(const QString &name, const QString &addr, int port);
void detachController(const QString &name, const QString &addr, int port);
};
//------------------------------------------------------------------------------
int FarmServerProxy::addTask(const QString &taskid, const QString &cmdline)
{
QString data("addTask");
data += ",";
data += taskid;
data += ",";
data += cmdline;
QString reply = sendToStub(data);
if (reply.isEmpty())
return -1;
int rc = reply.toInt();
return rc;
}
//------------------------------------------------------------------------------
int FarmServerProxy::terminateTask(const QString &taskid)
{
QString data("terminateTask");
data += ",";
data += taskid;
QString reply = sendToStub(data);
return 0;
}
//------------------------------------------------------------------------------
int FarmServerProxy::getTasks(vector<QString> &tasks)
{
QString data("getTasks");
QString reply = sendToStub(data);
// la stringa restituita contiene le informazioni desiderate separate da ","
vector<QString> argv;
int count = extractArgs(reply, argv);
assert(count > 0);
int taskCount = argv[0].toInt();
tasks.clear();
std::vector<QString>::iterator it = argv.begin();
std::advance(it, 1);
for (; it != argv.end(); ++it)
tasks.push_back(*it);
return taskCount;
}
//------------------------------------------------------------------------------
void FarmServerProxy::queryHwInfo(HwInfo &hwInfo)
{
QString data("queryHwInfo");
QString reply = sendToStub(data);
// la stringa restituita contiene le informazioni desiderate separate da ","
vector<QString> argv;
extractArgs(reply, argv);
assert(argv.size() > 4);
int cpuCount, totPhysMem, totVirtMem, availPhysMem, availVirtMem;
cpuCount = argv[0].toInt();
totPhysMem = argv[1].toInt();
availPhysMem = argv[2].toInt();
totVirtMem = argv[3].toInt();
availVirtMem = argv[4].toInt();
hwInfo.m_cpuCount = cpuCount;
hwInfo.m_totPhysMem = totPhysMem;
hwInfo.m_totVirtMem = totVirtMem;
hwInfo.m_availPhysMem = availPhysMem;
hwInfo.m_availVirtMem = availVirtMem;
if (argv.size() > 5)
hwInfo.m_type = (TFarmPlatform)argv[5].toInt();
}
//------------------------------------------------------------------------------
void FarmServerProxy::attachController(const QString &name, const QString &addr, int port)
{
QString data("attachController");
data += ",";
data += name;
data += ",";
data += addr;
data += ",";
data += QString::number(port);
sendToStub(data);
}
//------------------------------------------------------------------------------
void FarmServerProxy::detachController(const QString &name, const QString &addr, int port)
{
QString data("detachController");
data += ",";
data += name;
data += ",";
data += addr;
data += ",";
data += QString::number(port);
QString reply = sendToStub(data);
}
} // anonymous namespace
//==============================================================================
TFarmServerFactory::TFarmServerFactory()
{
}
//------------------------------------------------------------------------------
TFarmServerFactory::~TFarmServerFactory()
{
}
//------------------------------------------------------------------------------
int TFarmServerFactory::create(
const QString &hostName, const QString &addr, int port, TFarmServer **tfserver)
{
*tfserver = new FarmServerProxy(hostName, addr, port);
return 0;
}