![]() |
XRootD
|
A synchronized queue. More...
#include <XrdClJobManager.hh>
Public Member Functions | |
JobManager (uint32_t workers) | |
Constructor. More... | |
~JobManager () | |
Destructor. More... | |
bool | Finalize () |
Finalize the job manager, clear the queues. More... | |
bool | Initialize () |
Initialize the job manager. More... | |
bool | IsWorker () |
void | QueueJob (Job *job, void *arg=0) |
Add a job to be run. More... | |
void | RunJobs () |
Run the jobs. More... | |
bool | Start () |
Start the workers. More... | |
bool | Stop () |
Stop the workers. More... | |
A synchronized queue.
Definition at line 50 of file XrdClJobManager.hh.
|
inline |
Constructor.
Definition at line 56 of file XrdClJobManager.hh.
|
inline |
bool XrdCl::JobManager::Finalize | ( | ) |
Finalize the job manager, clear the queues.
Definition at line 52 of file XrdClJobManager.cc.
References XrdCl::SyncQueue< Item >::Clear().
Referenced by XrdEc::ThreadPool::~ThreadPool(), and XrdCl::CopyProcess::Run().
bool XrdCl::JobManager::Initialize | ( | ) |
Initialize the job manager.
Definition at line 44 of file XrdClJobManager.cc.
Referenced by XrdCl::CopyProcess::Run().
|
inline |
Definition at line 102 of file XrdClJobManager.hh.
|
inline |
Add a job to be run.
Definition at line 92 of file XrdClJobManager.hh.
References XrdCl::SyncQueue< Item >::Put().
Referenced by XrdCl::FileStateHandler::Close(), XrdEc::ThreadPool::Execute(), XrdCl::Stream::OnConnect(), XrdCl::Stream::OnIncoming(), XrdCl::LocalFileHandler::QueueTask(), XrdCl::CopyProcess::Run(), XrdCl::Operation< HasHndl >::Run(), XrdEc::ScheduleHandler(), and XrdCl::FileStateHandler::TimeOutRequests().
void XrdCl::JobManager::RunJobs | ( | ) |
Run the jobs.
Definition at line 146 of file XrdClJobManager.cc.
References XrdCl::SyncQueue< Item >::Get().
Referenced by RunRunnerThread().
bool XrdCl::JobManager::Start | ( | ) |
Start the workers.
Definition at line 61 of file XrdClJobManager.cc.
References XrdCl::Log::Debug(), XrdCl::Log::Error(), XrdCl::DefaultEnv::GetLog(), XrdCl::JobMgrMsg, RunRunnerThread(), and XrdSysE2T().
Referenced by XrdCl::CopyProcess::Run().
bool XrdCl::JobManager::Stop | ( | ) |
Stop the workers.
Definition at line 93 of file XrdClJobManager.cc.
References XrdCl::Log::Debug(), XrdCl::Log::Error(), XrdCl::DefaultEnv::GetLog(), and XrdCl::JobMgrMsg.
Referenced by XrdEc::ThreadPool::~ThreadPool(), and XrdCl::CopyProcess::Run().