Modifier and Type | Field and Description |
---|---|
protected FileServerType.OPERATION |
FileServerType.mOperation
The operations supported by the file server
|
Modifier and Type | Field and Description |
---|---|
protected Map<FileServerType.OPERATION,List<FileServer>> |
DirectoryLayout.mFileServers
The list of file servers that can be used to write to access this directory
indexed by operation type.
|
private static List<FileServerType.OPERATION> |
FileServerType.OPERATION.mGetOperations |
private static List<FileServerType.OPERATION> |
FileServerType.OPERATION.mPutOperations |
Modifier and Type | Method and Description |
---|---|
FileServerType.OPERATION |
FileServerType.getSupportedOperation()
Returns the operation supported by the file server
|
static FileServerType.OPERATION |
FileServerType.OPERATION.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FileServerType.OPERATION[] |
FileServerType.OPERATION.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static Collection<FileServerType.OPERATION> |
FileServerType.OPERATION.operationsFor(FileServerType.OPERATION operation)
Returns a collection of operations corresponding to a get or put operation
|
static Collection<FileServerType.OPERATION> |
FileServerType.OPERATION.operationsForGET()
Returns a collection of get operations.
|
static Collection<FileServerType.OPERATION> |
FileServerType.OPERATION.operationsForPUT()
Returns a collection of get operations.
|
Modifier and Type | Method and Description |
---|---|
String |
SiteStore.getExternalWorkDirectoryURL(String siteHandle,
FileServerType.OPERATION operation)
Returns a URL to the work directory as seen externally ( including external
mount point ).
|
List<FileServer> |
DirectoryLayout.getFileServers(FileServerType.OPERATION operation)
Selects all file servers and returns it matching an operation type.
|
Iterator<FileServer> |
DirectoryLayout.getFileServersIterator(FileServerType.OPERATION operation)
Returns at iterator to the file servers.
|
boolean |
DirectoryLayout.hasFileServerForOperations(FileServerType.OPERATION operation)
A convenience method that retrieves whether the directory has a
file server for a particular operation.
|
static Collection<FileServerType.OPERATION> |
FileServerType.OPERATION.operationsFor(FileServerType.OPERATION operation)
Returns a collection of operations corresponding to a get or put operation
|
FileServer |
DirectoryLayout.selectFileServer(FileServerType.OPERATION operation)
Selects a random file server and returns it matching an operation type.
|
FileServer |
SiteCatalogEntry.selectHeadNodeScratchSharedFileServer(FileServerType.OPERATION operation)
A convenience method to select the FileServer for the shared scratch
space on the HeadNode.
|
String |
SiteCatalogEntry.selectHeadNodeScratchSharedFileServerURLPrefix(FileServerType.OPERATION operation)
Deprecated.
should be removed
|
FileServer |
SiteCatalogEntry.selectStorageFileServerForStageout(FileServerType.OPERATION operation)
A convenience method that selects a file server for staging the data out to
a site.
|
void |
FileServerType.setSupportedOperation(FileServerType.OPERATION operation)
The operation supported by the file server
|
Modifier and Type | Method and Description |
---|---|
private void |
DirectoryLayout.initialize(Map<FileServerType.OPERATION,List<FileServer>> fs,
InternalMountPoint imt)
Initializes the object
|
Constructor and Description |
---|
DirectoryLayout(Map<FileServerType.OPERATION,List<FileServer>> fs,
InternalMountPoint imt)
The overloaded constructor
|
LocalDirectory(Map<FileServerType.OPERATION,List<FileServer>> fs,
InternalMountPoint imt)
The overloaded constructor
|
SharedDirectory(Map<FileServerType.OPERATION,List<FileServer>> fs,
InternalMountPoint imt)
The overloaded constructor
|
WorkerSharedDirectory(Map<FileServerType.OPERATION,List<FileServer>> fs,
InternalMountPoint imt)
The overloaded constructor
|
Modifier and Type | Method and Description |
---|---|
private String |
PlannerCache.getCacheFileName(ADag adag,
FileServerType.OPERATION operation)
Constructs the basename to the cache file that is to be used
to log the transient files.
|
int |
PlannerCache.insert(String lfn,
String pfn,
String handle,
FileServerType.OPERATION type)
Inserts a new entry into the cache.
|
private ReplicaCatalog |
PlannerCache.intializeRCAsCache(ADag dag,
FileServerType.OPERATION type)
Initializes the transient replica catalog and returns a handle to it.
|
ReplicaCatalogEntry |
PlannerCache.lookup(String lfn,
FileServerType.OPERATION type)
Retrieves all entries for a given LFN from the replica catalog.
|
String |
PlannerCache.lookup(String lfn,
String handle,
FileServerType.OPERATION type)
Retrieves the entry for a given filename and resource handle from
the replica catalog.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Engine.complainForHeadNodeURLPrefix(String refiner,
String site,
FileServerType.OPERATION operation)
Complains for head node url prefix not specified
|
protected void |
Engine.complainForHeadNodeURLPrefix(String refiner,
String site,
FileServerType.OPERATION operation,
Job job)
Complains for head node url prefix not specified
|
private void |
TransferEngine.complainForScratchFileServer(Job job,
FileServerType.OPERATION operation,
String site)
Complains for a missing head node file server on a site for a job
|
private void |
TransferEngine.complainForScratchFileServer(String jobname,
FileServerType.OPERATION operation,
String site)
Complains for a missing head node file server on a site for a job
|
private String |
TransferEngine.getURLOnSharedScratch(SiteCatalogEntry entry,
Job job,
FileServerType.OPERATION operation,
String lfn)
Returns a URL on the shared scratch of the staging site
|
private void |
TransferEngine.trackInPlannerCache(String lfn,
String pfn,
String site,
FileServerType.OPERATION type)
Inserts an entry into the planner cache as a put URL.
|
Modifier and Type | Method and Description |
---|---|
String |
OutputMapper.map(String lfn,
String site,
FileServerType.OPERATION operation)
Maps a LFN to a location on the filsystem of a site and returns a single
externally accessible URL corresponding to that location.
|
String |
OutputMapper.map(String lfn,
String site,
FileServerType.OPERATION operation,
boolean existing)
Maps a LFN to a location on the filsystem of a site and returns a single
externally accessible URL corresponding to that location.
|
List<String> |
OutputMapper.mapAll(String lfn,
String site,
FileServerType.OPERATION operation)
Maps a LFN to a location on the filsystem of a site and returns all the possible
equivalent externally accessible URL corresponding to that location.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractFileFactoryBasedMapper.complainForStorageFileServer(FileServerType.OPERATION operation,
String site)
Complains for a missing head node storage file server on a site for a job
|
String |
Replica.map(String lfn,
String site,
FileServerType.OPERATION operation)
Maps a LFN to a location on the filsystem of a site and returns a single
externally accessible URL corresponding to that location.
|
String |
AbstractFileFactoryBasedMapper.map(String lfn,
String site,
FileServerType.OPERATION operation)
Maps a LFN to a location on the filsystem of a site and returns a single
externally accessible URL corresponding to that location.
|
String |
Fixed.map(String lfn,
String site,
FileServerType.OPERATION operation)
Maps a LFN to a location on the filsystem of a site and returns a single
externally accessible URL corresponding to that location.
|
String |
Replica.map(String lfn,
String site,
FileServerType.OPERATION operation,
boolean existing)
Maps a LFN to a location on the filsystem of a site and returns a single
externally accessible URL corresponding to that location.
|
String |
AbstractFileFactoryBasedMapper.map(String lfn,
String site,
FileServerType.OPERATION operation,
boolean existing)
Maps a LFN to a location on the filsystem of a site and returns a single
externally accessible URL corresponding to that location.
|
String |
Fixed.map(String lfn,
String site,
FileServerType.OPERATION operation,
boolean existing)
Maps a LFN to a location on the filsystem of a site and returns a single
externally accessible URL corresponding to that location.
|
List<String> |
Replica.mapAll(String lfn,
String site,
FileServerType.OPERATION operation)
Maps a LFN to a location on the filsystem of a site and returns all the possible
equivalent externally accessible URL corresponding to that location.
|
List<String> |
AbstractFileFactoryBasedMapper.mapAll(String lfn,
String site,
FileServerType.OPERATION operation)
Maps a LFN to a location on the filsystem of a site and returns all the possible
equivalent externally accessible URL corresponding to that location.
|
List<String> |
Fixed.mapAll(String lfn,
String site,
FileServerType.OPERATION operation)
Maps a LFN to a location on the filesystem of a site and returns all the possible
equivalent externally accessible URL corresponding to that location.
|