| 133 |
|
deltaT = 0 |
| 134 |
|
print ' working on file: ' + file + ' to ' + localDir + \ |
| 135 |
|
' (size: %d MB) '%(int(size)/1024/1024) |
| 136 |
< |
if storageEle == 'srm-cms.cern.ch': |
| 136 |
> |
if storageEle == 'srm-cms.cern.ch': |
| 137 |
|
f = storagePath.split("="); |
| 138 |
|
rfPath = f[-1] |
| 139 |
|
cpy = 'rfcp ' + rfPath + '/' + file + ' ' + localPath + '/' \ |
| 140 |
|
+ mitCfg + '/' + version + '/' + mitDataset + '/' + file |
| 141 |
|
#print ' using rfcp.... ' + cpy |
| 142 |
|
#sys.exit(0) |
| 143 |
+ |
elif storageEle == 'se01.cmsaf.mit.edu': |
| 144 |
+ |
f = storagePath.split("="); |
| 145 |
+ |
rfPath = f[-1] |
| 146 |
+ |
#cpy = 'scp paus@cgate.mit.edu:' + rfPath + '/' + file + ' ' + localPath + '/' \ |
| 147 |
+ |
# + mitCfg + '/' + version + '/' + mitDataset + '/' + file |
| 148 |
+ |
cpy = 'dccp dcap://t2srv0005.cmsaf.mit.edu/' \ |
| 149 |
+ |
+ rfPath + '/' + file + ' ' + localPath + '/' \ |
| 150 |
+ |
+ mitCfg + '/' + version + '/' + mitDataset + '/' + file |
| 151 |
+ |
#print ' using rfcp.... ' + cpy |
| 152 |
+ |
#sys.exit(0) |
| 153 |
|
else: |
| 154 |
|
#storageUrl = 'srm://' + storageEle + ':8443' + storagePath |
| 155 |
|
cpy = 'lcg-cp ' + storageUrl + '/' + file + ' file:////' + localPath + '/' \ |
| 271 |
|
cmd = '--cmsDataset option not provided. This is required.' |
| 272 |
|
raise RuntimeError, cmd |
| 273 |
|
|
| 274 |
< |
crabFile = mitCfg + '/' + version + '/' + 'crab.cfg' |
| 274 |
> |
crabFile = os.environ['MIT_PROD_DIR'] + '/' + mitCfg + '/' + version + '/' + 'crab.cfg' |
| 275 |
|
if not os.path.exists(crabFile): |
| 276 |
|
cmd = 'Crab file not found: %s' % crabFile |
| 277 |
|
raise RuntimeError, cmd |
| 278 |
< |
cmsswFile = mitCfg + '/' + version + '/' + cmsswCfg |
| 278 |
> |
cmsswFile = os.environ['MIT_PROD_DIR'] + '/' + mitCfg + '/' + version + '/' + cmsswCfg |
| 279 |
|
if not os.path.exists(cmsswFile): |
| 280 |
|
cmd = 'Cmssw file not found: %s' % cmsswFile |
| 281 |
|
cmsswCfg = 'cmssw.py' |
| 282 |
< |
cmsswFile = mitCfg + '/' + version + '/' + cmsswCfg |
| 282 |
> |
cmsswFile = os.environ['MIT_PROD_DIR'] + '/' + mitCfg + '/' + version + '/' + cmsswCfg |
| 283 |
|
if not os.path.exists(cmsswFile): |
| 284 |
|
cmd = 'Cmssw file not found: %s' % cmsswFile |
| 285 |
|
cmd = ' XXXX ERROR no valid configuration found XXXX' |
| 286 |
|
raise RuntimeError, cmd |
| 287 |
|
|
| 288 |
|
# Resolve the other mitCfg parameters from the configuration file |
| 289 |
< |
cmd = 'cat ' + mitCfg + '/' + version + '/' + 'Productions' |
| 289 |
> |
cmd = 'cat ' + os.environ['MIT_PROD_DIR'] + '/' + mitCfg + '/' + version + '/' + 'Productions' |
| 290 |
|
if cmssw != '': |
| 291 |
|
cmd = cmd + '.' + cmssw |
| 292 |
|
|
| 358 |
|
pMitCfg = re.compile('XX-MITCFG-XX') |
| 359 |
|
pMitVers = re.compile('XX-MITVERSION-XX') |
| 360 |
|
# find the forseen storage place |
| 361 |
< |
crabFile = mitCfg + '/' + version + '/' + 'crab.cfg' |
| 361 |
> |
crabFile = os.environ['MIT_PROD_DIR'] + '/' + mitCfg + '/' + version + '/' + 'crab.cfg' |
| 362 |
|
cmd = 'grep ^storage_element ' + crabFile |
| 363 |
|
for file in os.popen(cmd).readlines(): # run command |
| 364 |
|
line = file[:-1] # strip '\n' |
