Package | Description |
---|---|
edu.isi.pegasus.planner.catalog.site.classes | |
edu.isi.pegasus.planner.transfer | |
edu.isi.pegasus.planner.transfer.mapper.impl | |
edu.isi.pegasus.planner.transfer.sls |
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
FileServer |
SiteCatalogEntry.selectStorageFileServerForStageout(FileServerType.OPERATION operation)
A convenience method that selects a file server for staging the data out to
a site.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
DirectoryLayout.addFileServer(FileServer server)
Adds a FileServer that can access this directory.
|
void |
XML3PrintVisitor.depart(FileServer server)
Depart the Directory object
|
void |
XML4PrintVisitor.depart(FileServer server)
Depart the Directory object
|
void |
SiteDataVisitor.depart(FileServer server)
Depart the Directory object
|
java.lang.String |
SiteStore.getExternalWorkDirectory(FileServer fs,
java.lang.String siteHandle)
Return the work directory as seen externally (including external mount point)
|
java.lang.String |
SiteStore.getExternalWorkDirectoryURL(FileServer server,
java.lang.String siteHandle)
Returns a URL to the work directory as seen externally ( including external
mount point ).
|
void |
XML3PrintVisitor.visit(FileServer server)
Visit FileServer site data object
|
void |
XML4PrintVisitor.visit(FileServer server)
Visit FileServer site data object
|
void |
SiteDataVisitor.visit(FileServer server)
Visit FileServer site data object
|
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
|
void |
DirectoryLayout.setFileServers(java.util.List<FileServer> servers)
Sets the list of FileServers that can access this directory.
|
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 |
---|---|
java.util.Collection<FileTransfer> |
SLS.determineSLSInputTransfers(Job job,
java.lang.String fileName,
FileServer stagingSiteServer,
java.lang.String stagingSiteDirectory,
java.lang.String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node
directory.
|
java.util.Collection<FileTransfer> |
SLS.determineSLSOutputTransfers(Job job,
java.lang.String fileName,
FileServer stagingSiteServer,
java.lang.String stagingSiteDirectory,
java.lang.String workerNodeDirectory)
Generates a second level staging file of the input files to the worker node
directory.
|
Modifier and Type | Method and Description |
---|---|
protected java.lang.String |
AbstractFileFactoryBasedMapper.constructURL(FileServer server,
java.lang.String addOn)
Returns the full path on remote output site, where the lfn will reside,
using the FileServer passed.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<FileTransfer> |
Transfer.determineSLSInputTransfers(Job job,
java.lang.String fileName,
FileServer stagingSiteServer,
java.lang.String stagingSiteDirectory,
java.lang.String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory.
|
java.util.Collection<FileTransfer> |
Condor.determineSLSInputTransfers(Job job,
java.lang.String fileName,
FileServer stagingSiteServer,
java.lang.String stagingSiteDirectory,
java.lang.String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory.
|
java.util.Collection<FileTransfer> |
Transfer.determineSLSOutputTransfers(Job job,
java.lang.String fileName,
FileServer stagingSiteServer,
java.lang.String stagingSiteDirectory,
java.lang.String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory.
|
java.util.Collection<FileTransfer> |
Condor.determineSLSOutputTransfers(Job job,
java.lang.String fileName,
FileServer stagingSiteServer,
java.lang.String stagingSiteDirectory,
java.lang.String workerNodeDirectory)
Generates a second level staging file of the input files to the worker
node directory.
|