1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
"""
Add a number of copy jobs and run them in parallel with a progress 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]
"""
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)
|
