#include <XrdClTPFallBackCopyJob.hh>

Inheritance diagram for XrdCl::TPFallBackCopyJob:

Collaboration diagram for XrdCl::TPFallBackCopyJob:

Public Member Functions
	TPFallBackCopyJob (uint16_t jobId, PropertyList jobProperties, PropertyList jobResults)
	Constructor. More...

virtual	~TPFallBackCopyJob ()
	Destructor. More...

virtual XRootDStatus	Run (CopyProgressHandler *progress=0)

Public Member Functions inherited from XrdCl::CopyJob
	CopyJob (uint16_t jobId, PropertyList jobProperties, PropertyList jobResults)
	Constructor. More...

virtual	~CopyJob ()
	Virtual destructor. More...

PropertyList *	GetProperties ()
	Get the job properties. More...

PropertyList *	GetResults ()
	Get the job results. More...

const URL &	GetSource () const
	Get source. More...

const URL &	GetTarget () const
	Get target. More...

void	Init ()

Additional Inherited Members
Protected Attributes inherited from XrdCl::CopyJob
uint16_t	pJobId

PropertyList *	pProperties

PropertyList *	pResults

URL	pSource

URL	pTarget

Detailed Description

Definition at line 33 of file XrdClTPFallBackCopyJob.hh.

Constructor & Destructor Documentation

◆ TPFallBackCopyJob()

XrdCl::TPFallBackCopyJob::TPFallBackCopyJob	(	uint16_t	jobId,
		PropertyList *	jobProperties,
		PropertyList *	jobResults
	)

Constructor.

Definition at line 38 of file XrdClTPFallBackCopyJob.cc.

                                                                   :
     CopyJob( jobId, jobProperties, jobResults ),
     pJob( 0 )
   {
     Log *log = DefaultEnv::GetLog();
     log->Debug( UtilityMsg, "Creating a third party fall back copy job, "
                 "from %s to %s", GetSource().GetObfuscatedURL().c_str(),
                 GetTarget().GetObfuscatedURL().c_str() );
   }

References XrdCl::Log::Debug(), XrdCl::DefaultEnv::GetLog(), XrdCl::CopyJob::GetSource(), XrdCl::CopyJob::GetTarget(), and XrdCl::UtilityMsg.

Here is the call graph for this function:

◆ ~TPFallBackCopyJob()

XrdCl::TPFallBackCopyJob::~TPFallBackCopyJob ( )

virtual

Destructor.

Definition at line 53 of file XrdClTPFallBackCopyJob.cc.

   {
     delete pJob;
   }

Member Function Documentation

◆ Run()

XRootDStatus XrdCl::TPFallBackCopyJob::Run ( CopyProgressHandler * progress = 0 )

virtual

Run the copy job

Parameters

progress the handler to be notified about the copy progress

Returns: status of the copy operation

Implements XrdCl::CopyJob.

Definition at line 61 of file XrdClTPFallBackCopyJob.cc.

   {
     //--------------------------------------------------------------------------
     // Set up the job
     //--------------------------------------------------------------------------
     std::string  tmp;
     bool         tpcFallBack = false;
  
     pProperties->Get( "thirdParty", tmp );
     if( tmp == "first" )
       tpcFallBack = true;
  
     pJob = new ThirdPartyCopyJob( pJobId, pProperties, pResults );
     XRootDStatus st = pJob->Run( progress );
     if( st.IsOK() ) return st; // we are done
  
     // check if we can fall back to streaming
     if( tpcFallBack && ( st.code == errNotSupported || st.code == errOperationExpired ) )
     {
       Log *log = DefaultEnv::GetLog();
       log->Debug( UtilityMsg, "TPC is not supported, falling back to streaming mode." );
  
       delete pJob;
       pJob = new ClassicCopyJob( pJobId, pProperties, pResults );
       return pJob->Run( progress );
     }
  
     return st;
   }

References XrdCl::Status::code, XrdCl::Log::Debug(), XrdCl::errNotSupported, XrdCl::errOperationExpired, XrdCl::PropertyList::Get(), XrdCl::DefaultEnv::GetLog(), XrdCl::Status::IsOK(), XrdCl::CopyJob::pJobId, XrdCl::CopyJob::pProperties, XrdCl::CopyJob::pResults, XrdCl::CopyJob::Run(), and XrdCl::UtilityMsg.