25 #ifndef SRC_XRDCL_XRDCLXCPCTX_HH_
26 #define SRC_XRDCL_XRDCLXCPCTX_HH_
56 XCpCtx(
const std::vector<std::string> &urls, uint64_t blockSize, uint8_t parallelSrc, uint64_t chunkSize, uint64_t parallelChunks, int64_t fileSize );
A synchronized queue.
Definition: XrdClSyncQueue.hh:34
Definition: XrdClXCpCtx.hh:41
void Delete()
Definition: XrdClXCpCtx.hh:61
void NotifyInitExpectant()
Definition: XrdClXCpCtx.hh:197
std::pair< uint64_t, uint64_t > GetBlock()
XrdSysCondVar pFileSizeCV
Definition: XrdClXCpCtx.hh:261
bool GetNextUrl(std::string &url)
uint32_t pChunkSize
Definition: XrdClXCpCtx.hh:238
void PutChunk(ChunkInfo *chunk)
uint64_t pDataReceived
Definition: XrdClXCpCtx.hh:278
uint8_t pParallelChunks
Definition: XrdClXCpCtx.hh:243
void RemoveSrc(XCpSrc *src)
Definition: XrdClXCpCtx.hh:167
XCpCtx * Self()
Definition: XrdClXCpCtx.hh:77
uint64_t pOffset
Definition: XrdClXCpCtx.hh:250
XCpCtx(const std::vector< std::string > &urls, uint64_t blockSize, uint8_t parallelSrc, uint64_t chunkSize, uint64_t parallelChunks, int64_t fileSize)
int64_t GetSize()
Definition: XrdClXCpCtx.hh:129
XCpSrc * WeakestLink(XCpSrc *exclude)
void SetFileSize(int64_t size)
int64_t pFileSize
Definition: XrdClXCpCtx.hh:255
size_t pRefCount
Definition: XrdClXCpCtx.hh:300
std::queue< std::string > pUrls
Definition: XrdClXCpCtx.hh:223
std::list< XCpSrc * > pSources
Definition: XrdClXCpCtx.hh:267
XrdSysMutex pMtx
Definition: XrdClXCpCtx.hh:295
XrdSysCondVar pDoneCV
Definition: XrdClXCpCtx.hh:290
uint8_t pParallelSrc
Definition: XrdClXCpCtx.hh:233
XRootDStatus GetChunk(XrdCl::ChunkInfo &ci)
XRootDStatus Initialize()
SyncQueue< ChunkInfo * > pSink
Definition: XrdClXCpCtx.hh:273
uint64_t pBlockSize
Definition: XrdClXCpCtx.hh:228
bool pDone
Definition: XrdClXCpCtx.hh:284
Definition: XrdClXCpSrc.hh:38
Request status.
Definition: XrdClXRootDResponses.hh:215
Definition: XrdSysPthread.hh:130
Definition: XrdSysPthread.hh:79
void Broadcast()
Definition: XrdSysPthread.hh:89
Definition: XrdSysPthread.hh:261
void UnLock()
Definition: XrdSysPthread.hh:272
Definition: XrdSysPthread.hh:166
Definition: XrdClAnyObject.hh:26
Describe a data chunk for vector read.
Definition: XrdClXRootDResponses.hh:889