RequestProcessor Class Reference

#include <Distributed/Schedulers/MongoDB/mongodbschedulerrequestprocessor.h>

Inheritance diagram for RequestProcessor:

Public Types
using	MapUuid2Retries = QMap< QString, QStringList >

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

Signals
void	hasLoggedOut ()
void	jobsAborted (const MapUuid2Retries &uuids)
void	jobsFinished (const QSet< QString > &uuids)
void	postponeRequest (DataExecution::SchedulerRequest *)

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

Detailed Description

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

Member Typedef Documentation

MapUuid2Retries

using MapUuid2Retries = QMap<QString, QStringList>

Constructor & Destructor Documentation

RequestProcessor()

RequestProcessor

(

MongoDbScheduler &

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

(

)

jobsAborted

void jobsAborted ( const MapUuid2Retries &  uuids )

signal

jobsFinished

void jobsFinished ( const QSet< QString > &  uuids )

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