TPC::Stream Class Reference

#include <XrdTpcStream.hh>

Collaboration diagram for TPC::Stream:

Classes
class	Entry

Public Member Functions
	Stream (std::unique_ptr< XrdSfsFile > fh, size_t max_blocks, size_t buffer_size, XrdSysError &log)
	~Stream ()
int	Stat (struct stat *)
int	Read (off_t offset, char *buffer, size_t size)
ssize_t	Write (off_t offset, const char *buffer, size_t size, bool force)
size_t	AvailableBuffers () const
void	DumpBuffers () const
bool	Finalize ()
std::string	GetErrorMessage () const

Private Member Functions
ssize_t	WriteImpl (off_t offset, const char *buffer, size_t size)

Private Attributes
bool	m_open_for_write
size_t	m_avail_count
std::unique_ptr< XrdSfsFile >	m_fh
off_t	m_offset
std::vector< Entry * >	m_buffers
XrdSysError &	m_log
std::string	m_error_buf

Constructor & Destructor Documentation

Stream()

TPC::Stream::Stream ( std::unique_ptr< XrdSfsFile > fh, size_t max_blocks, size_t buffer_size, XrdSysError & log )

inline

References m_buffers, and m_open_for_write.

~Stream()

TPC::Stream::~Stream

(

)

Member Function Documentation

AvailableBuffers()

size_t TPC::Stream::AvailableBuffers ( ) const

inline

References m_avail_count.

DumpBuffers()

void TPC::Stream::DumpBuffers

(

)

const

Finalize()

bool TPC::Stream::Finalize

(

)

GetErrorMessage()

std::string TPC::Stream::GetErrorMessage ( ) const

inline

References m_error_buf.

Read()

int TPC::Stream::Read	(	off_t	offset,
		char *	buffer,
		size_t	size )

Stat()

int TPC::Stream::Stat

(

struct stat *

)

Write()

ssize_t TPC::Stream::Write	(	off_t	offset,
		const char *	buffer,
		size_t	size,
		bool	force )

WriteImpl()

ssize_t TPC::Stream::WriteImpl ( off_t offset, const char * buffer, size_t size )

private

Referenced by TPC::Stream::Entry::Write().

Member Data Documentation

m_avail_count

size_t TPC::Stream::m_avail_count

private

Referenced by AvailableBuffers().

m_buffers

std::vector<Entry*> TPC::Stream::m_buffers

private

Referenced by Stream().

m_error_buf

std::string TPC::Stream::m_error_buf

private

Referenced by GetErrorMessage().

m_fh

std::unique_ptr<XrdSfsFile> TPC::Stream::m_fh

private

m_log

XrdSysError& TPC::Stream::m_log

private

m_offset

off_t TPC::Stream::m_offset

private

Referenced by TPC::Stream::Entry::CanWrite().

m_open_for_write

bool TPC::Stream::m_open_for_write

private

Referenced by Stream().

---

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

• XrdTpcStream.hh