#include <XrdcpXtremeRead.hh>
Public Member Functions | |
| XrdXtRdFile (int blksize, long long filesize) | |
| ~XrdXtRdFile () | |
| bool | AllDone () |
| int | GimmeANewClientIdx () |
| int | GetNBlks () |
| int | GetBlkToPrefetch (int fromidx, int clientIdx, XrdXtRdBlkInfo *&blkreadonly) |
| int | GetBlkToRead (int fromidx, int clientidx, XrdXtRdBlkInfo *&blkreadonly) |
| void | MarkBlkAsRequested (int blkidx) |
| int | MarkBlkAsRead (int blkidx) |
Static Public Member Functions | |
| static int | GetListOfSources (XrdClient *ref, XrdOucString xtrememgr, XrdClientVector< XrdClient * > &clients, int maxSources=12) |
Private Attributes | |
| int | clientidxcnt |
| XrdSysRecMutex | mtx |
| int | freeblks |
| int | nblks |
| int | doneblks |
| XrdXtRdBlkInfo * | blocks |
Constructor & Destructor Documentation
| XrdXtRdFile::XrdXtRdFile | ( | int | blksize, |
| long long | filesize | ||
| ) |
References blocks, clientidxcnt, freeblks, doneblks, nblks, XrdXtRdBlkInfo::offs, XrdXtRdBlkInfo::len, xrdmax, and xrdmin.
| XrdXtRdFile::~XrdXtRdFile | ( | ) |
References blocks.
Member Function Documentation
| bool XrdXtRdFile::AllDone | ( | ) | [inline] |
References mtx, doneblks, and nblks.
Referenced by ReaderThread_xrd_xtreme(), doCp_xrd2xrd(), and doCp_xrd2loc().
| int XrdXtRdFile::GetBlkToPrefetch | ( | int | fromidx, |
| int | clientIdx, | ||
| XrdXtRdBlkInfo *& | blkreadonly | ||
| ) |
References mtx, nblks, blocks, XrdXtRdBlkInfo::requests, XrdClientVector::Push_back(), XrdXtRdBlkInfo::lastrequested, and XrdClientVector::GetSize().
Referenced by ReaderThread_xrd_xtreme().
| int XrdXtRdFile::GetBlkToRead | ( | int | fromidx, |
| int | clientidx, | ||
| XrdXtRdBlkInfo *& | blkreadonly | ||
| ) |
References mtx, nblks, blocks, and XrdXtRdBlkInfo::lastrequested.
Referenced by ReaderThread_xrd_xtreme().
| int XrdXtRdFile::GetListOfSources | ( | XrdClient * | ref, |
| XrdOucString | xtrememgr, | ||
| XrdClientVector< XrdClient * > & | clients, | ||
| int | maxSources = 12 |
||
| ) | [static] |
References XrdOucString::beginswith(), XrdOucString::c_str(), XrdClientAdmin::Locate(), XrdClientAbs::GetCurrentUrl(), XrdClientUrlInfo::File, kXR_nowait, XrdClientVector::GetSize(), maxSources, XrdClientUrlInfo::HostWPort, and XrdClientVector::Push_back().
Referenced by doCp_xrd2xrd(), and doCp_xrd2loc().
| int XrdXtRdFile::GetNBlks | ( | ) | [inline] |
References nblks.
Referenced by doCp_xrd2xrd(), and doCp_xrd2loc().
| int XrdXtRdFile::GimmeANewClientIdx | ( | ) |
References mtx, and clientidxcnt.
Referenced by doCp_xrd2xrd(), and doCp_xrd2loc().
| int XrdXtRdFile::MarkBlkAsRead | ( | int | blkidx | ) |
References mtx, blocks, doneblks, and XrdXtRdBlkInfo::done.
Referenced by ReaderThread_xrd_xtreme().
| void XrdXtRdFile::MarkBlkAsRequested | ( | int | blkidx | ) |
Member Data Documentation
XrdXtRdBlkInfo* XrdXtRdFile::blocks [private] |
Referenced by XrdXtRdFile(), ~XrdXtRdFile(), GetBlkToPrefetch(), GetBlkToRead(), and MarkBlkAsRead().
int XrdXtRdFile::clientidxcnt [private] |
Referenced by XrdXtRdFile(), and GimmeANewClientIdx().
int XrdXtRdFile::doneblks [private] |
Referenced by XrdXtRdFile(), MarkBlkAsRead(), and AllDone().
int XrdXtRdFile::freeblks [private] |
Referenced by XrdXtRdFile().
XrdSysRecMutex XrdXtRdFile::mtx [private] |
Referenced by GimmeANewClientIdx(), GetBlkToPrefetch(), GetBlkToRead(), MarkBlkAsRead(), and AllDone().
int XrdXtRdFile::nblks [private] |
Referenced by XrdXtRdFile(), GetBlkToPrefetch(), GetBlkToRead(), AllDone(), and GetNBlks().
The documentation for this class was generated from the following files:
