ViewVC Help

View File | Revision Log | Show Annotations | Root Listing

root/cvsroot/UserCode/MitProd/Processing/bin/remove

Comparing UserCode/MitProd/Processing/bin/remove (file contents):
Revision 1.5 by paus, Tue Feb 28 11:54:36 2012 UTC vs.
Revision 1.8 by paus, Fri Jan 18 22:55:25 2013 UTC

#	Line 5 | Line 5
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:
#	Line 29 | Line 30 | def exists(target):
30		if   re.search('/castor/cern.ch/',target):
31		debugPrint(' Identified a castor directory: ' + target)
32		cmd = 'rfdir ' + target
32	–	elif re.search('/pnfs/cmsaf.mit.edu/',target):
33	–	debugPrint(' Identified a tier-2 directory: ' + target)
34	–	cmd = 'ssh -x paus@cgate.mit.edu ls -1 ' + target + ' \>\& /dev/null'
33		elif re.search('/mnt/hadoop/cms/store',target):
34		debugPrint(' Identified a tier-2 hadoop directory: ' + target)
35		target = srm.convertToUrl(target,debug)
#	Line 49 | Line 47 | def remove(source):
47		if   re.search('/castor/cern.ch/',source):
48		debugPrint(' Identified castor file')
49		cmd = "stager_rm -M " + source + "; nsrm " + source
52	–	elif re.search('/pnfs/cmsaf.mit.edu/',source):
53	–	debugPrint(' Identified tier-2 file')
54	–	cmd = 'ssh -x paus@cgate.mit.edu rm -rf ' + source
50		elif re.search('/mnt/hadoop/cms/store/user/paus',source):
51		debugPrint(' Identified a tier-2 hadoop directory: ' + source)
52	<	source = srm.convertToUrl(source,debug)
53	<	cmd = 'srmrm ' + source + ' >& /dev/null'
52	>	#source = srm.convertToUrl(source,debug)
53	>	#cmd = 'srmrm ' + source + ' >& /dev/null'
54	>	cmd = 'glexec rm ' + source
55		else:
56		debugPrint(' Identified a normal directory')
57		cmd = 'rm -rf ' + source
#	Line 77 | Line 73 | def removeCatalog(source,debug):
73		catalogDir = '/home/cmsprod/catalog/local'
74		if   re.search('/castor/cern.ch/',source):
75		catalogDir = '/home/cmsprod/catalog/cern'
76	<	elif re.search('/pnfs/cmsaf.mit.edu/',source) or \
81	<	re.search('/mnt/hadoop/cms/store/user/paus',source):
76	>	elif re.search('/mnt/hadoop/cms/store/user/paus',source):
77		catalogDir = '/home/cmsprod/catalog/t2mit'
78		# now get the dataset and the book
79		f       = source.split('/')

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines