6 |
|
#--------------------------------------------------------------------------------------------------- |
7 |
|
import os,sys,getopt,re |
8 |
|
import srm |
9 |
+ |
user = os.environ['TICKET_HOLDER'] |
10 |
+ |
t2user = os.environ['TIER2_USER'] |
11 |
|
|
12 |
|
def debugPrint(text): |
13 |
|
if debug ==1: |
29 |
|
def exists(target): |
30 |
|
if re.search('/castor/cern.ch/',target): |
31 |
|
debugPrint(' Identified a castor directory: ' + target) |
32 |
< |
cmd = 'ssh paus@lxplus.cern.ch rfdir ' + target + '>& /dev/null' |
32 |
> |
cmd = 'ssh ' + t2user + '@lxplus.cern.ch rfdir ' + target + '>& /dev/null' |
33 |
|
elif re.search('/pnfs/cmsaf.mit.edu/',target): |
34 |
|
debugPrint(' Identified a tier-2 directory: ' + target) |
35 |
< |
cmd = 'ssh -x paus@cgate.mit.edu ls -1 ' + target + ' \>\& /dev/null' |
35 |
> |
cmd = 'ssh ' + t2user + '@cgate.mit.edu ls -1 ' + target + ' \>\& /dev/null' |
36 |
|
elif re.search('/mnt/hadoop/cms/store',target): |
37 |
|
debugPrint(' Identified a tier-2 directory: ' + target) |
38 |
< |
cmd = 'ssh -x paus@se01.cmsaf.mit.edu ls -1 ' + target + ' \>\& /dev/null' |
38 |
> |
cmd = 'ssh ' + t2user + '@se01.cmsaf.mit.edu ls -1 ' + target + ' \>\& /dev/null' |
39 |
|
else: |
40 |
|
debugPrint(' Identified a normal directory: ' + target) |
41 |
|
cmd = 'ls -1 ' + target + '>\& /dev/null' |
48 |
|
def move(source,target): |
49 |
|
if re.search('/castor/cern.ch/',source) and re.search('/castor/cern.ch/',target): |
50 |
|
debugPrint(' Identified two castor directories') |
51 |
< |
cmd = 'ssh paus@lxplus.cern.ch nsrename ' + source + ' ' + target |
51 |
> |
cmd = 'ssh ' + user + '@lxplus.cern.ch nsrename ' + source + ' ' + target |
52 |
|
elif re.search('/pnfs/cmsaf.mit.edu/',source) and re.search('/pnfs/cmsaf.mit.edu/',target): |
53 |
|
debugPrint(' Identified two tier-2 directories') |
54 |
< |
cmd = 'ssh -x paus@cgate.mit.edu mv ' + source + ' ' + target |
54 |
> |
cmd = 'ssh ' + t2user + '@cgate.mit.edu mv ' + source + ' ' + target |
55 |
|
elif re.search('/mnt/hadoop/cms/store',target): |
56 |
|
urlSource = srm.convertToUrl(source,False) |
57 |
|
urlTarget = srm.convertToUrl(target,False) |
58 |
|
cmd = 'srmmv ' + urlSource + ' ' + urlTarget + ' >& /dev/null' |
59 |
|
cmd = 'glexec mv ' + source + ' ' + target ## + ' >& /dev/null' |
60 |
|
#debugPrint(' Identified a tier-2 directory: ' + target) |
61 |
< |
#cmd = 'ssh -x paus@se01.cmsaf.mit.edu ls -1 ' + target + ' \>\& /dev/null' |
61 |
> |
#cmd = 'ssh ' + t2user + '@se01.cmsaf.mit.edu ls -1 ' + target + ' \>\& /dev/null' |
62 |
|
else: |
63 |
|
debugPrint(' Identified a normal directory') |
64 |
|
cmd = 'mv ' + source + ' ' + target |