| 8 |
|
from ProdCommon.Storage.SEAPI.SElement import SElement, FullPath |
| 9 |
|
from ProdCommon.Storage.SEAPI.SBinterface import * |
| 10 |
|
from ProdCommon.Storage.SEAPI.Exceptions import * |
| 11 |
+ |
from ProdCommon.FwkJobRep.SiteLocalConfig import loadSiteLocalConfig |
| 12 |
+ |
|
| 13 |
|
|
| 14 |
|
|
| 15 |
|
class cmscp: |
| 181 |
|
## here we can add support for any kind of protocol, |
| 182 |
|
## maybe some local schedulers need something dedicated |
| 183 |
|
pass |
| 184 |
+ |
|
| 185 |
+ |
# force lstore protocol for Vanderbilt, waiting for better |
| 186 |
+ |
# long term solution |
| 187 |
+ |
if os.path.exists('/usr/local/cms-stageout') and \ |
| 188 |
+ |
( os.uname()[1].endswith('.vampire') or \ |
| 189 |
+ |
os.uname()[1].endwith('vanderbilt.edu') ): |
| 190 |
+ |
print "*** I am at Vanderbilt. Trying lstore first ***" |
| 191 |
+ |
supported_protocol.insert(0, ('lstore','') ) |
| 192 |
+ |
|
| 193 |
|
return supported_protocol |
| 194 |
|
|
| 195 |
|
|
| 471 |
|
return results |
| 472 |
|
|
| 473 |
|
self.hostname = Destination_SE.hostname |
| 474 |
< |
if Destination_SE.protocol in ['gridftp','rfio','srmv2','hadoop','local']: |
| 474 |
> |
if Destination_SE.protocol in ['gridftp','rfio','srmv2','hadoop','lstore','local']: |
| 475 |
|
try: |
| 476 |
|
self.createDir( Destination_SE, Destination_SE.protocol ) |
| 477 |
|
except OperationException, ex: |
