org.ow2.proactive.scheduler.task.data

Class TaskProActiveDataspaces

java.lang.Object

org.ow2.proactive.scheduler.task.data.TaskProActiveDataspaces

All Implemented Interfaces:

Serializable, TaskDataspaces

public class TaskProActiveDataspaces
extends Object
implements TaskDataspaces

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	PA_NODE_DATASPACE_CREATE_FOLDER_HIERARCHY_SEQUENTIALLY
static String	PA_NODE_DATASPACE_FILE_TRANSFER_THREAD_POOL_SIZE

Constructor Summary

Constructors

Constructor and Description
TaskProActiveDataspaces(TaskId taskId, org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService namingService, boolean isRunAsUser)

Method Summary

Modifier and Type	Method and Description
void	close()
void	copyInputDataToScratch(List<InputSelector> inputSelectors)
void	copyScratchDataToOutput(List<OutputSelector> outputSelectors)
protected void	createFolderHierarchy(boolean isDebugEnabled, org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject fileObject, org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject target)
protected void	createFolderHierarchySequentially(org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject destination, String spaceUri, List<org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject> spaceFiles, Map<String,org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject> filesToCopy)
String	getCacheURI()
protected int	getFileTransferThreadPoolSize()
String	getGlobalURI()
String	getInputURI()
String	getOutputURI()
File	getScratchFolder()
String	getScratchURI()
String	getUserURI()
protected void	handleResultsWhileTransferringFile(List<Future<Boolean>> transferFutures, String destinationSpaceName, long startTime)
protected boolean	isCreateFolderHierarchySequentiallyEnabled()
protected String	relativize(String inputSpaceUri, org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject fileObject)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PA_NODE_DATASPACE_FILE_TRANSFER_THREAD_POOL_SIZE

public static final String PA_NODE_DATASPACE_FILE_TRANSFER_THREAD_POOL_SIZE

See Also:

Constant Field Values

PA_NODE_DATASPACE_CREATE_FOLDER_HIERARCHY_SEQUENTIALLY

public static final String PA_NODE_DATASPACE_CREATE_FOLDER_HIERARCHY_SEQUENTIALLY

See Also:

Constant Field Values

Constructor Detail

TaskProActiveDataspaces

public TaskProActiveDataspaces(TaskId taskId,
                               org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService namingService,
                               boolean isRunAsUser)
                        throws Exception

Throws:

Exception

Method Detail

getFileTransferThreadPoolSize

protected int getFileTransferThreadPoolSize()

getScratchFolder

public File getScratchFolder()

Specified by:

getScratchFolder in interface TaskDataspaces

getScratchURI

public String getScratchURI()

Specified by:

getScratchURI in interface TaskDataspaces

getCacheURI

public String getCacheURI()

Specified by:

getCacheURI in interface TaskDataspaces

getInputURI

public String getInputURI()

Specified by:

getInputURI in interface TaskDataspaces

getOutputURI

public String getOutputURI()

Specified by:

getOutputURI in interface TaskDataspaces

getUserURI

public String getUserURI()

Specified by:

getUserURI in interface TaskDataspaces

getGlobalURI

public String getGlobalURI()

Specified by:

getGlobalURI in interface TaskDataspaces

copyInputDataToScratch

public void copyInputDataToScratch(List<InputSelector> inputSelectors)
                            throws org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException,
                                   InterruptedException

Specified by:

copyInputDataToScratch in interface TaskDataspaces

Throws:

org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

InterruptedException

createFolderHierarchySequentially

protected void createFolderHierarchySequentially(org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject destination,
                                                 String spaceUri,
                                                 List<org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject> spaceFiles,
                                                 Map<String,org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject> filesToCopy)
                                          throws org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

Throws:

org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

createFolderHierarchy

protected void createFolderHierarchy(boolean isDebugEnabled,
                                     org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject fileObject,
                                     org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject target)
                              throws org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

Throws:

org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

isCreateFolderHierarchySequentiallyEnabled

protected boolean isCreateFolderHierarchySequentiallyEnabled()

handleResultsWhileTransferringFile

protected void handleResultsWhileTransferringFile(List<Future<Boolean>> transferFutures,
                                                  String destinationSpaceName,
                                                  long startTime)
                                           throws org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

Throws:

org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

relativize

protected String relativize(String inputSpaceUri,
                            org.objectweb.proactive.extensions.dataspaces.api.DataSpacesFileObject fileObject)

copyScratchDataToOutput

public void copyScratchDataToOutput(List<OutputSelector> outputSelectors)
                             throws org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

Specified by:

copyScratchDataToOutput in interface TaskDataspaces

Throws:

org.objectweb.proactive.extensions.dataspaces.exceptions.FileSystemException

close

public void close()

Specified by:

close in interface TaskDataspaces