cgl.hpsearch.flow
Class FlowManager

java.lang.Object
  cgl.hpsearch.flow.FlowManager

All Implemented Interfaces:

SystemConstants

public class FlowManager

extends Object

implements SystemConstants

Rewritten TaskSchedulerEngine. The FlowManager manages all tasks in the same JVM and no distributed HPSearch engines are used for task distribution
Created on Oct 22, 2005

Author:

Harshawardhan Gadgil (hgadgil@grids.ucs.indiana.edu)

Field Summary

Fields inherited from interface cgl.hpsearch.common.SystemConstants

ABANDON_HANDLER, ABANDONED, BROKER_HOST, BROKER_PORT, BUF_SIZE, EOT, EXCEPTION, FAILURE, FILESEPARTOR, FLOW_LOGGING_MANAGER, FLOW_MANAGER, HPSEARCH_CONFIG, HPSEARCH_HOME, HPSEARCH_SHELL, HPSEARCH_WS, MARKER, NB_HOME, NB_PERFORMANCE_DATA_TOPIC, OS_TYPE, OS_UNIX, OS_WIN, PORT, PROTOCOL, READY, RESUME, RUNNING, SCRIPT_ARGS, SCRIPT_PATH, SHELLWS_PORT, START_HANDLER, STREAM_MARKER_DATA, STREAM_MARKER_EOF, STX, SUCCESS, SUSPEND, TASK_DEFINED, TASK_SCHEDULER_ENGINE, TASKSCHEDULER_AUTO_CONNECT_COMM_LINK, TASKSCHEDULER_ENGINE_COMM_LINK, THREAD_SLEEP_INTERVAL, UNKNOWN, WAITING, WSCONTEXT_RESULT_BIN, WSCONTEXT_SERVICE

Constructor Summary

FlowManager()

Method Summary

FlowHandler	getFlowHandler(String id) Returns the flowhandler corresponding to specified id
String[]	getFlows() Returns an array of all flowIDs
FlowHandler	registerFlow(String id, Vector flowComponents) Generates a new flow

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowManager

public FlowManager()

Method Detail

registerFlow

public FlowHandler registerFlow(String id,
                                Vector flowComponents)

Generates a new flow

Parameters:

flowComponents -

getFlows

public String[] getFlows()

Returns an array of all flowIDs

Returns:

getFlowHandler

public FlowHandler getFlowHandler(String id)

Returns the flowhandler corresponding to specified id

Parameters:

id - - id of the flow handler

Returns:

requested flow handler, NULL if none is found