RequestProcessor Class Reference

#include <RemoteExecution/Schedulers/Sql/sqlschedulerrequestprocessor.h>

Inheritance diagram for RequestProcessor:

Public Slots
void	destroyRequest (DataExecution::SchedulerRequest *)
void	scheduleRequest (DataExecution::SchedulerRequest *)
void	stopRequest (QString)

Signals
void	hasLoggedOut ()
void	jobsFinished (const QSet< QString > &uuids, bool aborted)
void	postponeRequest (DataExecution::SchedulerRequest *)

Public Member Functions
	RequestProcessor (SqlScheduler &)
	~RequestProcessor () override
QString	getWorkflow (const QString &uuid) const
bool	isReadyToProcessRequests () const
void	queryJobFinished (const QString &uuid)
void	stop ()

Detailed Description

Worker thread that handles communication between the client and ssh end point

Constructor & Destructor Documentation

RequestProcessor()

RequestProcessor

(

SqlScheduler &

scheduler

)

~RequestProcessor()

~RequestProcessor ( )

overridedefault

Member Function Documentation

destroyRequest

void destroyRequest ( DataExecution::SchedulerRequest *  request )

slot

getWorkflow()

QString getWorkflow ( const QString &  uuid ) const

inline

hasLoggedOut

void hasLoggedOut ( )

signal

isReadyToProcessRequests()

bool isReadyToProcessRequests

(

)

const

jobsFinished

void jobsFinished ( const QSet< QString > &  uuids, bool  aborted  )

signal

postponeRequest

void postponeRequest ( DataExecution::SchedulerRequest *  )

signal

queryJobFinished()

void queryJobFinished

(

const QString &

uuid

)

Async query of a job, get a jobFinished signal when the job finished (or aborted)

scheduleRequest

void scheduleRequest ( DataExecution::SchedulerRequest *  request )

slot

stop()

void stop

(

)

stopRequest

void stopRequest ( QString  uuid )

slot