#include <remote.h>
Public Slots | |
bool | submitJob (MoleQueue::Job job) |
void | killJob (MoleQueue::Job job) |
virtual void | requestQueueUpdate ()=0 |
![]() | |
virtual bool | submitJob (MoleQueue::Job job)=0 |
virtual void | killJob (MoleQueue::Job job)=0 |
virtual void | setLaunchTemplate (const QString &script) |
virtual void | setLaunchScriptName (const QString &scriptName) |
Public Member Functions | |
QueueRemote (const QString &queueName="AbstractRemote", QueueManager *parentManager=0) | |
bool | writeJsonSettings (QJsonObject &json, bool exportOnly, bool includePrograms) const |
bool | readJsonSettings (const QJsonObject &json, bool importOnly, bool includePrograms) |
virtual AbstractQueueSettingsWidget * | settingsWidget ()=0 |
void | setWorkingDirectoryBase (const QString &base) |
QString | workingDirectoryBase () const |
void | setQueueUpdateInterval (int i) |
int | queueUpdateInterval () const |
void | setDefaultMaxWallTime (int time) |
int | defaultMaxWallTime () const |
void | replaceKeywords (QString &launchScript, const Job &job, bool addNewline=true) |
![]() | |
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 |
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 |
Protected Slots | |
virtual void | submitPendingJobs () |
virtual void | beginJobSubmission (MoleQueue::Job job) |
virtual void | createRemoteDirectory (MoleQueue::Job job)=0 |
virtual void | remoteDirectoryCreated ()=0 |
virtual void | copyInputFilesToHost (MoleQueue::Job job)=0 |
virtual void | inputFilesCopied ()=0 |
virtual void | submitJobToRemoteQueue (MoleQueue::Job job)=0 |
virtual void | jobSubmittedToRemoteQueue ()=0 |
virtual void | handleQueueUpdate ()=0 |
virtual void | beginFinalizeJob (MoleQueue::IdType queueId)=0 |
virtual void | finalizeJobCopyFromServer (MoleQueue::Job job)=0 |
virtual void | finalizeJobOutputCopiedFromServer ()=0 |
virtual void | finalizeJobCopyToCustomDestination (MoleQueue::Job job)=0 |
virtual void | finalizeJobCleanup (MoleQueue::Job job) |
virtual void | cleanRemoteDirectory (MoleQueue::Job job)=0 |
virtual void | remoteDirectoryCleaned ()=0 |
void | jobAboutToBeRemoved (const MoleQueue::Job &job) |
virtual void | beginKillJob (MoleQueue::Job job)=0 |
virtual void | endKillJob ()=0 |
![]() | |
virtual void | jobAboutToBeRemoved (const MoleQueue::Job &job) |
void | programNameChanged (const QString &newName, const QString &oldName) |
void | cleanLocalDirectory (const MoleQueue::Job &job) |
Protected Member Functions | |
virtual void | removeStaleJobs () |
virtual void | timerEvent (QTimerEvent *theEvent) |
![]() | |
Queue (const QString &queueName="Undefined", QueueManager *parentManager=0) | |
bool | writeInputFiles (const Job &job) |
bool | addJobFailure (IdType moleQueueId) |
void | clearJobFailures (IdType moleQueueId) |
Protected Attributes | |
int | m_checkQueueTimerId |
QList< IdType > | m_pendingSubmission |
int | m_checkForPendingJobsTimerId |
int | m_queueUpdateInterval |
int | m_defaultMaxWallTime |
QString | m_workingDirectoryBase |
![]() | |
QueueManager * | m_queueManager |
Server * | m_server |
QString | m_name |
QString | m_launchTemplate |
QString | m_launchScriptName |
QMap< QString, Program * > | m_programs |
QMap< IdType, IdType > | m_jobs |
QMap< IdType, int > | m_failureTracker |
Additional Inherited Members | |
![]() | |
void | programAdded (const QString &name, MoleQueue::Program *program) |
void | programRemoved (const QString &name, MoleQueue::Program *program) |
void | programRenamed (const QString &newName, Program *prog, const QString &oldName) |
void | nameChanged (const QString &newName, const QString &oldName) |
![]() | |
static QString | queueTypeFromFile (const QString &mqqFile) |
abstract Queue subclass for interacting with a generic Remote queue.
|
virtual |
writeJsonSettings Write the queue's internal state into a JSON object.
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. |
Reimplemented from Queue.
Reimplemented in QueueRemoteSsh.
|
virtual |
readJsonSettings Initialize the queue's internal state from a JSON object.
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. |
Reimplemented from Queue.
Reimplemented in QueueRemoteSsh.
|
pure virtual |
Returns a widget that can be used to configure the settings for the queue.
Reimplemented from Queue.
Implemented in QueueRemoteSsh, and QueueUit.
void setQueueUpdateInterval | ( | int | i | ) |
Time between remote queue updates in minutes.
int queueUpdateInterval | ( | ) | const |
Time between remote queue updates in minutes.
void setDefaultMaxWallTime | ( | int | time | ) |
setDefaultMaxWallTime Set the default walltime limit (in minutes) for jobs on this queue. This value will be used if the job's Job::maxWallTime() method returns a value <= 0. Default is one day.
time | walltime limit in minutes |
int defaultMaxWallTime | ( | ) | const |
defaultMaxWallTime Get the default walltime limit (in minutes) for jobs on this queue. This value will be used if the job's Job::maxWallTime() method returns a value <= 0. Default is one day.
|
virtual |
Reimplemented from Queue::replaceKeywords.
Reimplemented from Queue.
|
protectedvirtualslot |
Main entry point into the job submission pipeline.
|
protectedslot |
Reimplemented from Queue.
|
protectedvirtual |
Check for any jobs that are not present in the JobManager but are still in this object's internal data structures. This may be the result of an improper shut down when state is serialized inconsistently. If any such jobs are found, they are removed from the internal structures and an Error is emitted.
|
protectedvirtual |
Reimplemented to monitor queue events.
|
protected |
MoleQueue ids of jobs that have been accepted but not submitted.
|
protected |
Time between remote queue updates in minutes.
|
protected |
Default maximum walltime limit for jobs on this queue in minutes.