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:33
Definition XrdClXCpCtx.hh:41
void Delete()
Definition XrdClXCpCtx.hh:61
SyncQueue< PageInfo * > pSink
Definition XrdClXCpCtx.hh:273
void NotifyInitExpectant()
Definition XrdClXCpCtx.hh:197
XrdSysCondVar pFileSizeCV
Definition XrdClXCpCtx.hh:261
bool GetNextUrl(std::string &url)
uint32_t pChunkSize
Definition XrdClXCpCtx.hh:238
uint64_t pDataReceived
Definition XrdClXCpCtx.hh:278
uint8_t pParallelChunks
Definition XrdClXCpCtx.hh:243
void RemoveSrc(XCpSrc *src)
Definition XrdClXCpCtx.hh:167
XCpSrc * WeakestLink(XCpSrc *exclude)
void PutChunk(PageInfo *chunk)
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
void SetFileSize(int64_t size)
int64_t pFileSize
Definition XrdClXCpCtx.hh:255
std::pair< uint64_t, uint64_t > GetBlock()
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 Initialize()
XCpCtx * Self()
Definition XrdClXCpCtx.hh:77
XRootDStatus GetChunk(XrdCl::PageInfo &ci)
uint64_t pBlockSize
Definition XrdClXCpCtx.hh:228
bool pDone
Definition XrdClXCpCtx.hh:284
Definition XrdClXCpSrc.hh:38
Request status.
Definition XrdClXRootDResponses.hh:219
Definition XrdSysPthread.hh:129
Definition XrdSysPthread.hh:79
void Broadcast()
Definition XrdSysPthread.hh:89
Definition XrdSysPthread.hh:263
void UnLock()
Definition XrdSysPthread.hh:274
Definition XrdSysPthread.hh:165
Definition XrdClAction.hh:34
Definition XrdClXRootDResponses.hh:956