3.3. CopyProcess examples

3.3.1. Add a number of copy jobs and run them in parallel with a progress handler

from XRootD import client

class MyCopyProgressHandler(client.utils.CopyProgressHandler):
  def begin(self, jobId, total, source, target):
    print 'id: %d, total: %d' % (jobId, total)
    print 'source: %s' % source
    print 'target: %s' % target

  def end(self, jobId, result):
    print 'end status:', jobId, result

  def update(self, jobId, processed, total):
    print 'jobId: %d, processed: %d, total: %d' % (jobId, processed, total)

  def should_cancel( jobId ):
    return False

process = client.CopyProcess()

# From local to local
process.add_job( '/tmp/spam', '/tmp/spam1' )
# From local to remote
process.add_job( '/tmp/spam', 'root://localhost//tmp/spam2' )
# From remote to local
process.add_job( 'root://localhost//tmp/spam', '/tmp/spam3' )
# From remote to remote
process.add_job( 'root://localhost//tmp/spam', 'root://localhost//tmp/spam4' )

handler = MyCopyProgressHandler()
process.prepare()
process.run(handler)

Produces output similar to the following:

id: 1, total: 4
source: /tmp/spam
target: /tmp/spam1
processed: 20, total: 20
end status: [SUCCESS]
id: 2, total: 4
source: /tmp/spam
target: root://localhost//tmp/spam2
processed: 20, total: 20
end status: [SUCCESS]
id: 3, total: 4
source: root://localhost//tmp/spam
target: /tmp/spam3
processed: 20, total: 20
end status: [SUCCESS]
id: 4, total: 4
source: root://localhost//tmp/spam
target: root://localhost//tmp/spam4
processed: 20, total: 20
end status: [SUCCESS]