A B C D E F G H I J K L M N P Q R S T U V W X Z

G

generateAccountingInfo(String, String, long, List<NodeAcct>) - Method in class tassl.workflow.resources.Resource

Generate the accounting information of a stage.

generateAccountingInfo(String, String, long, List<NodeAcct>) - Method in class tassl.workflow.resources.ResourceCloud

generateAccountingInfo(String, String, long, List<NodeAcct>) - Method in class tassl.workflow.resources.ResourceCluster

generatePreviousResultFiles(String, List) - Method in class tassl.application.cometcloud.GenerateTasksAbstract

Get result files of the previous stages that had dependencies with the current one This is assuming that ALL Results of previous stages are FileProperties objects

generatePreviousResultFilesStageId(String) - Method in class tassl.application.cometcloud.GenerateTasksAbstract

Get result files of a specific previous stage This is assuming that ALL Results of previous stages are FileProperties objects

GenerateTasks - Class in tassl.application.cometcloud.sample

This code is a simple map/reduce application.

GenerateTasks() - Constructor for class tassl.application.cometcloud.sample.GenerateTasks

GenerateTasks - Class in tassl.application.cometcloud.sampleLoop

GenerateTasks() - Constructor for class tassl.application.cometcloud.sampleLoop.GenerateTasks

GenerateTasks - Class in tassl.application.cometcloud.sampleNonBlocking

This code is an application that has multiple stages.

GenerateTasks() - Constructor for class tassl.application.cometcloud.sampleNonBlocking.GenerateTasks

generateTasks() - Method in class tassl.application.cometcloud.WorkflowMaster

This method is called to read the application properties and initiate the tasks creation.

GenerateTasksAbstract - Class in tassl.application.cometcloud

GenerateTasksAbstract() - Constructor for class tassl.application.cometcloud.GenerateTasksAbstract

GenerateTasksMontage - Class in tassl.application.cometcloud.sampleMontage

GenerateTasksMontage() - Constructor for class tassl.application.cometcloud.sampleMontage.GenerateTasksMontage

GenerateTasksObject - Class in tassl.application.cometcloud

GenerateTasksObject() - Constructor for class tassl.application.cometcloud.GenerateTasksObject

GenerateTasksObject(List<List>, List<String>, List<Double>, List<Double>, List<List<FileProperties>>, List<List<FileProperties>>) - Constructor for class tassl.application.cometcloud.GenerateTasksObject

genStage(List<FileProperties>, FileProperties, String, HashMap, String, String) - Method in class tassl.application.cometcloud.sampleMontage.GenerateTasksMontage

genStageConcatModel(List<FileProperties>, FileProperties, String, HashMap, String, String) - Method in class tassl.application.cometcloud.sampleMontage.GenerateTasksMontage

genStageFinal(List<FileProperties>, FileProperties, String, HashMap, String, String) - Method in class tassl.application.cometcloud.sampleMontage.GenerateTasksMontage

getActiveResourcesWorkflow() - Method in class tassl.workflow.resources.Resource

Get the list of active resources organized by workflowid.stageid

getActiveWorkers() - Method in class tassl.workflow.resources.Node

getAllAvailableSlots(String, String) - Method in class tassl.application.workflow.AutonomicScheduler

Look into available resources and determine the number of slots(workers) available.

getAllDoneTasks(String) - Method in class tassl.application.cometcloud.WorkflowMaster

Retrieve the ids of the tasks that have been completed.

getAllTaskProp() - Method in class tassl.workflow.WorkflowStage

Return the properties of all tasks composing a stage

getAppName() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getAppName() - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getAssignHours() - Method in class tassl.application.workflow.WorkerForScheduler

getAvailableSlotsScheduling(String, String[]) - Method in class tassl.workflow.resources.Resource

It creates the list of available slots for scheduling considering the workers per machine and the number of available machines.

getAvailableSlotsScheduling(String, String[]) - Method in class tassl.workflow.resources.ResourceCloud

getAvailableSlotsScheduling(String, String[]) - Method in class tassl.workflow.resources.ResourceCluster

getBalancedChordIDs(String) - Method in class tassl.application.InternalStarter

getCandidateTunnelPort(List) - Method in class tassl.workflow.resources.Resource

Return a port to use for the tunnel from Agent to Worker

getCloudScript() - Method in class tassl.workflow.resources.ResourceCloud

getCompletedStages() - Method in class tassl.workflow.Workflow

getConstraints() - Method in class tassl.application.cometcloud.FileProperties

List of sitenames and zones where the dataset can be moved

getCost() - Method in class tassl.application.workflow.WorkerForScheduler

getCost() - Method in class tassl.workflow.resources.Node

getCost() - Method in class tassl.workflow.resources.NodeAcct

getCostDataIn() - Method in class tassl.workflow.resources.Resource

getCostDataOut() - Method in class tassl.workflow.resources.Resource

getCurrentTasks() - Method in class tassl.application.cometcloud.AgentLite

getDataTransferTime() - Method in class tassl.application.cometcloud.AgentFileServer

getDefaultImageId() - Method in class tassl.workflow.resources.ResourceCloud

getDependencies() - Method in class tassl.workflow.WorkflowStage

getDestinationFiles(List<FileProperties>) - Method in class tassl.application.workflow.PolicyAbstract

getDoneTasks() - Method in class tassl.workflow.WorkflowStage

getDrtsPeer() - Method in class tassl.application.InternalStarter

getDurationStage() - Method in class tassl.workflow.WorkflowStage

Duration of the stage since it was ready to execute until it was completed

getEndTime() - Method in class tassl.workflow.WorkflowStage

Time in milliseconds

getExecutableStages() - Method in class tassl.workflow.Workflow

getFile(Boolean, String, List, String) - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

Retrieve input files to the local worker.

getFileserver() - Method in class tassl.application.cometcloud.AgentLite

getFileServerPort() - Method in class tassl.application.cometcloud.AgentLite

getFinalMap(HashMap<Integer, WorkerForScheduler>, String) - Method in class tassl.application.workflow.AutonomicScheduler

Return the number of machines and workers per site

getFreePort() - Method in class tassl.workflow.resources.Node

getId() - Method in class tassl.workflow.Workflow

getId() - Method in class tassl.workflow.WorkflowStage

getIdentifier() - Method in class tassl.workflow.resources.Resource

getImageId(String) - Method in class tassl.workflow.resources.ResourceCloud

Get the imageId of the custom VM image of an Application

getInitialTaskCount() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getInputList() - Method in class tassl.application.cometcloud.GenerateTasksObject

List of input files as objects of FileProperties

getInputs() - Method in class tassl.application.cometcloud.TaskProperties

getIp() - Method in class tassl.workflow.resources.NodeAcct

getIsUp() - Method in class tassl.workflow.resources.Node

getIterNumLoop(String) - Method in class tassl.workflow.WorkflowStage

Return the index number of the loop identified by idLoop

getKeyfile() - Method in class tassl.workflow.resources.Resource

getListTasks() - Method in class tassl.application.workflow.WorkerForScheduler

getListTasksSize() - Method in class tassl.application.workflow.WorkerForScheduler

getLocation() - Method in class tassl.application.cometcloud.FileProperties

URI of the dataset.

getLoops() - Method in class tassl.workflow.Workflow

getLoopsInvolved() - Method in class tassl.workflow.WorkflowStage

getLoopsOrder() - Method in class tassl.workflow.Workflow

getLoopsOrigName() - Method in class tassl.workflow.Workflow

getMachine_index() - Method in class tassl.application.workflow.WorkerForScheduler

getMachine_indexType() - Method in class tassl.application.workflow.WorkerForScheduler

getMapTask() - Method in class tassl.application.workflow.PolicyAbstract

getMasterPort() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getMaxPort() - Method in class tassl.workflow.resources.Node

getMaxTime() - Method in class tassl.application.cometcloud.GenerateTasksObject

Maximum time to execute in slowest proc

getMaxTime() - Method in class tassl.application.cometcloud.TaskProperties

Maximum time to execute in slowest proc

getMinPort() - Method in class tassl.workflow.resources.Node

getMinTime() - Method in class tassl.application.cometcloud.GenerateTasksObject

Minimum time to execute in slowest

getMinTime() - Method in class tassl.application.cometcloud.TaskProperties

Minimum time to execute in slowest proc

getName() - Method in class tassl.application.cometcloud.FileProperties

When the dataset refers to a file, this is the name of the file

getName() - Method in class tassl.workflow.resources.Node

getNestedLoops() - Method in class tassl.workflow.Workflow

getNewId(List<String>) - Method in class tassl.workflow.WorkflowStage

Generate Stage Id based on participant loops We assume that loopsOrder is only renamed at the beginning of workflow creation

getNodeList() - Method in class tassl.workflow.resources.Resource

Return the list of nodes of this site in the format "name or ip": Node

getNodeMap() - Method in class tassl.application.InternalStarter

getNonBlockingTransitions() - Method in class tassl.workflow.WorkflowStage

getNumberActiveWorkers(String) - Method in class tassl.workflow.resources.ResourceCluster

getNumCompletedStages() - Method in class tassl.workflow.Workflow

getNumStages() - Method in class tassl.workflow.Workflow

getObjectiveAddOnFromNonBlockingT() - Method in class tassl.workflow.WorkflowStage

Get objectives to be added due to Non-blocking transitions

getObjectiveType() - Method in class tassl.workflow.WorkflowStage

Return the objective type of this stage.

getObjectiveValue(String) - Method in class tassl.workflow.WorkflowStage

Get the objective value.

getObjectiveValueOriginal(String) - Method in class tassl.workflow.WorkflowStage

Get the original objective value.

getOriginFiles(List<FileProperties>) - Method in class tassl.application.workflow.PolicyAbstract

getOutput(String, int) - Static method in class tassl.application.utils.CommonUtils

Get a socket connection with address and port.

getOutputInput(String, int) - Static method in class tassl.application.utils.CommonUtils

Get a socket connection with address and port.

getOutputInput(String, int, boolean) - Static method in class tassl.application.utils.CommonUtils

Get a socket connection with address and port.

getOutputList() - Method in class tassl.application.cometcloud.GenerateTasksObject

List of output files as objects of FileProperties

getOutputs() - Method in class tassl.application.cometcloud.TaskProperties

getOverhead() - Method in class tassl.application.workflow.WorkerForScheduler

getOverhead() - Method in class tassl.workflow.resources.Resource

getPeer() - Method in class tassl.application.node.isolate.RequestHandlerWfl

getPeerIP() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getPerformance() - Method in class tassl.application.workflow.WorkerForScheduler

getPerformance() - Method in class tassl.workflow.resources.Node

getPolicies(String) - Method in class tassl.application.workflow.AutonomicScheduler

getPortMapWorker(String, int) - Method in class tassl.workflow.resources.Resource

getPreviousResults() - Method in class tassl.application.cometcloud.GenerateTasksAbstract

Get results from previous stages

getProperties() - Method in class tassl.workflow.WorkflowStage

getProperty(String, String) - Method in class tassl.application.cometcloud.GenerateTasksAbstract

getProperty(String) - Method in class tassl.application.cometcloud.GenerateTasksAbstract

getProviderConfigFile() - Method in class tassl.workflow.resources.ResourceCloud

getProviderType() - Method in class tassl.workflow.resources.ResourceCloud

getQuery() - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getQuery(String, String, String, String, String) - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getQuery(String, String, String, String, String, String) - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getReadyToExecute() - Method in class tassl.application.workflow.WorkerForScheduler

getRegion() - Method in class tassl.workflow.resources.ResourceCloud

getRelatedWorkflowsResults(String) - Method in class tassl.application.cometcloud.GenerateTasksAbstract

Get results of all stages of a related workflow id

getRequirement() - Method in class tassl.application.cometcloud.TaskProperties

getRequirement() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getRequirement() - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getResources() - Method in class tassl.application.cometcloud.AgentResourceManager

getResult() - Method in class tassl.application.cometcloud.Results

getResultAddress() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getResultList() - Method in class tassl.workflow.Workflow

getResults(String, String, String) - Method in class tassl.application.workflow.WorkflowClient

Get list of Result locations and retrieve them

getServiceObject() - Method in class tassl.application.InternalStarter

getServPort() - Method in class tassl.application.cometcloud.AgentLite

getServSock() - Method in class tassl.application.node.isolate.RequestHandlerWfl

getSiteAddress() - Method in class tassl.application.workflow.WorkerForScheduler

getSiteIdentifier() - Method in class tassl.application.workflow.WorkerForScheduler

getSitename() - Method in class tassl.application.cometcloud.FileProperties

Name of the site where the dataset is located

getSiteZone() - Method in class tassl.application.workflow.WorkerForScheduler

getSize() - Method in class tassl.application.cometcloud.FileProperties

When the dataset refers to a file, this is its size

getStage(String) - Method in class tassl.workflow.Workflow

getStageID() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getStageID() - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getStartTime() - Method in class tassl.workflow.resources.NodeAcct

getStartTime() - Method in class tassl.workflow.WorkflowStage

Time in milliseconds

getStatistics() - Method in class tassl.application.cometcloud.AgentFileServer

getStopTime() - Method in class tassl.workflow.resources.NodeAcct

getSupportedApps() - Method in class tassl.application.workflow.WorkflowClient

getSupportedApps() - Method in class tassl.application.workflow.WorkflowManager

getSupportedApps() - Method in class tassl.workflow.resources.Resource

getTask(int) - Method in class tassl.application.workflow.WorkerForScheduler

getTaskCost() - Method in class tassl.application.workflow.WorkerForScheduler

getTaskId() - Method in class tassl.application.cometcloud.Results

getTaskidS() - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getTaskParam() - Method in class tassl.application.cometcloud.TaskProperties

getTaskParams() - Method in class tassl.application.cometcloud.GenerateTasksObject

getTaskProp() - Method in class tassl.workflow.WorkflowStage

Return the properties of those tasks that need to be scheduled.

getTaskRequirement() - Method in class tassl.application.cometcloud.GenerateTasksObject

getTaskTuple(XmlTuple) - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getTaskTupleValues() - Method in class tassl.application.cometcloud.TaskProperties

getTemplateQuery() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getTotalWorkers() - Method in class tassl.workflow.resources.Node

getType() - Method in class tassl.workflow.resources.NodeAcct

getType_name() - Method in class tassl.application.workflow.WorkerForScheduler

getTypebyIp(String) - Method in class tassl.workflow.resources.ResourceCloud

Return the type of VM that corresponds to the ip or null if not found

getUserWorker() - Method in class tassl.workflow.resources.Resource

getVMAddressbyType(String, String, List<String>) - Method in class tassl.workflow.resources.ResourceCloud

Return list of addresses corresponding with VMs from those allocated to the specific stage

getVMLimits() - Method in class tassl.workflow.resources.ResourceCloud

getWflId() - Method in class tassl.workflow.WorkflowStage

getWflNode() - Method in class tassl.workflow.resources.Resource

Return nodes assigned to each workflow

getWflStageWorker(String) - Method in class tassl.workflow.resources.Resource

Return the workflowId.stageId where the worker is allocated worker ip:port

getWfManagerName() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getWfManagerName() - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getWkfStageId(int) - Method in class tassl.application.cometcloud.WorkflowMaster

Find stage that a task is part of

getWorker() - Method in class tassl.application.node.isolate.IsolatedWorker

getWorker_index() - Method in class tassl.application.workflow.WorkerForScheduler

getWorkerBasePropertyFile() - Method in class tassl.workflow.resources.Resource

getWorkerid() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getWorkersWorkflowStage(String, String) - Method in class tassl.workflow.resources.Resource

Return the workers allocated to a specific stage workflow

getWorkflowID() - Method in class tassl.application.cometcloud.WorkflowMeteorGenericWorker

getWorkflowID() - Method in class tassl.application.cometcloud.WorkflowTaskTuple

getWorkflowStages() - Method in class tassl.workflow.Workflow

Get stages that compose the workflow

getZone() - Method in class tassl.application.cometcloud.FileProperties

Zone where the dataset is located

getZone() - Method in class tassl.workflow.resources.Resource

globalResources - Variable in class tassl.application.workflow.PolicyAbstract