XrdCl::ThirdPartyCopyJob Class Reference

#include <XrdClThirdPartyCopyJob.hh>

Inheritance diagram for XrdCl::ThirdPartyCopyJob:

Collaboration diagram for XrdCl::ThirdPartyCopyJob:

Public Member Functions
	ThirdPartyCopyJob (uint16_t jobId, PropertyList *jobProperties, PropertyList *jobResults)
	Constructor.
virtual XRootDStatus	Run (CopyProgressHandler *progress=0)
Public Member Functions inherited from XrdCl::CopyJob
	CopyJob (uint16_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
uint16_t	pJobId
PropertyList *	pProperties
PropertyList *	pResults
URL	pSource
URL	pTarget

Detailed Description

Definition at line 30 of file XrdClThirdPartyCopyJob.hh.

Constructor & Destructor Documentation

ThirdPartyCopyJob()

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

Constructor.

Definition at line 156 of file XrdClThirdPartyCopyJob.cc.

                                                                  :
    CopyJob( jobId, jobProperties, jobResults ),
    dstFile( File::DisableVirtRedirect ),
    sourceSize( 0 ),
    initTimeout( 0 ),
    force( false ),
    coerce( false ),
    delegate( false ),
    nbStrm( 0 ),
    tpcLite( false )
  {
    Log *log = DefaultEnv::GetLog();
    log->Debug( UtilityMsg, "Creating a third party 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:

Member Function Documentation

Run()

XRootDStatus XrdCl::ThirdPartyCopyJob::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 177 of file XrdClThirdPartyCopyJob.cc.

  {
    Log *log = DefaultEnv::GetLog();
 
    XRootDStatus st = CanDo();
    if( !st.IsOK() ) return st;
 
    if( tpcLite )
    {
      //------------------------------------------------------------------------
      // Run TPC-lite algorithm
      //------------------------------------------------------------------------
      XRootDStatus st = RunLite( progress );
      if( !st.IsOK() ) return st;
    }
    else
    {
      //------------------------------------------------------------------------
      // Run vanilla TPC algorithm
      //------------------------------------------------------------------------
      XRootDStatus st = RunTPC( progress );
      if( !st.IsOK() ) return st;
    }
 
    //--------------------------------------------------------------------------
    // Verify the checksums if needed
    //--------------------------------------------------------------------------
    if( checkSumMode != "none" )
    {
      log->Debug( UtilityMsg, "Attempting checksum calculation." );
      std::string sourceCheckSum;
      std::string targetCheckSum;
 
      //------------------------------------------------------------------------
      // Get the check sum at source
      //------------------------------------------------------------------------
      timeval oStart, oEnd;
      XRootDStatus st;
      if( checkSumMode == "end2end" || checkSumMode == "source" ||
          !checkSumPreset.empty() )
      {
        gettimeofday( &oStart, 0 );
        if( !checkSumPreset.empty() )
        {
          sourceCheckSum  = checkSumType + ":";
          sourceCheckSum += Utils::NormalizeChecksum( checkSumType,
                                                      checkSumPreset );
        }
        else
        {
          VirtualRedirector *redirector = 0;
          std::string vrCheckSum;
          if( GetSource().IsMetalink() &&
              ( redirector = RedirectorRegistry::Instance().Get( GetSource() ) ) &&
              !( vrCheckSum = redirector->GetCheckSum( checkSumType ) ).empty() )
            sourceCheckSum = vrCheckSum;
          else
            st = Utils::GetRemoteCheckSum( sourceCheckSum, checkSumType, tpcSource );
        }
        gettimeofday( &oEnd, 0 );
        if( !st.IsOK() )
          return UpdateErrMsg( st, "source" );
 
        pResults->Set( "sourceCheckSum", sourceCheckSum );
      }
 
      //------------------------------------------------------------------------
      // Get the check sum at destination
      //------------------------------------------------------------------------
      timeval tStart, tEnd;
 
      if( checkSumMode == "end2end" || checkSumMode == "target" )
      {
        gettimeofday( &tStart, 0 );
        st = Utils::GetRemoteCheckSum( targetCheckSum, checkSumType, realTarget );
 
        gettimeofday( &tEnd, 0 );
        if( !st.IsOK() )
          return UpdateErrMsg( st, "destination" );
        pResults->Set( "targetCheckSum", targetCheckSum );
      }
 
      //------------------------------------------------------------------------
      // Make sure the checksums are both lower case
      //------------------------------------------------------------------------
      auto sanitize_cksum = []( char c )
                            {
                              std::locale loc;
                              if( std::isalpha( c ) ) return std::tolower( c, loc );
                              return c;
                            };
 
      std::transform( sourceCheckSum.begin(), sourceCheckSum.end(),
                      sourceCheckSum.begin(), sanitize_cksum );
 
      std::transform( targetCheckSum.begin(), targetCheckSum.end(),
                      targetCheckSum.begin(), sanitize_cksum );
 
      //------------------------------------------------------------------------
      // Compare and inform monitoring
      //------------------------------------------------------------------------
      if( !sourceCheckSum.empty() && !targetCheckSum.empty() )
      {
        bool match = false;
        if( sourceCheckSum == targetCheckSum )
          match = true;
 
        Monitor *mon = DefaultEnv::GetMonitor();
        if( mon )
        {
          Monitor::CheckSumInfo i;
          i.transfer.origin = &GetSource();
          i.transfer.target = &GetTarget();
          i.cksum           = sourceCheckSum;
          i.oTime           = Utils::GetElapsedMicroSecs( oStart, oEnd );
          i.tTime           = Utils::GetElapsedMicroSecs( tStart, tEnd );
          i.isOK            = match;
          mon->Event( Monitor::EvCheckSum, &i );
        }
 
        if( !match )
          return XRootDStatus( stError, errCheckSumError, 0 );
 
        log->Info(UtilityMsg, "Checksum verification: succeeded." );
      }
    }
 
    return XRootDStatus();
  }

References XrdCl::Monitor::CheckSumInfo::cksum, XrdCl::Log::Debug(), XrdCl::errCheckSumError, XrdCl::Monitor::EvCheckSum, XrdCl::Monitor::Event(), XrdCl::VirtualRedirector::GetCheckSum(), XrdCl::Utils::GetElapsedMicroSecs(), XrdCl::DefaultEnv::GetLog(), XrdCl::DefaultEnv::GetMonitor(), XrdCl::Utils::GetRemoteCheckSum(), XrdCl::CopyJob::GetSource(), XrdCl::CopyJob::GetTarget(), XrdCl::Log::Info(), XrdCl::RedirectorRegistry::Instance(), XrdCl::Monitor::CheckSumInfo::isOK, XrdCl::Status::IsOK(), XrdCl::Utils::NormalizeChecksum(), XrdCl::Monitor::TransferInfo::origin, XrdCl::Monitor::CheckSumInfo::oTime, XrdCl::CopyJob::pResults, XrdCl::PropertyList::Set(), XrdCl::stError, XrdCl::Monitor::TransferInfo::target, XrdCl::Monitor::CheckSumInfo::transfer, XrdCl::Monitor::CheckSumInfo::tTime, and XrdCl::UtilityMsg.

Here is the call graph for this function:

---

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

• XrdClThirdPartyCopyJob.hh
• XrdClThirdPartyCopyJob.cc