#include <sge.h>
Public Member Functions | |
QueueSge (QueueManager *parentManager=0) | |
QString | typeName () const |
![]() | |
QueueRemoteSsh (const QString &queueName="AbstractRemoteSsh", QueueManager *parentManager=0) | |
bool | writeJsonSettings (QJsonObject &json, bool exportOnly, bool includePrograms) const |
bool | readJsonSettings (const QJsonObject &json, bool importOnly, bool includePrograms) |
void | setSshExecutable (const QString &exe) |
QString | sshExecutable () const |
void | setScpExecutable (const QString &exe) |
QString | scpExectuable () const |
void | setHostName (const QString &host) |
QString | hostName () const |
void | setUserName (const QString &user) |
QString | userName () const |
void | setIdentityFile (const QString &identity) |
QString | identityFile () const |
void | setSshPort (int port) |
int | sshPort () const |
void | setSubmissionCommand (const QString &command) |
QString | submissionCommand () const |
void | setKillCommand (const QString &command) |
QString | killCommand () const |
void | setRequestQueueCommand (const QString &command) |
QString | requestQueueCommand () const |
virtual AbstractQueueSettingsWidget * | settingsWidget () |
![]() | |
QueueRemote (const QString &queueName="AbstractRemote", QueueManager *parentManager=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 |
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 Member Functions | |
virtual bool | parseQueueId (const QString &submissionOutput, IdType *queueId) |
virtual QString | generateQueueRequestCommand () |
virtual bool | parseQueueLine (const QString &queueListOutput, IdType *queueId, JobState *state) |
![]() | |
virtual SshConnection * | newSshConnection () |
![]() | |
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) |
Additional Inherited Members | |
![]() | |
void | requestQueueUpdate () |
![]() | |
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) |
![]() | |
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) |
![]() | |
void | createRemoteDirectory (MoleQueue::Job job) |
void | remoteDirectoryCreated () |
void | copyInputFilesToHost (MoleQueue::Job job) |
void | inputFilesCopied () |
void | submitJobToRemoteQueue (MoleQueue::Job job) |
void | jobSubmittedToRemoteQueue () |
void | handleQueueUpdate () |
void | beginFinalizeJob (MoleQueue::IdType queueId) |
void | finalizeJobCopyFromServer (MoleQueue::Job job) |
void | finalizeJobOutputCopiedFromServer () |
void | finalizeJobCopyToCustomDestination (MoleQueue::Job job) |
void | finalizeJobCleanup (MoleQueue::Job job) |
void | cleanRemoteDirectory (MoleQueue::Job job) |
void | remoteDirectoryCleaned () |
void | beginKillJob (MoleQueue::Job job) |
void | endKillJob () |
![]() | |
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) |
![]() | |
QString | m_sshExecutable |
QString | m_scpExecutable |
QString | m_hostName |
QString | m_userName |
QString | m_identityFile |
int | m_sshPort |
bool | m_isCheckingQueue |
QString | m_submissionCommand |
QString | m_killCommand |
QString | m_requestQueueCommand |
QList< int > | m_allowedQueueRequestExitCodes |
![]() | |
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 |
QueueRemote subclass for interacting with Sun Grid Engine.
|
virtual |
Returns the type of the queue as a string.
Reimplemented from Queue.
|
protectedvirtual |
Extract the job id from the submission output. Reimplement this in derived classes.
submissionOutput | Output from m_submissionCommand |
queueId | The queuing system's job id. |
Implements QueueRemoteSsh.
|
protectedvirtual |
Prepare the command to check the remote queue. The default implementation is m_requestQueueCommand followed by the owned job ids separated by spaces.
Reimplemented from QueueRemoteSsh.
|
protectedvirtual |
Extract the queueId and JobState from a single line of the the queue list output. Reimplement this in derived classes.
queueListOutput | Single line of output from m_requestQueueCommand |
queueId | The queuing system's job id. |
state | The state of the job with id queueId |
Implements QueueRemoteSsh.