#include <XrdTpcStream.hh>
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) |
int | Write (off_t offset, const char *buffer, size_t size) |
size_t | AvailableBuffers () const |
void | DumpBuffers () const |
bool | Finalize () |
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 |
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.
TPC::Stream::~Stream | ( | ) |
size_t TPC::Stream::AvailableBuffers | ( | ) | const [inline] |
References m_avail_count.
void TPC::Stream::DumpBuffers | ( | ) | const |
bool TPC::Stream::Finalize | ( | ) |
int TPC::Stream::Read | ( | off_t | offset, | |
char * | buffer, | |||
size_t | size | |||
) |
int TPC::Stream::Stat | ( | struct stat * | ) |
int TPC::Stream::Write | ( | off_t | offset, | |
const char * | buffer, | |||
size_t | size | |||
) |
Referenced by TPC::Stream::Entry::Write().
size_t TPC::Stream::m_avail_count [private] |
Referenced by AvailableBuffers().
std::vector<Entry*> TPC::Stream::m_buffers [private] |
Referenced by Stream().
std::unique_ptr<XrdSfsFile> TPC::Stream::m_fh [private] |
XrdSysError& TPC::Stream::m_log [private] |
off_t TPC::Stream::m_offset [private] |
Referenced by TPC::Stream::Entry::CanWrite().
bool TPC::Stream::m_open_for_write [private] |
Referenced by Stream().