Workspace 6.21.5
|
#include <Workspace/DataExecution/Execution/abstractscheduler.h>
Public Types | |
enum | Scope { User , System , UserExternalFile , SystemExternalFile } |
Public Member Functions | |
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 |
Static Public Attributes | |
static const int | temporarilyDisabledTime = 3000 |
Protected Slots | |
virtual void | onConnected () |
virtual void | onDisconnected () |
virtual void | onError (const QString &description) |
void | setVersion (const QString &version) |
Protected Member Functions | |
virtual void | connect () |
virtual void | destroyRequest (SchedulerRequest &) |
virtual void | disconnect () |
bool | isSchedulerBusy () const |
virtual void | scheduleRequest (SchedulerRequest &)=0 |
virtual void | stopRequest (SchedulerRequest &)=0 |
Protected Attributes | |
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 | |
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 |
enum Scope |
The default constructor.
AbstractScheduler | ( | const Scope | scope, |
const QString & | hostName, | ||
quint16 | port, | ||
int | cpuCount, | ||
bool | enabled | ||
) |
An initialising constructor.
scope | the server's scope |
hostName | the server's host address |
port | the server's port |
cpuCount | the server's cpu count |
enabled | the server's enabled status |
|
overridedefault |
Destructs the AbstractScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
protectedvirtual |
Reimplemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, and TcpScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
protectedvirtual |
Reimplemented in PbsScheduler, SlurmScheduler, MongoDbScheduler, and SqlScheduler.
|
protectedvirtual |
Reimplemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, and TcpScheduler.
|
inlinevirtual |
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
Normalized workload. 0 is free, 1 is busy.
Reimplemented in TcpScheduler.
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
Summary of occupied features, if any.
Reimplemented in TcpScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
inlinevirtual |
|
virtual |
|
inlinevirtual |
|
pure virtual |
Implemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, OOPScheduler, and TcpScheduler.
|
inlinevirtual |
Reimplemented in TcpScheduler.
|
inlinevirtual |
Reimplemented in TcpScheduler.
|
inlinevirtual |
|
pure virtual |
Implemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, OOPScheduler, and TcpScheduler.
|
virtual |
Reimplemented in MongoDbScheduler, SqlScheduler, and TcpScheduler.
|
virtual |
Reimplemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, OOPScheduler, and TcpScheduler.
|
inlinevirtual |
Reimplemented in OOPScheduler.
|
protected |
|
virtual |
Reimplemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, and TcpScheduler.
|
virtual |
Reimplemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, OOPScheduler, and TcpScheduler.
void notifyFailure | ( | SchedulerRequest & | request, |
const AbortReason & | abortReason, | ||
const QString & | text = "" |
||
) |
Handles a failed SchedulerRequest
void notifyProgress | ( | SchedulerRequest & | request, |
int | percentComplete | ||
) |
void notifyStarted | ( | SchedulerRequest & | request | ) |
Handles a started SchedulerRequest
void notifySuccess | ( | SchedulerRequest & | request | ) |
Handles a successful SchedulerRequest
|
protectedvirtualslot |
|
protectedvirtualslot |
|
protectedvirtualslot |
|
virtual |
Reimplemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, OOPScheduler, and TcpScheduler.
|
virtual |
Reimplemented in MongoDbScheduler, SqlScheduler, PbsScheduler, SlurmScheduler, and TcpScheduler.
void schedule | ( | SchedulerRequest & | request | ) |
Schedules a workspace for execution by the remote scheduler
request | The request to be processed |
|
protectedpure virtual |
Implemented in PbsScheduler, SlurmScheduler, MongoDbScheduler, SqlScheduler, OOPScheduler, and TcpScheduler.
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
Reimplemented in TcpScheduler.
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
virtual |
|
inlinevirtual |
|
inlinevirtual |
Reimplemented in TcpScheduler.
|
inlinevirtual |
|
protectedslot |
|
virtual |
|
virtual |
void stop | ( | SchedulerRequest & | request | ) |
Stops a request scheduled on this scheduler.
request | The request to be stopped |
|
protectedpure virtual |
Implemented in PbsScheduler, SlurmScheduler, MongoDbScheduler, SqlScheduler, OOPScheduler, and TcpScheduler.
|
virtual |
Returns true if the scheduler supports the provided features.
|
protected |
|
protected |
|
staticprotected |
|
staticprotected |
|
staticprotected |
|
staticprotected |
|
staticprotected |
|
staticprotected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
static |
|
protected |
|
protected |
|
protected |
|
protected |