Workspace 6.21.5
|
#include <SSH/SSHPlugin/Schedulers/Pbs/pbsscheduler.h>
Signals | |
void | queueDestroyRequest (CSIRO::DataExecution::SchedulerRequest *) |
void | queueStartRequest (CSIRO::DataExecution::SchedulerRequest *) |
void | queueStopRequest (QString) |
Public Member Functions | |
PbsScheduler () | |
~PbsScheduler () override | |
const QString & | getInitialisationScript () const |
const QString & | getLogoutScript () const |
int | getPollingInterval () |
const QString & | getPrivateKey () const |
const QString & | getPublicKey () const |
const RetryRules & | getRules () const |
int | getTemplateJobMemory () const |
const QString & | getTemplateJobScript () const |
const WallTime & | getTemplateJobWalltime () const |
QString | getTypeId () const override |
const QString & | getUserName () const |
QString | getVersion () const override |
bool | isConnected () const override |
void | load (const QJsonDocument &) override |
void | load (QDataStream &) override |
void | save (QDataStream &) const override |
void | save (QJsonDocument &) const override |
void | setInitialisationScript (const QString &) |
void | setLogoutScript (const QString &) |
void | setPollingInterval (int) |
void | setPrivateKey (const QString &) |
void | setPublicKey (const QString &) |
void | setRules (const RetryRules &rules) |
void | setTemplateJobMemory (int) |
void | setTemplateJobScript (const QString &) |
void | setTemplateJobWalltime (const WallTime &) |
void | setUserName (const QString &) |
Public Member Functions inherited from AbstractScheduler | |
AbstractScheduler () | |
AbstractScheduler (const Scope scope, const QString &hostName, quint16 port, int cpuCount, bool enabled) | |
~AbstractScheduler () override | |
virtual bool | canChangeServerType () const |
virtual bool | canConfigure () const |
virtual bool | canDelegateTo () const |
virtual bool | canEditConcurrencyCount () const |
virtual bool | canEditFeatures () const |
virtual bool | canEditHostName () const |
virtual bool | canEditMaxServerTimeDiff () const |
virtual bool | canEditPort () const |
virtual bool | canEditScope () const |
virtual bool | canEnable () const |
virtual bool | canRemove () const |
virtual bool | contributesToTotalWorkload () const |
virtual int | getActiveCount () const |
virtual int | getConcurrencyCount () const |
virtual double | getCurrentWorkload () const |
virtual const QString & | getDescription () const |
virtual bool | getEnabled () const |
virtual const SchedulerFeatures & | getFeatures () |
virtual const QString & | getHostName () const |
virtual int | getMaxServerTimeDiff () const |
virtual SchedulerFeatures | getOccupiedFeatures () const |
virtual quint16 | getPort () const |
virtual Scope | getScope () const |
virtual bool | getTemporarilyDisabled () |
virtual int | getTimeout () const |
virtual QString | getTypeId () const =0 |
virtual QString | getUserField (QString) const |
virtual QStringList | getUserFieldList () const |
virtual const QString & | getUuid () const |
virtual QString | getVersion () const =0 |
virtual QFuture< ObjectDictionary > | getWorkflowOutputs (QString uuid) |
Query for a workflows results. | |
virtual bool | isConnected () const |
virtual bool | isLocalWorker () const |
virtual void | load (const QJsonDocument &) |
virtual void | load (QDataStream &) |
void | notifyFailure (SchedulerRequest &, const AbortReason &abortReason, const QString &text="") |
void | notifyProgress (SchedulerRequest &, int percentComplete) |
Triggers a progress notification event on a request. | |
void | notifyStarted (SchedulerRequest &) |
void | notifySuccess (SchedulerRequest &) |
virtual void | save (QDataStream &) const |
virtual void | save (QJsonDocument &) const |
void | schedule (SchedulerRequest &request) |
virtual void | setConcurrencyCount (int cpuCount) |
virtual void | setDescription (const QString &description) |
virtual void | setEnabled (bool enabled) |
virtual void | setFeatures (const SchedulerFeatures &features) |
virtual void | setHostName (const QString &host) |
virtual void | setMaxServerTimeDiff (int maxServerTimeDiff) |
virtual void | setPort (const quint16 port) |
virtual void | setScope (const Scope scope) |
virtual void | setTemporarilyDisabled (bool) |
virtual void | setTimeout (int timeout) |
virtual void | setUserField (QString key, QString value) |
virtual void | setUuid (const QString &uuid) |
virtual void | start () |
virtual void | stop () |
void | stop (SchedulerRequest &request) |
virtual bool | supports (const SchedulerFeatures &features) const |
Protected Slots | |
void | requestProcessorHasLoggedOut () |
Protected Slots inherited from AbstractScheduler | |
virtual void | onConnected () |
virtual void | onDisconnected () |
virtual void | onError (const QString &description) |
void | setVersion (const QString &version) |
Protected Member Functions | |
void | connect () override |
void | destroyRequest (CSIRO::DataExecution::SchedulerRequest &) override |
void | disconnect () override |
void | scheduleRequest (CSIRO::DataExecution::SchedulerRequest &) override |
void | stopRequest (CSIRO::DataExecution::SchedulerRequest &) override |
Protected Member Functions inherited from AbstractScheduler | |
virtual void | connect () |
virtual void | destroyRequest (SchedulerRequest &) |
virtual void | disconnect () |
bool | isSchedulerBusy () const |
virtual void | scheduleRequest (SchedulerRequest &)=0 |
virtual void | stopRequest (SchedulerRequest &)=0 |
Additional Inherited Members | |
Public Types inherited from AbstractScheduler | |
enum | Scope { User , System , UserExternalFile , SystemExternalFile } |
Static Public Attributes inherited from AbstractScheduler | |
static const int | temporarilyDisabledTime = 3000 |
Protected Attributes inherited from AbstractScheduler | |
QAtomicInt | activeCount_ |
int | cpuCount_ |
QString | description_ |
bool | enabled_ |
SchedulerFeatures | features_ |
QString | host_ |
int | maxServerTimeDiff_ |
quint16 | port_ |
Scope | scope_ |
bool | temporarilyDisabled_ |
QTime | temporarilyDisabledTimer_ |
int | timeout_ |
QString | uuid_ |
QString | version_ |
Static Protected Attributes inherited from AbstractScheduler | |
static int | DEFAULT_CPUCOUNT = 2 |
static QString | DEFAULT_HOST = "127.0.0.1" |
static int | DEFAULT_MAXSERVERTIMEDIFF = 5000 |
static quint16 | DEFAULT_PORT = 42150 |
static Scope | DEFAULT_SCOPE = AbstractScheduler::User |
static int | DEFAULT_TIMEOUT = 3000 |
PbsScheduler | ( | ) |
|
override |
Destructs the PbsScheduler.
|
overrideprotectedvirtual |
Establishes a connection to the PbsScheduler.
Reimplemented from AbstractScheduler.
|
overrideprotectedvirtual |
Reimplemented from AbstractScheduler.
|
overrideprotectedvirtual |
Disconnects the PbsScheduler.
Reimplemented from AbstractScheduler.
const QString & getInitialisationScript | ( | ) | const |
const QString & getLogoutScript | ( | ) | const |
int getPollingInterval | ( | ) |
const QString & getPrivateKey | ( | ) | const |
const QString & getPublicKey | ( | ) | const |
|
inline |
int getTemplateJobMemory | ( | ) | const |
const QString & getTemplateJobScript | ( | ) | const |
const WallTime & getTemplateJobWalltime | ( | ) | const |
|
overridevirtual |
Implements AbstractScheduler.
const QString & getUserName | ( | ) | const |
|
overridevirtual |
Implements AbstractScheduler.
|
overridevirtual |
Returns true if the PbsScheduler is connected, false if not.
Reimplemented from AbstractScheduler.
|
overridevirtual |
Reimplemented from AbstractScheduler.
|
overridevirtual |
Reimplemented from AbstractScheduler.
|
signal |
|
signal |
|
signal |
|
protectedslot |
|
overridevirtual |
Reimplemented from AbstractScheduler.
|
overridevirtual |
Reimplemented from AbstractScheduler.
|
overrideprotectedvirtual |
Implements AbstractScheduler.
void setInitialisationScript | ( | const QString & | val | ) |
void setLogoutScript | ( | const QString & | val | ) |
void setPollingInterval | ( | int | val | ) |
void setPrivateKey | ( | const QString & | key | ) |
void setPublicKey | ( | const QString & | key | ) |
|
inline |
void setTemplateJobMemory | ( | int | val | ) |
void setTemplateJobScript | ( | const QString & | val | ) |
void setTemplateJobWalltime | ( | const WallTime & | val | ) |
void setUserName | ( | const QString & | val | ) |
|
overrideprotectedvirtual |
Implements AbstractScheduler.