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 );
114 std::pair<uint64_t, uint64_t>
GetBlock();
132 while( pFileSize < 0 && GetRunning() > 0 ) pFileSizeCV.
Wait();
170 pSources.remove( src );
223 std::queue<std::string> pUrls;
233 uint8_t pParallelSrc;
243 uint8_t pParallelChunks;
267 std::list<XCpSrc*> pSources;
278 uint64_t pDataReceived;
void NotifyInitExpectant()
bool GetNextUrl(std::string &url)
void RemoveSrc(XCpSrc *src)
XCpSrc * WeakestLink(XCpSrc *exclude)
void PutChunk(PageInfo *chunk)
XCpCtx(const std::vector< std::string > &urls, uint64_t blockSize, uint8_t parallelSrc, uint64_t chunkSize, uint64_t parallelChunks, int64_t fileSize)
void SetFileSize(int64_t size)
std::pair< uint64_t, uint64_t > GetBlock()
XRootDStatus Initialize()
XRootDStatus GetChunk(XrdCl::PageInfo &ci)