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<TubeConsumer<ItemT> *> TubeConsumerGroup< ItemT >::consumers_

private

Definition at line 111 of file task.h.

Referenced by TubeConsumerGroup< FileItem >::Spawn(), TubeConsumerGroup< FileItem >::TakeConsumer(), TubeConsumerGroup< FileItem >::Terminate(), and TubeConsumerGroup< FileItem >::~TubeConsumerGroup().

template<typename ItemT>

bool TubeConsumerGroup< ItemT >::is_active_

private

Definition at line 110 of file task.h.

Referenced by TubeConsumerGroup< FileItem >::is_active(), TubeConsumerGroup< FileItem >::Spawn(), TubeConsumerGroup< FileItem >::TakeConsumer(), and TubeConsumerGroup< FileItem >::Terminate().

template<typename ItemT>

std::vector<pthread_t> TubeConsumerGroup< ItemT >::threads_

private

Definition at line 112 of file task.h.

Referenced by TubeConsumerGroup< FileItem >::Spawn(), and TubeConsumerGroup< FileItem >::Terminate().

---

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

• /home/sftnight/jenkins/workspace/CvmfsDoxygen/label/docker-x86_64/cvmfs/cvmfs/ingestion/task.h