#include <PGQueue.h>
Inheritance diagram for PGQueue:
Public Member Functions | |
PGQueue (string aDbName, string aUser, string aPass, string aHostAddr, string aPort, string aMailServerIp) | |
~PGQueue () | |
PGQueue destructor. | |
list< string > | getInWaitTasks () |
Get all the tasks in wait. | |
list< string > | getTerminatedTasks () |
Get all the tasks terminated. | |
list< string > | getInUseTasks () |
Get all the tasks in use. | |
list< string > | getExpiredTasks () |
Get all the tasks expired. | |
void | changeStateToInWait (string &aIdTask) |
Permit to put the task in mode in wait. | |
void | changeStateToInUse (string &aIdTask) |
Permit to put the task in mode in use. | |
void | changeStateToExpired (string &aIdTask) |
Permit to put the task in mode expired. | |
void | changeStateToTerminated (string &aIdTask) |
Permit to put the task in mode terminated. | |
void | saveTask (Task *aDescriptor) |
void | addTaskAgentInUse (string aTask, string aAgent) |
void | deleteTaskAgentInUse (string aAgent, bool aError) |
void | updateAging () |
Permit to update the list of available tasks with aging. | |
void | addTask (string &aId, string &aCreationDate, int aExpiration, int aPriority, string &aTaskName, string &aUserName, string &aUserMail, list< vector< string > > aFilters, list< vector< string > > aDatas, string &aResultLocalPath, string &aResultStoragePath, string &aBinSourcePath, string &aResultCommand) |
bool | extractTaskToExec (PGAgentInfo *aAgent, Task *aDesc, string &aIp, string &aPort) |
list< string > | orderInWaitTasks () |
Permit to reorder the list of tasks in wait. | |
void | updateAdvanceTask (string &aTaskId, string &value) |
Permit to update the advance of the task for task in use. | |
list< vector< string > > | getInformations (string aTaskId) |
Permit to get all the informations of a task. | |
void | checkTimeout () |
Permit to verify if the agents are still active. If they aren't, they are delete;. | |
string | getPath () |
Get the path for connection to a database. | |
void | deleteErrorTask (string aTask, string aAgent) |
Permit to delete a task when a problem occurred. | |
void | eraseBase () |
Delete all the base. | |
bool | getTaskInUse (string aAgent, string aTask) |
verify if the task and agent are in use. | |
string | getMail (string aTask) |
get the mail. | |
string | getResultStorage (string aTask) |
get the result storage. | |
string | getName (string aTask) |
get the name of the task. |
|
Permit to put the task in mode expired.
Implements Queue. |
|
Permit to put the task in mode in use.
Implements Queue. |
|
Permit to put the task in mode in wait.
Implements Queue. |
|
Permit to put the task in mode terminated.
Implements Queue. |
|
Permit to delete a task when a problem occurred.
|
|
Get all the tasks expired.
Implements Queue. |
|
Permit to get all the informations of a task.
Implements Queue. |
|
Get all the tasks in use.
Implements Queue. |
|
Get all the tasks in wait.
Implements Queue. |
|
get the mail.
|
|
get the name of the task.
|
|
get the result storage.
|
|
verify if the task and agent are in use.
|
|
Get all the tasks terminated.
Implements Queue. |
|
Permit to reorder the list of tasks in wait.
Implements Queue. |
|
Permit to update the advance of the task for task in use.
Implements Queue. |