25#ifndef SRC_XRDCL_XRDCLXCPSRC_HH_
26#define SRC_XRDCL_XRDCLXCPSRC_HH_
53 XCpSrc( uint32_t chunkSize, uint8_t parallel, int64_t fileSize,
XCpCtx *ctx );
130 delete[]
static_cast<char*
>( chunk->
GetBuffer() );
148 static void*
Run(
void* arg );
245 if( !f1 || !f2 )
return false;
247 const std::string lastURL =
"LastURL";
248 std::string url1, url2;
254 size_t pos = url1.find(
'?' );
255 if( pos != std::string::npos )
256 url1 = url1.substr( 0 , pos );
257 pos = url2.find(
'?' );
258 if( pos != std::string::npos )
259 url2 = url2.substr( 0 , pos );
A file.
Definition XrdClFile.hh:46
bool GetProperty(const std::string &name, std::string &value) const
A synchronized queue.
Definition XrdClSyncQueue.hh:33
Definition XrdClXCpCtx.hh:41
Definition XrdClXCpSrc.hh:38
time_t pStartTime
Definition XrdClXCpSrc.hh:356
XrdSysRecMutex pMtx
Definition XrdClXCpSrc.hh:339
std::map< uint64_t, uint64_t > pRecovered
Definition XrdClXCpSrc.hh:326
uint32_t pChunkSize
Definition XrdClXCpSrc.hh:267
bool IsRunning()
Definition XrdClXCpSrc.hh:97
uint64_t pDataTransfered
Definition XrdClXCpSrc.hh:314
File * pFile
Definition XrdClXCpSrc.hh:297
uint64_t pBlkEnd
Definition XrdClXCpSrc.hh:309
static bool FilesEqual(File *f1, File *f2)
Definition XrdClXCpSrc.hh:243
bool pRunning
Definition XrdClXCpSrc.hh:351
void Stop()
Definition XrdClXCpSrc.hh:63
int64_t pFileSize
Definition XrdClXCpSrc.hh:277
size_t pRefCount
Definition XrdClXCpSrc.hh:344
friend class ChunkHandler
Definition XrdClXCpSrc.hh:39
std::map< uint64_t, uint64_t > pOngoing
Definition XrdClXCpSrc.hh:320
void Delete()
Definition XrdClXCpSrc.hh:71
SyncQueue< XRootDStatus * > pReports
Definition XrdClXCpSrc.hh:334
uint8_t pParallel
Definition XrdClXCpSrc.hh:272
static void DeleteChunk(PageInfo *&chunk)
Definition XrdClXCpSrc.hh:126
XCpSrc * Self()
Definition XrdClXCpSrc.hh:87
XCpCtx * pCtx
Definition XrdClXCpSrc.hh:287
static void * Run(void *arg)
uint64_t pCurrentOffset
Definition XrdClXCpSrc.hh:304
std::map< File *, uint8_t > pFailed
Definition XrdClXCpSrc.hh:299
std::string pUrl
Definition XrdClXCpSrc.hh:292
bool pUsePgRead
Definition XrdClXCpSrc.hh:368
XRootDStatus ReadChunks()
XCpSrc(uint32_t chunkSize, uint8_t parallel, int64_t fileSize, XCpCtx *ctx)
void ReportResponse(XRootDStatus *status, PageInfo *chunk, File *handle)
static void DeletePtr(T *&obj)
Definition XrdClXCpSrc.hh:231
time_t pTransferTime
Definition XrdClXCpSrc.hh:362
bool HasData()
Definition XrdClXCpSrc.hh:106
pthread_t pThread
Definition XrdClXCpSrc.hh:282
XRootDStatus Initialize()
Request status.
Definition XrdClXRootDResponses.hh:219
Definition XrdSysPthread.hh:263
void UnLock()
Definition XrdSysPthread.hh:274
Definition XrdSysPthread.hh:242
Definition XrdClAction.hh:34
Definition XrdClXRootDResponses.hh:956
void * GetBuffer()
Get the buffer.