#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 () |
| std::string | GetErrorMessage () const |
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 |
| 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 | ( | ) |
| std::string TPC::Stream::GetErrorMessage | ( | ) | const [inline] |
References m_error_buf.
| 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::string TPC::Stream::m_error_buf [private] |
Referenced by GetErrorMessage().
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().
1.6.1