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 );
bool HasData()
Definition: XrdClXCpSrc.hh:106
XrdSysRecMutex pMtx
Definition: XrdClXCpSrc.hh:339
Definition: XrdSysPthread.hh:241
XRootDStatus Initialize()
uint8_t pParallel
Definition: XrdClXCpSrc.hh:272
static void * Run(void *arg)
Definition: XrdClXCpSrc.hh:37
time_t pTransferTime
Definition: XrdClXCpSrc.hh:362
Definition: XrdClXRootDResponses.hh:946
std::string pUrl
Definition: XrdClXCpSrc.hh:292
time_t pStartTime
Definition: XrdClXCpSrc.hh:356
void UnLock()
Definition: XrdSysPthread.hh:274
A synchronized queue.
Definition: XrdClSyncQueue.hh:32
uint64_t pDataTransfered
Definition: XrdClXCpSrc.hh:314
static void DeletePtr(T *&obj)
Definition: XrdClXCpSrc.hh:231
SyncQueue< XRootDStatus * > pReports
Definition: XrdClXCpSrc.hh:334
static void DeleteChunk(PageInfo *&chunk)
Definition: XrdClXCpSrc.hh:126
friend class ChunkHandler
Definition: XrdClXCpSrc.hh:39
std::map< uint64_t, uint64_t > pOngoing
Definition: XrdClXCpSrc.hh:320
A file.
Definition: XrdClFile.hh:45
uint64_t pBlkEnd
Definition: XrdClXCpSrc.hh:309
File * pFile
Definition: XrdClXCpSrc.hh:297
Definition: XrdClXCpCtx.hh:40
XCpSrc * Self()
Definition: XrdClXCpSrc.hh:87
Request status.
Definition: XrdClXRootDResponses.hh:218
std::map< File *, uint8_t > pFailed
Definition: XrdClXCpSrc.hh:299
void Stop()
Definition: XrdClXCpSrc.hh:63
XCpSrc(uint32_t chunkSize, uint8_t parallel, int64_t fileSize, XCpCtx *ctx)
void ReportResponse(XRootDStatus *status, PageInfo *chunk, File *handle)
void * GetBuffer()
Get the buffer.
bool pUsePgRead
Definition: XrdClXCpSrc.hh:368
bool GetProperty(const std::string &name, std::string &value) const
bool IsRunning()
Definition: XrdClXCpSrc.hh:97
std::map< uint64_t, uint64_t > pRecovered
Definition: XrdClXCpSrc.hh:326
int64_t pFileSize
Definition: XrdClXCpSrc.hh:277
uint32_t pChunkSize
Definition: XrdClXCpSrc.hh:267
size_t pRefCount
Definition: XrdClXCpSrc.hh:344
uint64_t pCurrentOffset
Definition: XrdClXCpSrc.hh:304
bool pRunning
Definition: XrdClXCpSrc.hh:351
XCpCtx * pCtx
Definition: XrdClXCpSrc.hh:287
pthread_t pThread
Definition: XrdClXCpSrc.hh:282
Definition: XrdSysPthread.hh:262
void Delete()
Definition: XrdClXCpSrc.hh:71
XRootDStatus ReadChunks()
static bool FilesEqual(File *f1, File *f2)
Definition: XrdClXCpSrc.hh:243