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 java.util.Map<FileServerType.OPERATION,java.util.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 java.util.List<FileServerType.OPERATION> |
FileServerType.OPERATION.mGetOperations |
private static java.util.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(java.lang.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 java.util.Collection<FileServerType.OPERATION> |
FileServerType.OPERATION.operationsFor(FileServerType.OPERATION operation)
Returns a collection of operations corresponding to a get or put operation
|
static java.util.Collection<FileServerType.OPERATION> |
FileServerType.OPERATION.operationsForGET()
Returns a collection of get operations.
|
static java.util.Collection<FileServerType.OPERATION> |
FileServerType.OPERATION.operationsForPUT()
Returns a collection of get operations.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
SiteStore.getExternalWorkDirectoryURL(java.lang.String siteHandle,
FileServerType.OPERATION operation)
Returns a URL to the work directory as seen externally ( including external
mount point ).
|
java.util.List<FileServer> |
DirectoryLayout.getFileServers(FileServerType.OPERATION operation)
Selects all file servers and returns it matching an operation type.
|
java.util.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 java.util.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.
|
java.lang.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(java.util.Map<FileServerType.OPERATION,java.util.List<FileServer>> fs,
InternalMountPoint imt)
Initializes the object
|
Constructor and Description |
---|
DirectoryLayout(java.util.Map<FileServerType.OPERATION,java.util.List<FileServer>> fs,
InternalMountPoint imt)
The overloaded constructor
|
LocalDirectory(java.util.Map<FileServerType.OPERATION,java.util.List<FileServer>> fs,
InternalMountPoint imt)
The overloaded constructor
|
SharedDirectory(java.util.Map<FileServerType.OPERATION,java.util.List<FileServer>> fs,
InternalMountPoint imt)
The overloaded constructor
|
WorkerSharedDirectory(java.util.Map<FileServerType.OPERATION,java.util.List<FileServer>> fs,
InternalMountPoint imt)
The overloaded constructor
|
Modifier and Type | Method and Description |
---|---|
private java.lang.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(java.lang.String lfn,
java.lang.String pfn,
java.lang.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(java.lang.String lfn,
FileServerType.OPERATION type)
Retrieves all entries for a given LFN from the replica catalog.
|
java.lang.String |
PlannerCache.lookup(java.lang.String lfn,
java.lang.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(java.lang.String refiner,
java.lang.String site,
FileServerType.OPERATION operation)
Complains for head node url prefix not specified
|
protected void |
Engine.complainForHeadNodeURLPrefix(java.lang.String refiner,
java.lang.String site,
FileServerType.OPERATION operation,
Job job)
Complains for head node url prefix not specified
|
private void |
TransferEngine.complainForScratchFileServer(Job job,
FileServerType.OPERATION operation,
java.lang.String site)
Complains for a missing head node file server on a site for a job
|
private void |
TransferEngine.complainForScratchFileServer(java.lang.String jobname,
FileServerType.OPERATION operation,
java.lang.String site)
Complains for a missing head node file server on a site for a job
|
private java.lang.String |
TransferEngine.getURLOnSharedScratch(SiteCatalogEntry entry,
Job job,
FileServerType.OPERATION operation,
java.lang.String lfn)
Returns a URL on the shared scratch of the staging site
|
private void |
TransferEngine.trackInPlannerCache(java.lang.String lfn,
java.lang.String pfn,
java.lang.String site,
FileServerType.OPERATION type)
Inserts an entry into the planner cache as a put URL.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
OutputMapper.map(java.lang.String lfn,
java.lang.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.
|
java.lang.String |
OutputMapper.map(java.lang.String lfn,
java.lang.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.
|
java.util.List<java.lang.String> |
OutputMapper.mapAll(java.lang.String lfn,
java.lang.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,
java.lang.String site)
Complains for a missing head node storage file server on a site for a job
|
java.lang.String |
Replica.map(java.lang.String lfn,
java.lang.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.
|
java.lang.String |
Fixed.map(java.lang.String lfn,
java.lang.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.
|
java.lang.String |
AbstractFileFactoryBasedMapper.map(java.lang.String lfn,
java.lang.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.
|
java.lang.String |
Replica.map(java.lang.String lfn,
java.lang.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.
|
java.lang.String |
Fixed.map(java.lang.String lfn,
java.lang.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.
|
java.lang.String |
AbstractFileFactoryBasedMapper.map(java.lang.String lfn,
java.lang.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.
|
java.util.List<java.lang.String> |
Replica.mapAll(java.lang.String lfn,
java.lang.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.
|
java.util.List<java.lang.String> |
Fixed.mapAll(java.lang.String lfn,
java.lang.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.
|
java.util.List<java.lang.String> |
AbstractFileFactoryBasedMapper.mapAll(java.lang.String lfn,
java.lang.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.
|