XrdCl::TPFallBackCopyJob Class Reference

#include <XrdClTPFallBackCopyJob.hh>

Inheritance diagram for XrdCl::TPFallBackCopyJob:

Collaboration diagram for XrdCl::TPFallBackCopyJob:

Public Member Functions
	TPFallBackCopyJob (uint32_t jobId, PropertyList *jobProperties, PropertyList *jobResults)
	Constructor.
virtual	~TPFallBackCopyJob ()
	Destructor.
virtual XRootDStatus	Run (CopyProgressHandler *progress=0)
Public Member Functions inherited from XrdCl::CopyJob
	CopyJob (uint32_t jobId, PropertyList *jobProperties, PropertyList *jobResults)
	Constructor.
virtual	~CopyJob ()
	Virtual destructor.
PropertyList *	GetProperties ()
	Get the job properties.
PropertyList *	GetResults ()
	Get the job results.
const URL &	GetSource () const
	Get source.
const URL &	GetTarget () const
	Get target.
void	Init ()

Additional Inherited Members
Protected Attributes inherited from XrdCl::CopyJob
uint32_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	(	uint32_t	jobId,
		PropertyList *	jobProperties,
		PropertyList *	jobResults )

Constructor.

Definition at line 77 of file XrdClTPFallBackCopyJob.cc.

                                                                  :
    CopyJob( jobId, jobProperties, jobResults )
  {
    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::CopyJob::CopyJob(), XrdCl::Log::Debug(), XrdCl::DefaultEnv::GetLog(), XrdCl::CopyJob::GetSource(), XrdCl::CopyJob::GetTarget(), and XrdCl::UtilityMsg.

Referenced by XrdCl::CopyProcess::Prepare().

Here is the call graph for this function:

Here is the caller graph for this function:

~TPFallBackCopyJob()

XrdCl::TPFallBackCopyJob::~TPFallBackCopyJob ( )

virtualdefault

Destructor.

References Run().

Here is the call graph for this function:

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 96 of file XrdClTPFallBackCopyJob.cc.

  {
    //--------------------------------------------------------------------------
    // Set up the job
    //--------------------------------------------------------------------------
    const bool tpcFallBack = pProperties->Get<std::string>( "thirdParty" ) == "first"s;
 
    XRootDStatus st = ThirdPartyCopyJob(pJobId, pProperties, pResults).Run(progress);
    if( st.IsOK() ) return st; // we are done
 
    // try with the plugins
    if (st.code == errNotSupported)
    {
      std::optional<PlugInProgressHandler> progress_handler;
      if( progress )
        progress_handler.emplace( pJobId, *progress );
 
      st = ThirdPartyCopy(GetSource(), GetTarget(), pProperties,
                          progress_handler ? &progress_handler.value() : nullptr);
      if (st.IsOK())
        return st;
    }
 
    // check if we can fall back to streaming
    if( tpcFallBack && ( st.code == errNotSupported || st.code == errNotImplemented || st.code == errOperationExpired ) )
    {
      Log *log = DefaultEnv::GetLog();
      log->Debug( UtilityMsg, "TPC is not supported, falling back to streaming mode." );
 
      return ClassicCopyJob(pJobId, pProperties, pResults).Run(progress);
    }
 
    return st;
  }

References XrdCl::ClassicCopyJob::ClassicCopyJob(), XrdCl::ThirdPartyCopyJob::ThirdPartyCopyJob(), XrdCl::Log::Debug(), XrdCl::errNotImplemented, XrdCl::errNotSupported, XrdCl::errOperationExpired, XrdCl::PropertyList::Get(), XrdCl::DefaultEnv::GetLog(), XrdCl::CopyJob::GetSource(), XrdCl::CopyJob::GetTarget(), XrdCl::CopyJob::pJobId, XrdCl::CopyJob::pProperties, XrdCl::CopyJob::pResults, XrdCl::ThirdPartyCopy(), and XrdCl::UtilityMsg.

Referenced by ~TPFallBackCopyJob().

Here is the call graph for this function:

Here is the caller graph for this function:

---

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

• XrdClTPFallBackCopyJob.hh
• XrdClTPFallBackCopyJob.cc