#pragma once
#ifndef TFARMCONTROLLER_H
#define TFARMCONTROLLER_H
#include <vector>
using std::vector;
#include "tfarmtask.h"
//#include "texception.h"
#include "tconvert.h"
//#include "tfilepath.h"
class TFilePath;
#ifdef TFARMAPI
#undef TFARMAPI
#endif
#ifdef _WIN32
#ifdef TFARM_EXPORTS
#define TFARMAPI __declspec(dllexport)
#else
#define TFARMAPI __declspec(dllimport)
#endif
#else
#define TFARMAPI
#endif
//------------------------------------------------------------------------------
enum ServerState {
Ready,
Busy,
NotResponding,
Down,
Offline,
ServerUnknown
};
class ServerIdentity
{
public:
ServerIdentity(const QString &id, const QString &name)
: m_id(id), m_name(name) {}
QString m_id;
QString m_name;
};
class ServerInfo
{
public:
QString m_name;
QString m_ipAddress;
QString m_portNumber;
ServerState m_state;
QString m_platform;
int m_cpuCount;
unsigned int m_totPhysMem;
unsigned int m_totVirtMem;
// the following fields can be used just if the server state is not Down
unsigned int m_availPhysMem;
unsigned int m_availVirtMem;
QString m_currentTaskId;
};
//------------------------------------------------------------------------------
class TaskShortInfo
{
public:
TaskShortInfo(const QString &id, const QString &name, TaskState status)
: m_id(id), m_name(name), m_status(status) {}
QString m_id;
QString m_name;
TaskState m_status;
};
//------------------------------------------------------------------------------
class TFARMAPI TFarmController
{
public:
virtual ~TFarmController() {}
virtual QString addTask(const TFarmTask &task, bool suspended) = 0;
virtual void removeTask(const QString &id) = 0;
virtual void suspendTask(const QString &id) = 0;
virtual void activateTask(const QString &id) = 0;
virtual void restartTask(const QString &id) = 0;
virtual void getTasks(vector<QString> &tasks) = 0;
virtual void getTasks(const QString &parentId, vector<QString> &tasks) = 0;
virtual void getTasks(const QString &parentId, vector<TaskShortInfo> &tasks) = 0;
virtual void queryTaskInfo(const QString &id, TFarmTask &task) = 0;
virtual void queryTaskShortInfo(
const QString &id,
QString &parentId,
QString &name,
TaskState &status) = 0;
// used (by a server) to notify a server start
virtual void attachServer(const QString &name, const QString &addr, int port) = 0;
// used (by a server) to notify a server stop
virtual void detachServer(const QString &name, const QString &addr, int port) = 0;
// used by a server to notify a task submission error
virtual void taskSubmissionError(const QString &taskId, int errCode) = 0;
// used by a server to notify a task progress
virtual void taskProgress(
const QString &taskId,
int step,
int stepCount,
int frameNumber,
FrameState state) = 0;
// used by a server to notify a task completion
virtual void taskCompleted(const QString &taskId, int exitCode) = 0;
// fills the servers vector with the identities of the servers
virtual void getServers(vector<ServerIdentity> &servers) = 0;
// returns the state of the server whose id has been specified
virtual ServerState queryServerState2(const QString &id) = 0;
// fills info with the infoes about the server whose id is specified
virtual void queryServerInfo(const QString &id, ServerInfo &info) = 0;
// activates the server whose id has been specified
virtual void activateServer(const QString &id) = 0;
// deactivates the server whose id has been specified
// once deactivated, a server is not available for task rendering
virtual void deactivateServer(const QString &id, bool completeRunningTasks = true) = 0;
};
//------------------------------------------------------------------------------
class TFARMAPI ControllerData
{
public:
ControllerData(const QString &hostName = "", const QString &ipAddr = "", int port = 0)
: m_hostName(hostName), m_ipAddress(ipAddr), m_port(port)
{
}
bool operator==(const ControllerData &rhs)
{
return m_hostName == rhs.m_hostName &&
m_ipAddress == rhs.m_ipAddress &&
m_port == rhs.m_port;
}
QString m_hostName;
QString m_ipAddress;
int m_port;
};
//------------------------------------------------------------------------------
class TFARMAPI TFarmControllerFactory
{
public:
TFarmControllerFactory();
int create(const ControllerData &data, TFarmController **controller);
int create(const QString &hostname, int port, TFarmController **controller);
};
//------------------------------------------------------------------------------
void TFARMAPI loadControllerData(const TFilePath &fp, ControllerData &data);
#endif