#include <local.h>
|
| QueueLocal (QueueManager *parentManager=0) |
|
QString | typeName () const |
|
bool | writeJsonSettings (QJsonObject &json, bool exportOnly, bool includePrograms) const |
|
bool | readJsonSettings (const QJsonObject &json, bool importOnly, bool includePrograms) |
|
AbstractQueueSettingsWidget * | settingsWidget () |
|
int | maxNumberOfCores () const |
|
void | setMaxNumberOfCores (int cores) |
|
Server * | server () |
|
const Server * | server () const |
|
QueueManager * | queueManager () |
|
const QueueManager * | queueManager () const |
|
virtual void | setName (const QString &newName) |
|
QString | name () const |
|
virtual QString | typeName () const |
|
bool | readSettings (const QString &filePath) |
|
bool | writeSettings () const |
|
bool | exportSettings (const QString &fileName, bool includePrograms=true) const |
|
bool | importSettings (const QString &fileName, bool includePrograms=true) |
|
QString | stateFileName () const |
|
virtual bool | writeJsonSettings (QJsonObject &value, bool exportOnly, bool includePrograms) const |
|
virtual bool | readJsonSettings (const QJsonObject &value, bool importOnly, bool includePrograms) |
|
virtual AbstractQueueSettingsWidget * | settingsWidget () |
|
bool | addProgram (Program *newProgram, bool replace=false) |
|
bool | removeProgram (Program *programToRemove) |
|
bool | removeProgram (const QString &programName) |
|
Program * | lookupProgram (const QString &programName) const |
|
QStringList | programNames () const |
|
QList< Program * > | programs () const |
|
int | numPrograms () const |
|
virtual QString | launchTemplate () const |
|
QString | launchScriptName () const |
|
int | jobFailureCount (IdType moleQueueId) const |
|
virtual void | replaceKeywords (QString &launchScript, const Job &job, bool addNewline=true) |
|
Queue for running jobs locally.
◆ typeName()
QString typeName |
( |
| ) |
const |
|
virtual |
Returns the type of the queue as a string.
Reimplemented from Queue.
◆ writeJsonSettings()
bool writeJsonSettings |
( |
QJsonObject & |
value, |
|
|
bool |
exportOnly, |
|
|
bool |
includePrograms |
|
) |
| const |
|
virtual |
writeJsonSettings Write the queue's internal state into a JSON object.
- Parameters
-
value | Target JSON object. |
exportOnly | If true, instance specific information (e.g. currently running jobs, login details, etc) is omitted. |
includePrograms | Whether or not to include the Queue's program configurations. |
- Returns
- True on success, false on failure.
Reimplemented from Queue.
◆ readJsonSettings()
bool readJsonSettings |
( |
const QJsonObject & |
value, |
|
|
bool |
importOnly, |
|
|
bool |
includePrograms |
|
) |
| |
|
virtual |
readJsonSettings Initialize the queue's internal state from a JSON object.
- Parameters
-
value | Source JSON object. |
importOnly | If true, instance specific information (e.g. currently running jobs, login details, etc) is ignored. |
includePrograms | Whether or not to include the Queue's program configurations. |
- Returns
- True on success, false on failure.
- Note
- When reimplementing this method, verify and parse the Json object into temporary variables, then call the base class implementation and only modify the queue if the call returns true.
Reimplemented from Queue.
◆ settingsWidget()
Returns a widget that can be used to configure the settings for the queue.
Reimplemented from Queue.
◆ maxNumberOfCores()
int maxNumberOfCores |
( |
| ) |
const |
The number of cores available.
◆ setMaxNumberOfCores()
void setMaxNumberOfCores |
( |
int |
cores | ) |
|
The number of cores available.
◆ prepareJobForSubmission
bool prepareJobForSubmission |
( |
Job & |
job | ) |
|
|
protectedslot |
Write the input files for the job and add to the queue
- Parameters
-
- Returns
- True on success, false otherwise.
◆ processStarted
Called when a process starts.
◆ processFinished
void processFinished |
( |
int |
exitCode, |
|
|
QProcess::ExitStatus |
exitStatus |
|
) |
| |
|
protectedslot |
Called when a process exits.
- Parameters
-
exitCode | Exit code of process |
exitStatus | Exit status of process |
◆ processError
void processError |
( |
QProcess::ProcessError |
error | ) |
|
|
protectedslot |
Called when a error occurs with a process.
- Parameters
-
error | the specific error that occurred |
◆ addJobToQueue()
bool addJobToQueue |
( |
const Job & |
job | ) |
|
|
protected |
Insert the job into the queue.
◆ connectProcess()
void connectProcess |
( |
QProcess * |
proc | ) |
|
|
protected |
Connect proc to handlers prior to submitting job.
◆ checkJobQueue()
Submit any queued jobs that can be started.
◆ startJob()
bool startJob |
( |
IdType |
moleQueueId | ) |
|
|
protected |
Submit the job with MoleQueue id moleQueueId.
◆ timerEvent()
void timerEvent |
( |
QTimerEvent * |
theEvent | ) |
|
|
protected |
Reimplemented to monitor queue events.
◆ m_checkJobLimitTimerId
int m_checkJobLimitTimerId |
|
protected |
◆ m_pendingJobQueue
QList<IdType> m_pendingJobQueue |
|
protected |
FIFO queue of MoleQueue ids.
◆ m_runningJobs
QMap<IdType, QProcess*> m_runningJobs |
|
protected |
List of running processes. MoleQueue Id to QProcess*.
◆ m_cores
The number of cores available.
The documentation for this class was generated from the following file: