TaskRead Class Reference

#include <task_read.h>

Inheritance diagram for TaskRead:

Collaboration diagram for TaskRead:

Public Member Functions
	TaskRead (Tube< FileItem > *tube_in, TubeGroup< BlockItem > *tubes_out, ItemAllocator *allocator)
void	SetWatermarks (uint64_t low, uint64_t high)
uint64_t	n_block ()
Public Member Functions inherited from TubeConsumer< FileItem >
virtual	~TubeConsumer ()

Static Public Attributes
static const unsigned	kThrottleInitMs = 50
static const unsigned	kThrottleMaxMs = 500
static const unsigned	kThrottleResetMs = 2000
static const unsigned	kBlockSize = kPageSize * 4

Protected Member Functions
virtual void	Process (FileItem *item)
Protected Member Functions inherited from TubeConsumer< FileItem >
	TubeConsumer (Tube< FileItem > *tube)
virtual void	OnTerminate ()

Private Attributes
TubeGroup< BlockItem > *	tubes_out_
ItemAllocator *	allocator_
uint64_t	low_watermark_
uint64_t	high_watermark_
atomic_int64	n_block_

Static Private Attributes
static atomic_int64	tag_seq_ = 0

Additional Inherited Members
Protected Attributes inherited from TubeConsumer< FileItem >
Tube< FileItem > *	tube_

Detailed Description

Definition at line 18 of file task_read.h.

Constructor & Destructor Documentation

TaskRead::TaskRead ( Tube< FileItem > *  tube_in, TubeGroup< BlockItem > *  tubes_out, ItemAllocator *  allocator  )

inline

Definition at line 25 of file task_read.h.

Member Function Documentation

uint64_t TaskRead::n_block ( )

inline

Definition at line 38 of file task_read.h.

void TaskRead::Process ( FileItem *  item )

protectedvirtual

Implements TubeConsumer< FileItem >.

Definition at line 24 of file task_read.cc.

Here is the call graph for this function:

void TaskRead::SetWatermarks	(	uint64_t	low,
		uint64_t	high
	)

Definition at line 80 of file task_read.cc.

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

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

ItemAllocator* TaskRead::allocator_

private

Definition at line 51 of file task_read.h.

Referenced by Process().

uint64_t TaskRead::high_watermark_

private

Stop reading new data into the pipeline when the amount BlockItem managed byte is higher than the given level.

Definition at line 61 of file task_read.h.

Referenced by Process(), and SetWatermarks().

const unsigned TaskRead::kBlockSize = kPageSize * 4

static

Definition at line 23 of file task_read.h.

Referenced by Process().

const unsigned TaskRead::kThrottleInitMs = 50

static

Definition at line 20 of file task_read.h.

Referenced by Process().

const unsigned TaskRead::kThrottleMaxMs = 500

static

Definition at line 21 of file task_read.h.

Referenced by Process().

const unsigned TaskRead::kThrottleResetMs = 2000

static

Definition at line 22 of file task_read.h.

Referenced by Process().

uint64_t TaskRead::low_watermark_

private

Continue reading once the amount of BlockItem managed bytes is back to the given level.

Definition at line 56 of file task_read.h.

Referenced by Process(), and SetWatermarks().

atomic_int64 TaskRead::n_block_

private

Number of times reading was blocked on a high watermark.

Definition at line 65 of file task_read.h.

Referenced by n_block(), Process(), and TaskRead().

atomic_int64 TaskRead::tag_seq_ = 0

staticprivate

Every new file increases the tag sequence counter that is used to annotate BlockItems.

This file is part of the CernVM File System.

Definition at line 48 of file task_read.h.

Referenced by Process().

TubeGroup<BlockItem>* TaskRead::tubes_out_

private

Definition at line 50 of file task_read.h.

Referenced by Process().

---

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

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