CernVM-FS  2.9.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
TubeConsumerGroup< ItemT > Class Template Reference

#include <task.h>

Inheritance diagram for TubeConsumerGroup< ItemT >:
Collaboration diagram for TubeConsumerGroup< ItemT >:

Public Member Functions

 TubeConsumerGroup ()
 
 ~TubeConsumerGroup ()
 
void TakeConsumer (TubeConsumer< ItemT > *consumer)
 
void Spawn ()
 
void Terminate ()
 
bool is_active ()
 

Private Attributes

bool is_active_
 
std::vector< TubeConsumer
< ItemT > * > 
consumers_
 
std::vector< pthread_t > threads_
 

Additional Inherited Members

- Private Member Functions inherited from SingleCopy
 SingleCopy ()
 

Detailed Description

template<typename ItemT>
class TubeConsumerGroup< ItemT >

This file is part of the CernVM File System. Forward declaration of TubeConsumerGroup so that it can be used as a friend class to TubeConsumer.

Definition at line 24 of file task.h.

Constructor & Destructor Documentation

template<typename ItemT>
TubeConsumerGroup< ItemT >::TubeConsumerGroup ( )
inline

Definition at line 67 of file task.h.

template<typename ItemT>
TubeConsumerGroup< ItemT >::~TubeConsumerGroup ( )
inline

Definition at line 69 of file task.h.

Member Function Documentation

template<typename ItemT>
bool TubeConsumerGroup< ItemT >::is_active ( )
inline

Definition at line 107 of file task.h.

template<typename ItemT>
void TubeConsumerGroup< ItemT >::Spawn ( )
inline

Definition at line 79 of file task.h.

Referenced by IngestionPipeline::Spawn(), and ScrubbingPipeline::Spawn().

Here is the caller graph for this function:

template<typename ItemT>
void TubeConsumerGroup< ItemT >::TakeConsumer ( TubeConsumer< ItemT > *  consumer)
inline

Definition at line 74 of file task.h.

Referenced by IngestionPipeline::IngestionPipeline(), and ScrubbingPipeline::ScrubbingPipeline().

Here is the caller graph for this function:

template<typename ItemT>
void TubeConsumerGroup< ItemT >::Terminate ( )
inline

Definition at line 94 of file task.h.

Referenced by IngestionPipeline::~IngestionPipeline(), and ScrubbingPipeline::~ScrubbingPipeline().

Here is the caller graph for this function:

Member Data Documentation

template<typename ItemT>
std::vector<pthread_t> TubeConsumerGroup< ItemT >::threads_
private

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