XrdCl::XCpSrc Class Reference

#include <XrdClXCpSrc.hh>

Collaboration diagram for XrdCl::XCpSrc:

Public Member Functions
	XCpSrc (uint32_t chunkSize, uint8_t parallel, int64_t fileSize, XCpCtx *ctx)
void	Delete ()
bool	HasData ()
bool	IsRunning ()
XCpSrc *	Self ()
int	Start ()
void	Stop ()
uint64_t	TransferRate ()

Static Public Member Functions
static void	DeleteChunk (PageInfo *&chunk)

Friends
class	ChunkHandler

Detailed Description

Definition at line 39 of file XrdClXCpSrc.hh.

Constructor & Destructor Documentation

XCpSrc()

XrdCl::XCpSrc::XCpSrc	(	uint32_t	chunkSize,
		uint8_t	parallel,
		int64_t	fileSize,
		XCpCtx *	ctx
	)

Constructor.

Parameters

chunkSize	: default chunk size
parallel	: number of parallel chunks
fileSize	: file size if available (e.g. in metalink file), should be set to -1 if not available, in this case a stat will be performed during initialization
ctx	: Extreme Copy context

Definition at line 110 of file XrdClXCpSrc.cc.

                                                                                    :
  pChunkSize( chunkSize ), pParallel( parallel ), pFileSize( fileSize ), pThread(),
  pCtx( ctx->Self() ), pFile( 0 ), pCurrentOffset( 0 ), pBlkEnd( 0 ), pDataTransfered( 0 ), pRefCount( 1 ),
  pRunning( false ), pStartTime( 0 ), pTransferTime( 0 ), pUsePgRead( false )
{
}

Member Function Documentation

Delete()

void XrdCl::XCpSrc::Delete ( )

inline

Deletes the instance if the reference counter reached 0.

Definition at line 73 of file XrdClXCpSrc.hh.

    {
      XrdSysMutexHelper lck( pMtx );
      --pRefCount;
      if( !pRefCount )
      {
        lck.UnLock();
        delete this;
      }
    }

References XrdSysMutexHelper::UnLock().

Referenced by XrdCl::ChunkHandler::~ChunkHandler().

Here is the call graph for this function:

Here is the caller graph for this function:

DeleteChunk()

static void XrdCl::XCpSrc::DeleteChunk ( PageInfo *&  chunk )

inlinestatic

Delete ChunkInfo object, and set the pointer to null.

Parameters

chunk

: the chunk to be deleted

Definition at line 131 of file XrdClXCpSrc.hh.

    {
      if( chunk )
      {
        delete[] static_cast<char*>( chunk->GetBuffer() );
        delete   chunk;
        chunk = 0;
      }
    }

References XrdCl::PageInfo::GetBuffer().

Here is the call graph for this function:

HasData()

bool XrdCl::XCpSrc::HasData ( )

inline

Returns

true if the source has a block of non zero size / some chunks allocated, false otherwise

Definition at line 111 of file XrdClXCpSrc.hh.

    {
      XrdSysMutexHelper lck( pMtx );
      return pCurrentOffset < pBlkEnd || !pRecovered.empty() || !pOngoing.empty();
    }

Referenced by XrdCl::XCpCtx::WeakestLink().

Here is the caller graph for this function:

IsRunning()

bool XrdCl::XCpSrc::IsRunning ( )

inline

Returns

: true if the thread is running, false otherwise

Definition at line 102 of file XrdClXCpSrc.hh.

    {
      return pRunning;
    }

Self()

XCpSrc* XrdCl::XCpSrc::Self ( )

inline

Increments the reference counter.

Returns

: myself.

Definition at line 89 of file XrdClXCpSrc.hh.

    {
      XrdSysMutexHelper lck( pMtx );
      // if Ctx is trying to increase our ref count it is possible
      // we are already in our destrutor, waiting for RemoveSrc().
      if( !pRefCount ) return nullptr;
      ++pRefCount;
      return this;
    }

Referenced by XrdCl::XCpCtx::WeakestLink().

Here is the caller graph for this function:

Start()

int XrdCl::XCpSrc::Start

(

)

Creates new thread with XCpSrc::Run as the start routine.

Definition at line 125 of file XrdClXCpSrc.cc.

{
  pRunning = true;
  int rc = pthread_create( &pThread, 0, Run, this );
  if( rc ) pRunning = false;
  return rc;
}

Stop()

void XrdCl::XCpSrc::Stop ( )

inline

Stops the thread.

Definition at line 65 of file XrdClXCpSrc.hh.

    {
      pRunning = false;
    }

TransferRate()

uint64_t XrdCl::XCpSrc::TransferRate

(

)

Get the transfer rate for current source

Returns

: transfer rate for current source [B/s]

Definition at line 596 of file XrdClXCpSrc.cc.

{
  time_t duration = pTransferTime + time( 0 ) - pStartTime;
  return pDataTransfered / ( duration + 1 ); // add one to avoid floating point exception
}

Referenced by XrdCl::XCpCtx::WeakestLink().

Here is the caller graph for this function:

Friends And Related Function Documentation

ChunkHandler

friend class ChunkHandler

friend

Definition at line 41 of file XrdClXCpSrc.hh.

---

The documentation for this class was generated from the following files:

• XrdClXCpSrc.hh
• XrdClXCpSrc.cc