CernVM-FS  2.12.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
ConcurrentWorkers< WorkerT > Member List

This is the complete list of members for ConcurrentWorkers< WorkerT >, including all inherited members.

Acquire()ConcurrentWorkers< WorkerT >inlineprotected
callback_thread_ConcurrentWorkers< WorkerT >private
CallbackJob typedefConcurrentWorkers< WorkerT >protected
CallbackPtr typedefObservable< WorkerT::returned_data >
CallbackQueue typedefConcurrentWorkers< WorkerT >private
Callbacks typedefObservable< WorkerT::returned_data >protected
CallbackTN typedefCallbackable< WorkerT::returned_data >
ConcurrentWorkers(const size_t number_of_workers, const size_t maximal_queue_length, worker_context_t *worker_context=NULL)ConcurrentWorkers< WorkerT >
expected_data_t typedefConcurrentWorkers< WorkerT >
GetNumberOfFailedJobs() const ConcurrentWorkers< WorkerT >inline
GetNumberOfWorkers() const ConcurrentWorkers< WorkerT >inline
Initialize()ConcurrentWorkers< WorkerT >
initialized_ConcurrentWorkers< WorkerT >private
IsRunning() const ConcurrentWorkers< WorkerT >inlineprotected
JobDone(const returned_data_t &data, const bool success=true)ConcurrentWorkers< WorkerT >protected
JobFailed(const returned_data_t &data)ConcurrentWorkers< WorkerT >inline
JobQueue typedefConcurrentWorkers< WorkerT >private
jobs_all_done_ConcurrentWorkers< WorkerT >mutableprivate
jobs_all_done_mutex_ConcurrentWorkers< WorkerT >mutableprivate
jobs_failed_ConcurrentWorkers< WorkerT >mutableprivate
jobs_pending_ConcurrentWorkers< WorkerT >mutableprivate
jobs_processed_ConcurrentWorkers< WorkerT >mutableprivate
jobs_queue_ConcurrentWorkers< WorkerT >private
JobSuccessful(const returned_data_t &data)ConcurrentWorkers< WorkerT >inline
MakeCallback(typename BoundCallback< WorkerT::returned_data, DelegateT >::CallbackMethod method, DelegateT *delegate)Callbackable< WorkerT::returned_data >inlinestatic
MakeCallback(typename Callback< WorkerT::returned_data >::CallbackFunction function)Callbackable< WorkerT::returned_data >inlinestatic
MakeClosure(typename BoundClosure< WorkerT::returned_data, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data)Callbackable< WorkerT::returned_data >inlinestatic
NotifyListeners(const WorkerT::returned_data &parameter)Observable< WorkerT::returned_data >protected
number_of_workers_ConcurrentWorkers< WorkerT >private
Observable()Observable< WorkerT::returned_data >protected
RegisterListener(typename BoundClosure< WorkerT::returned_data, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data)Observable< WorkerT::returned_data >
RegisterListener(typename BoundCallback< WorkerT::returned_data, DelegateT >::CallbackMethod method, DelegateT *delegate)Observable< WorkerT::returned_data >
RegisterListener(typename Callback< WorkerT::returned_data >::CallbackFunction fn)Observable< WorkerT::returned_data >
RegisterListener(CallbackPtr callback_object)Observable< WorkerT::returned_data >protected
ReportStartedWorker() const ConcurrentWorkers< WorkerT >protected
results_queue_ConcurrentWorkers< WorkerT >private
returned_data_t typedefConcurrentWorkers< WorkerT >
RunCallbackThread()ConcurrentWorkers< WorkerT >
RunCallbackThreadWrapper(void *run_binding)ConcurrentWorkers< WorkerT >protectedstatic
running_ConcurrentWorkers< WorkerT >private
RunWorker(void *run_binding)ConcurrentWorkers< WorkerT >protectedstatic
Schedule(const expected_data_t &data)ConcurrentWorkers< WorkerT >inline
Schedule(WorkerJob job)ConcurrentWorkers< WorkerT >protected
ScheduleDeathSentences()ConcurrentWorkers< WorkerT >protected
SpawnWorkers()ConcurrentWorkers< WorkerT >protected
StartRunning()ConcurrentWorkers< WorkerT >inlineprotected
status_mutex_ConcurrentWorkers< WorkerT >mutableprivate
StopRunning()ConcurrentWorkers< WorkerT >inlineprotected
Terminate()ConcurrentWorkers< WorkerT >
thread_context_ConcurrentWorkers< WorkerT >private
TruncateJobQueue(const bool forget_pending=false)ConcurrentWorkers< WorkerT >protected
UnregisterListener(CallbackPtr callback_object)Observable< WorkerT::returned_data >
UnregisterListeners()Observable< WorkerT::returned_data >
WaitForEmptyQueue() const ConcurrentWorkers< WorkerT >
WaitForTermination()ConcurrentWorkers< WorkerT >
worker_context_ConcurrentWorkers< WorkerT >private
worker_context_t typedefConcurrentWorkers< WorkerT >
worker_started_ConcurrentWorkers< WorkerT >mutableprivate
worker_threads_ConcurrentWorkers< WorkerT >private
WorkerJob typedefConcurrentWorkers< WorkerT >protected
workers_started_ConcurrentWorkers< WorkerT >mutableprivate
WorkerThreads typedefConcurrentWorkers< WorkerT >protected
~ConcurrentWorkers()ConcurrentWorkers< WorkerT >virtual
~Observable()Observable< WorkerT::returned_data >virtual