xrootd: XrdEc::WrtBuff Class Reference

#include <XrdEcWrtBuff.hh>

Collaboration diagram for XrdEc::WrtBuff:

Collaboration graph

Public Member Functions
	WrtBuff (const ObjCfg &objcfg)

	WrtBuff (WrtBuff &&wrtbuff)
	Move constructor. More...

	~WrtBuff ()

uint32_t	Write (uint32_t size, const char *buffer)

void	Pad (uint32_t size)

char *	GetStrpBuff (uint8_t strpnb)

uint32_t	GetStrpSize (uint8_t strp)

uint32_t	GetBlkSize ()
	Get size of the data in the buffer. More...

bool	Complete ()
	True if the buffer if full, false otherwise. More...

bool	Empty ()
	True if there are no data in the buffer, false otherwise. More...

void	Encode ()
	Calculate the parity for the data stripes and the crc32cs. More...

uint32_t	GetCrc32c (size_t strpnb)

Private Attributes
ObjCfg	objcfg

XrdCl::Buffer	wrtbuff

stripes_t	stripes

std::vector< std::future < uint32_t > >	cksums

Detailed Description

Write cache, accumulates full block and then calculates parity and all of it to the storage

Constructor & Destructor Documentation

XrdEc::WrtBuff::WrtBuff ( const ObjCfg & objcfg )

inline

Constructor

Parameters

objcfg : data object configuration

References XrdCl::Buffer::GetBuffer(), XrdCl::Buffer::GetSize(), XrdEc::ObjCfg::nbchunks, stripes, and wrtbuff.

XrdEc::WrtBuff::WrtBuff ( WrtBuff && wrtbuff )

inline

Move constructor.

XrdEc::WrtBuff::~WrtBuff ( )

inline

References XrdEc::BufferPool::Instance(), XrdEc::BufferPool::Recycle(), and wrtbuff.

Member Function Documentation

bool XrdEc::WrtBuff::Complete ( )

inline

True if the buffer if full, false otherwise.

References XrdEc::ObjCfg::datasize, XrdCl::Buffer::GetCursor(), objcfg, and wrtbuff.

bool XrdEc::WrtBuff::Empty ( )

inline

True if there are no data in the buffer, false otherwise.

References XrdCl::Buffer::GetCursor(), XrdCl::Buffer::GetSize(), and wrtbuff.

void XrdEc::WrtBuff::Encode ( )

inline

Calculate the parity for the data stripes and the crc32cs.

References XrdEc::ObjCfg::chunksize, cksums, XrdEc::RedundancyProvider::compute(), XrdEc::ObjCfg::digest, XrdEc::ThreadPool::Execute(), XrdCl::Buffer::GetBuffer(), XrdEc::Config::GetRedundancy(), GetStrpSize(), XrdEc::Config::Instance(), XrdEc::ThreadPool::Instance(), XrdEc::ObjCfg::nbchunks, XrdEc::ObjCfg::nbdata, objcfg, stripes, and wrtbuff.

uint32_t XrdEc::WrtBuff::GetBlkSize ( )

inline

Get size of the data in the buffer.

References XrdCl::Buffer::GetCursor(), and wrtbuff.

uint32_t XrdEc::WrtBuff::GetCrc32c ( size_t strpnb )

inline

Calculate the crc32c for given data stripe

Parameters

strpnb : number of the stripe

Returns: : the crc32c of the data stripe

References cksums.

char* XrdEc::WrtBuff::GetStrpBuff ( uint8_t strpnb )

inline

Return buffer corresponding to given stripe

Parameters

strpnb : number of the stripe

References stripes.

uint32_t XrdEc::WrtBuff::GetStrpSize ( uint8_t strp )

inline

Return size of the data in the given stripe

Parameters

strp	: number of the stripe

References XrdEc::ObjCfg::chunksize, XrdCl::Buffer::GetCursor(), XrdEc::ObjCfg::nbdata, objcfg, and wrtbuff.

Referenced by Encode().

void XrdEc::WrtBuff::Pad ( uint32_t size )

inline

Pad the buffer with zeros.

Parameters

size	: number of zeros to be written into the buffer

References XrdCl::Buffer::AdvanceCursor(), XrdCl::Buffer::Allocate(), XrdEc::ObjCfg::datasize, XrdCl::Buffer::GetBuffer(), XrdCl::Buffer::GetSize(), objcfg, XrdCl::Buffer::SetCursor(), and wrtbuff.

uint32_t XrdEc::WrtBuff::Write	(	uint32_t	size,
		const char *	buffer
	)

inline

Write data into the buffer

Parameters

size	: number of bytes to be written
buffer	: buffer with data to be written

Returns: : number of bytes accepted by the buffer

References XrdCl::Buffer::AdvanceCursor(), XrdEc::ObjCfg::datasize, XrdCl::Buffer::GetBufferAtCursor(), XrdCl::Buffer::GetCursor(), objcfg, and wrtbuff.

Member Data Documentation

std::vector<std::future<uint32_t> > XrdEc::WrtBuff::cksums

private

Referenced by Encode(), and GetCrc32c().

ObjCfg XrdEc::WrtBuff::objcfg

private

Referenced by Complete(), Encode(), GetStrpSize(), Pad(), and Write().

stripes_t XrdEc::WrtBuff::stripes

private

Referenced by Encode(), GetStrpBuff(), and WrtBuff().

XrdCl::Buffer XrdEc::WrtBuff::wrtbuff

private

Referenced by Complete(), Empty(), Encode(), GetBlkSize(), GetStrpSize(), Pad(), Write(), WrtBuff(), and ~WrtBuff().

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

XrdEcWrtBuff.hh