5 |
|
# Author: C.Paus (May 06, 2010) |
6 |
|
#--------------------------------------------------------------------------------------------------- |
7 |
|
import os,sys,getopt,re,srm |
8 |
+ |
t2user = os.environ['TIER2_USER'] |
9 |
|
|
10 |
|
def debugPrint(text): |
11 |
|
if debug: |
32 |
|
cmd = 'rfdir ' + target |
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 hadoop directory: ' + target) |
38 |
|
target = srm.convertToUrl(target,debug) |
52 |
|
cmd = "stager_rm -M " + source + "; nsrm " + source |
53 |
|
elif re.search('/pnfs/cmsaf.mit.edu/',source): |
54 |
|
debugPrint(' Identified tier-2 file') |
55 |
< |
cmd = 'ssh -x paus@cgate.mit.edu rm -rf ' + source |
55 |
> |
cmd = 'ssh ' + t2user + '@cgate.mit.edu rm -rf ' + source |
56 |
|
elif re.search('/mnt/hadoop/cms/store/user/paus',source): |
57 |
|
debugPrint(' Identified a tier-2 hadoop directory: ' + source) |
58 |
|
source = srm.convertToUrl(source,debug) |