XrdCl::JobManager Class Reference

A synchronized queue. More...

#include <XrdClJobManager.hh>

Collaboration diagram for XrdCl::JobManager:
Collaboration graph
[legend]

List of all members.

Classes

struct  JobHelper

Public Member Functions

 JobManager (uint32_t workers)
 Constructor.
 ~JobManager ()
 Destructor.
bool Initialize ()
 Initialize the job manager.
bool Finalize ()
 Finalize the job manager, clear the queues.
bool Start ()
 Start the workers.
bool Stop ()
 Stop the workers.
void QueueJob (Job *job, void *arg=0)
 Add a job to be run.
void RunJobs ()
 Run the jobs.
bool IsWorker ()

Private Member Functions

void StopWorkers (uint32_t n)
 Stop all workers up to n'th.

Private Attributes

std::vector< pthread_t > pWorkers
SyncQueue< JobHelperpJobs
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.

bool XrdCl::JobManager::Initialize (  ) 

Initialize the job manager.

bool XrdCl::JobManager::IsWorker (  )  [inline]

References pWorkers.

void XrdCl::JobManager::QueueJob ( Job job,
void *  arg = 0 
) [inline]

Add a job to be run.

References pJobs, and XrdCl::SyncQueue< Item >::Put().

void XrdCl::JobManager::RunJobs (  ) 

Run the jobs.

bool XrdCl::JobManager::Start (  ) 

Start the workers.

bool XrdCl::JobManager::Stop (  ) 

Stop the workers.

void XrdCl::JobManager::StopWorkers ( uint32_t  n  )  [private]

Stop all workers up to n'th.


Member Data Documentation

Referenced by QueueJob().

Referenced by JobManager().

std::vector<pthread_t> XrdCl::JobManager::pWorkers [private]

Referenced by IsWorker(), and JobManager().


The documentation for this class was generated from the following file:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines

Generated on 2 Oct 2019 for xrootd by  doxygen 1.6.1