xrootd: XrdCl::JobManager Class Reference

xrootd

A synchronized queue. More...

#include <XrdClJobManager.hh>

Collaboration diagram for XrdCl::JobManager:

Collaboration graph

Classes
struct	JobHelper

Public Member Functions
	JobManager (uint32_t workers)
	Constructor. More...

	~JobManager ()
	Destructor. More...

bool	Initialize ()
	Initialize the job manager. More...

bool	Finalize ()
	Finalize the job manager, clear the queues. More...

bool	Start ()
	Start the workers. More...

bool	Stop ()
	Stop the workers. More...

void	QueueJob (Job job, void arg=0)
	Add a job to be run. More...

void	RunJobs ()
	Run the jobs. More...

Private Member Functions
void	StopWorkers (uint32_t n)
	Stop all workers up to n'th. More...

Private Attributes
std::vector< pthread_t >	pWorkers

SyncQueue< JobHelper >	pJobs

XrdSysMutex	pMutex

bool	pRunning

Detailed Description

A synchronized queue.

Constructor & Destructor Documentation

XrdCl::JobManager::JobManager ( uint32_t workers )

inline

Constructor.

References pRunning, and pWorkers.

XrdCl::JobManager::~JobManager ( )

inline

Destructor.

Member Function Documentation

bool XrdCl::JobManager::Finalize ( )

Finalize the job manager, clear the queues.

References pJobs.

Referenced by XrdCl::PostMaster::Finalize().

bool XrdCl::JobManager::Initialize ( )

Initialize the job manager.

Referenced by XrdCl::PostMaster::Initialize().

void XrdCl::JobManager::QueueJob	(	Job *	job,
		void *	arg = `0`
	)

inline

Add a job to be run.

References pJobs.

Referenced by XrdCl::Stream::OnIncoming(), and XrdCl::FileStateHandler::TimeOutRequests().

void XrdCl::JobManager::RunJobs ( )

Run the jobs.

References XrdCl::JobManager::JobHelper::arg, XrdCl::JobManager::JobHelper::job, pJobs, and XrdCl::Job::Run().

Referenced by RunRunnerThread().

bool XrdCl::JobManager::Start ( )

Start the workers.

References XrdCl::Log::Debug(), XrdCl::Log::Error(), XrdCl::DefaultEnv::GetLog(), XrdCl::JobMgrMsg, pMutex, pRunning, pWorkers, RunRunnerThread(), and StopWorkers().

Referenced by XrdCl::PostMaster::Start().

bool XrdCl::JobManager::Stop ( )

Stop the workers.

References XrdCl::Log::Debug(), XrdCl::Log::Error(), XrdCl::DefaultEnv::GetLog(), XrdCl::JobMgrMsg, pMutex, pRunning, pWorkers, and StopWorkers().

Referenced by XrdCl::PostMaster::Stop().

void XrdCl::JobManager::StopWorkers ( uint32_t n )

private

Stop all workers up to n'th.

References XrdCl::Log::Dump(), XrdCl::DefaultEnv::GetLog(), XrdCl::JobMgrMsg, and pWorkers.

Referenced by Start(), and Stop().

Member Data Documentation

SyncQueue<JobHelper> XrdCl::JobManager::pJobs

private

Referenced by Finalize(), QueueJob(), and RunJobs().

XrdSysMutex XrdCl::JobManager::pMutex

private

Referenced by Start(), and Stop().

bool XrdCl::JobManager::pRunning

private

Referenced by JobManager(), Start(), and Stop().

std::vector<pthread_t> XrdCl::JobManager::pWorkers

private

Referenced by JobManager(), Start(), Stop(), and StopWorkers().

The documentation for this class was generated from the following files: